调用amqplib的assertExchange后RabbitMQ发布消息到exchange仍报404如何解决

• 核心原因是amqplib的channel.assertExchange是异步返回Promise的方法，你的代码中没有添加await关键字等待该操作执行完成，就直接调用了channel.publish发布消息。此时exchange还没有被RabbitMQ服务端成功创建，因此触发了404不存在的错误。
• 次要可排查原因：如果之前已存在同名但类型不同的exchange、或连接配置的vhost权限不足、或通道在执行操作前已意外关闭，也可能触发同类报错，但从你给出的代码片段来看，异步未等待是最高概率的诱因。

1. 给assertExchange调用添加await关键字，确保exchange校验/创建完成后再执行消息发布，修改后的emit方法如下：

public async emit(eventName: string, data: any): Promise<void> {
  const event = {
    data,
    eventName
  };

  // 添加await等待异步操作完成
  await this.channel.assertExchange(eventName, 'fanout', { durable: false });

  const serializedData = JSON.stringify(event);
  this.channel.publish(eventName, '', Buffer.from(serializedData));
}

2. 补充错误捕获和通道异常处理逻辑：建议在初始化和发布逻辑中添加try/catch捕获异常，同时监听channel的close、error事件，实现通道断开后的自动重连逻辑，避免单次错误导致后续所有发布操作失效。
3. 性能优化（可选）：如果是高频发布场景，可以将已经校验过的exchange名称缓存到内存中，不需要每次发布都重复调用assertExchange，减少和RabbitMQ服务端的交互次数。
4. 配置校验：确认RabbitMQ连接字符串中的vhost配置正确，且连接使用的账号拥有对应vhost下的exchange创建、写入权限。

内容的提问来源于stack exchange，提问作者Erez Shlomo