Golang使用RabbitMQ执行Publish后连接自动关闭问题求助

1. 使用了已废弃的immediate参数 #

你调用Publish时第四个参数设置为了true，即开启了immediate模式：

err = k.outChannel.Publish(k.outExchangeName, "", true, true, amqp.Publishing{...})

该参数在RabbitMQ 3.0及以上版本已经被官方完全移除，服务端收到携带immediate=true的请求时，会直接返回错误并关闭当前Channel/连接，这是你单次Publish后连接自动断开的最直接原因。

2. 未处理mandatory模式下的消息退回 #

你同时开启了mandatory模式（第三个参数为true），该模式规则为：如果消息无法被路由到任何队列，RabbitMQ会将消息退回给生产者。你没有为Channel注册NotifyReturn回调处理退回的消息，RabbitMQ Go客户端收到未处理的退回消息时，也会主动关闭当前Channel/连接。
同时因为消息被直接退回，没有进入队列，所以消费者完全收不到任何数据，和你描述的现象完全匹配。

3. 连接状态管理逻辑缺失 #

你自定义的k.connected状态标识没有和实际连接状态绑定：

• 调用initOutConnection连接成功后，没有主动将k.connected设置为true
• 没有监听RabbitMQ提供的outConnection.NotifyClose()、outChannel.NotifyClose()关闭通知，连接被服务端断开时无法及时更新k.connected状态，导致状态判断逻辑不可靠。

1. 直接将Publish方法的immediate参数改为false，该参数已废弃，无任何使用价值，修改后即可解决连接被主动断开的问题。
2. 如果不需要消息退回能力，直接将mandatory参数也改为false，是成本最低的修复方案。如果确实需要使用mandatory能力，为Channel注册消息退回回调：

// 注册退回消息监听
returnChan := k.outChannel.NotifyReturn(make(chan amqp.Return, 10))
go func() {
    for ret := range returnChan {
        // 自定义处理退回消息的逻辑，比如记录日志、重试等
        fmt.Printf("消息退回: 原因=%s, 交换机=%s, 路由键=%s\n", ret.ReplyText, ret.Exchange, ret.RoutingKey)
    }
}()

3. 补充连接/Channel关闭事件监听，收到关闭通知时及时更新k.connected状态，触发重连逻辑。
4. 检查交换器绑定规则，确保你声明的fanout类型交换器已经和消费者的队列完成绑定，保证消息可以正常路由到队列。

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