IllegalOperationError: Channel closed 是因在已关闭的 channel 上调用方法所致；amqplib 不自动重建，需监听 channel.on('close') 和 channel.on('error') 并手动重建，避免缓存失效 channel 引用。

为什么 IllegalOperationError: Channel closed 会突然出现

这不是连接断了，而是你试图在一个已经关闭的 channel 上调用方法，比如 channel.assertQueue()、channel.sendToQueue() 或 channel.consume()。amqplib 不会自动重建通道，一旦 channel.close() 被调用（显式或由服务端触发），该实例就永久失效。后续任何操作都会抛出这个错误。

channel.on('close') 和 channel.on('error') 必须监听

通道可能被 RabbitMQ 主动关闭（例如权限不足、交换机不存在、内存告警），也可能因网络闪断导致底层 socket 异常。不监听这两个事件，你就收不到关闭信号，还会继续往已失效的 channel 发请求。

• channel.on('close', () => console.log('通道被服务端关闭')) —— 明确告诉你它挂了，别再用了
• channel.on('error', err => console.error('通道级错误:', err.message)) —— 比如尝试绑定到不存在的 exchange，会在这里报 AMQPProtocolException，紧接着 channel 就被关
• 注意：connection.on('error') 不会捕获通道级错误，必须在每个 channel 实例上单独监听

修复代码：每次使用前检查 channel 状态 + 自动重建

不能依赖“创建一次用到底”，尤其在长连接消费者中。正确做法是封装一个可重试的通道获取函数，并在关键操作前做有效性判断。

async function getOrCreateChannel(connection) {
  if (!connection || connection.closed) return null;

  let channel = await connection.createChannel();
  
  // 必须监听，否则下次出错时你还不知道 channel 已废
  channel.on('close', () => {
    console.warn('Channel closed by server, will recreate on next use');
  });
  channel.on('error', (err) => {
    console.error('Channel error:', err.message);
  });

  return channel;
}

// 使用示例：发消息前确保 channel 可用
async function safePublish(channel, exchange, routingKey, msg) {
  if (!channel || channel.closed) {
    throw new Error('Channel is closed, cannot publish');
  }
  try {
    await channel.publish(exchange, routingKey, Buffer.from(msg));
  } catch (err) {
    if (err.message.includes('Channel closed')) {
      throw err; // 让上层决定是否重建
    }
    throw err;
  }
}

最容易被忽略的坑：忘记清理旧 channel 引用

你在全局缓存了一个 channel 变量，但它某次被 close 后，变量值没重置，后续逻辑仍直接使用它——这是最典型的触发点。Node.js 中没有弱引用机制，channel 实例不会自动被回收，也不会自我失效。

• 不要把 channel 存在模块顶层变量里长期持有
• 消费者循环中，每次处理消息前都应校验 channel.closed === false
• 如果用 channel.consume()，回调里拿到的 msg 是异步的，此时 channel 可能已在别处被关掉，务必在回调开头加防护