详解一下RabbitMQ中的channel.Publish

函数定义（来自 github.com/streadway/amqp）

func (ch *Channel) Publish(exchange string,key string,mandatory bool,immediate bool,msg Publishing,
) error

这个方法的作用是：向指定的交换机 exchange 发送一条消息 msg，带上路由键 key。

参数名	类型	含义
exchange	string	指定要将消息发布到哪个 交换机（exchange）。可以是 “” 表示默认交换机。
key	string	路由键（routing key），根据交换机类型决定消息怎么路由。
mandatory	bool	是否强制投递。若为 true 且无法路由到队列，则会触发 Basic.Return（需要监听返回）。
immediate	bool	是否立即投递。很少使用，RabbitMQ 通常不支持，建议设为 false。
msg	Publishing	消息体及其元数据（headers、content-type、body等）

📦 msg（Publishing）结构

type Publishing struct {ContentType     stringContentEncoding stringDeliveryMode    uint8 // 1=非持久化 2=持久化Priority        uint8CorrelationId   stringReplyTo         stringExpiration      stringMessageId       stringTimestamp       time.TimeType            stringUserId          stringAppId           stringBody            []byteHeaders         Table
}

常用字段：
Body: 消息内容（[]byte）
ContentType: 比如 “application/json”，“text/plain”
DeliveryMode: 2 表示持久化消息，1 表示不持久化（内存中）
Headers: 自定义属性（可以设置 key-value）

✅ 使用示例：基本用法

body := "Hello RabbitMQ!"
err := channel.Publish("my-exchange", // exchange 这表示你要将消息发布到一个叫 "my-exchange" 的交换机。"my-key",      // routing key 会被用于匹配绑定在交换机上的队列。false,         // mandatory 如果消息无法路由到队列，不返回任何信息。false,         // immediate 不要求立即投递（几乎总是 false）。amqp.Publishing{ ContentType: "text/plain",Body:        []byte(body), //消息正文，以字节形式传递。DeliveryMode: amqp.Persistent, // 2 = 持久化},
)
if err != nil {log.Fatalf("Publish failed: %s", err)
}

通俗的讲一下mandatory和immediate两个参数及其应用场景

参数	通俗解释
mandatory	“找不到接收方要告诉我”（确保消息不被悄悄丢掉）
immediate	“没有消费者就别投了”（对方不在线就别发）

err := ch.Publish("logs", "debug.key",true,  // mandatoryfalse,msg,
)

结果：
如果没有任何队列绑定了 “logs” 交换机并匹配 “debug.key”，这条消息就会被退回来，你可以通过监听 channel.NotifyReturn() 获取退回消息。

⚠️ 注意：RabbitMQ 早就不支持 immediate = true了！这个参数基本是“历史遗留”。几乎都设置为false
RabbitMQ 默认就不支持 immediate。 设置 immediate = true 会直接报错：“immediate=true” not supported

带 mandatory 回退处理机制的 RabbitMQ 生产者完整示例代码

✅ 功能概览
启动 RabbitMQ 连接与通道
使用 mandatory = true 发布消息
使用 NotifyReturn() 接收“退回的消息”
输出退回原因和消息内容

package mainimport ("log""time""github.com/streadway/amqp"
)func failOnError(err error, msg string) {if err != nil {log.Fatalf("%s: %s", msg, err)}
}func main() {// 连接 RabbitMQconn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")failOnError(err, "连接失败")defer conn.Close()ch, err := conn.Channel()failOnError(err, "打开通道失败")defer ch.Close()// 声明交换机（topic 类型）err = ch.ExchangeDeclare("my-exchange", // name"topic",       // typetrue,          // durablefalse,         // auto-deletedfalse,         // internalfalse,         // no-waitnil,           // arguments)failOnError(err, "声明交换机失败")// 设置 return 回退监听（必须在 Publish 之前设置）returns := ch.NotifyReturn(make(chan amqp.Return))// 模拟发送消息，但没有任何队列绑定这个 key → 消息将被退回err = ch.Publish("my-exchange", // exchange"unmatched.key", // routing keytrue,          // mandatory：要求通知投递失败false,         // immediate：RabbitMQ 不支持amqp.Publishing{ContentType:  "text/plain",Body:         []byte("This message will be returned"),DeliveryMode: amqp.Persistent,},)if err != nil {log.Printf("Publish error: %s", err)}// 检查是否被回退（注意：这是异步的）select {case ret := <-returns:log.Println("❗ 消息被退回！")log.Printf("原因：%s", ret.ReplyText)log.Printf("交换机：%s", ret.Exchange)log.Printf("路由键：%s", ret.RoutingKey)log.Printf("内容：%s", string(ret.Body))case <-time.After(2 * time.Second):log.Println("✅ 消息已成功路由（没有被退回）")}
}

🧪 测试说明
你不绑定任何队列到 my-exchange + unmatched.key，运行这段代码会看到：

❗ 消息被退回！
原因：NO_ROUTE
交换机：my-exchange
路由键：unmatched.key
内容：This message will be returned