Kratos框架未内置RabbitMQ支持，因其设计强调“显式依赖”和“最小抽象”，不提供类似Spring Boot的自动配置机制，所有连接、声明、消费逻辑需手动实现，包括连接池、重连、心跳、exchange/queue绑定及goroutine监听等。
Kratos 框架本身不内置 RabbitMQ 支持，必须手动集成 pika（Python）或 amqp（Go）等客户端库；直接套用 SpringBoot 那套 auto-configuration 会失败。
为什么 Kratos 没有现成的 RabbitMQ starter
Kratos 是 Go 语言微服务框架，设计上强调“显式依赖”和“最小抽象”——它不封装消息中间件，也不提供类似 Spring Boot 的 spring-boot-starter-amqp。所有连接、声明、消费逻辑都得你自己写，好处是可控性强，坏处是容易漏掉关键步骤。
常见误判是以为加个配置就能自动连上、自动声明队列，结果跑起来发现 channel.basic_publish 没报错但消费者收不到消息，或者程序启动就 panic：connection refused。
- kratos 并不管理
amqp.Connection生命周期，你得自己做连接池、重连、心跳 - 没有自动绑定 exchange/queue 的机制，
channel.queue_bind必须显式调用，否则消息静默丢弃 - kratos 的
app.Run不等待 consumer loop，如果没用 goroutine 启动监听，进程秒退
Go 中用 amqp/v2 连接 RabbitMQ 的最小可靠写法
别用已归档的 streadway/amqp，改用维护中的 github.com/rabbitmq/amqp091-go（即 amqp/v2），它修复了大量连接闪断、panic on close 等问题。
关键实操点：
- 连接参数必须设
amqp.Config{Heartbeat: 30}，否则 broker 默认 60s 无心跳就断连 - 声明 exchange 和 queue 时，
durable要一致开启：channel.ExchangeDeclare(..., durable: true)+channel.QueueDeclare(..., durable: true)，否则 broker 重启后队列消失，生产者继续发 → 消息 404 - 必须调
channel.QueueBind，哪怕 exchange 和 queue 名字完全匹配，不 bind 就路由失败 - 消费端用
channel.Consume后，立刻起 goroutine 执行for msg := range msgs { ... }，并在处理完调msg.Ack(false)；别用msg.AutoAck = true，否则崩溃时消息丢失
示例片段（非完整）：
conn, _ := amqp.Dial("amqp://guest:guest@localhost:5672/", amqp.WithConnectionHeartbeat(30))
ch, _ := conn.Channel()
ch.ExchangeDeclare("order.exchange", "topic", true, false, false, false, nil)
ch.QueueDeclare("inventory.queue", true, false, false, false, nil)
ch.QueueBind("inventory.queue", "order.created", "order.exchange", false, nil)
msgs, _ := ch.Consume("inventory.queue", "", false, false, false, false, nil)
go func() {
for msg := range msgs {
// 处理逻辑
msg.Ack(false) // 手动确认
}
}()
在 Kratos 的 wire.go 里怎么注入 RabbitMQ 实例
Kratos 依赖注入靠 Wire，不能把 *amqp.Connection 或 *amqp.Channel 直接塞进 provider 函数返回值里——它们不是线程安全的，多个 service 共享一个 channel 会 panic。
正确做法是：
- 只注入连接对象
*amqp.Connection，每个需要发消息的服务自己conn.Channel()获取新 channel - 消费者逻辑单独封装为
Consumer结构体，实现Start(ctx context.Context) error方法，在wire.Build中注册为func(*amqp.Connection) *Consumer - 在
app.New的app.WithServers之外，额外传入app.WithService(func(ctx context.Context, c *Consumer) error { return c.Start(ctx) })，确保 consumer loop 在 app.Run 期间持续运行
注意：不要在 Initialize 阶段就启动消费循环，否则 wire 初始化未完成就阻塞，整个 app 启不来。
最容易被忽略的三个点
一是 RabbitMQ 默认关闭远程 guest 登录，本地开发没问题，部署到 k8s 或 docker-compose 时，guest/guest 连不上，必须提前建用户并赋权；二是 amqp091-go 的 ExchangeDeclare 第二个参数是 exchangeType string，填 "direct" 而不是 amqp.DirectExchange（那是旧版常量）；三是消息体默认是 raw bytes，如果你用 JSON 发送，消费者端得自己 json.Unmarshal(msg.Body)，kratos 不会帮你反序列化。
