iris不内置消息队列，需用streadway/amqp（rabbitmq）、redis/go-redis（redis streams）或segmentio/kafka-go（kafka）独立集成；生产者应异步发送并检查error，消费者须与http服务分离启动并实现重连，配置应通过环境变量而非iris config管理。
Iris 本身不内置消息队列支持，必须通过第三方客户端库手动集成。选对客户端、避免阻塞主线程、正确管理连接生命周期，是对接成功的关键。
用哪个 Go 客户端连 RabbitMQ / Redis / Kafka？
不要试图用 Iris 的 iris.Context 或中间件封装队列逻辑——它不是消息处理框架。你需要独立的 Go 客户端：
- RabbitMQ：用
streadway/amqp（最稳定），别用已归档的go-amqplib - Redis：用
redis/go-redis（v9+），LPUSH/BRPOP可做简单队列，但生产环境建议用streams模式 - Kafka：用
segmentio/kafka-go（纯 Go，无 CGO 依赖），比confluent-kafka-go更轻量易部署
所有客户端都需在 main() 初始化并传入全局变量或依赖注入容器，而不是每次 HTTP 请求都新建连接。
如何在 Iris 路由里安全地发消息？
HTTP 请求生命周期短，不能在 handler 里同步等待消息发送结果（比如等 RabbitMQ 确认）。常见错误是直接调用 ch.Publish() 后不检查 error，或误以为返回即成功：
- 生产者侧：用
ch.Publish()发送后，立刻检查返回的error；若需强可靠性，开启ch.Confirm()并监听confirm.Select()通道 - 别在 handler 里做耗时操作：把消息体序列化后丢进内存 channel 或 goroutine 异步发，handler 立即返回 202 Accepted
- 示例关键片段：
go func() { err := amqpCh.Publish(...); if err != nil { log.Printf("publish fail: %v", err) } }()
消费者怎么和 Iris 应用共存而不冲突？
Iris 是 HTTP 服务，消息消费者是长运行后台任务，二者必须分离启动：
- 不要在
iris.Run()后写consumeFromQueue()—— 这行代码永远不会执行 - 正确做法：用
sync.WaitGroup同时启动 HTTP server 和 consumer goroutine，主 goroutine 阻塞等待信号退出 - 消费者内部必须重连机制：网络断开时，
amqp.Connection或kafka.Conn会失效，需捕获io.EOF或net.OpError后重建连接和 channel - 注意信号处理：收到
SIGINT时，先关闭 consumer 循环，再调用app.Shutdown()关 HTTP server
为什么用 Iris 的 config 包管不了队列配置？
iris.Configuration().GetString("amqp_url") 看似方便，但实际危险：
- 配置项如
amqp_url、redis_addr属于基础设施层，应和数据库连接串一样，通过环境变量（os.Getenv("RABBITMQ_URL")）或专用配置结构体加载 - Iris 的 config 默认只读取 JSON/TOML 文件，无法热更新；而队列连接参数变更（如切换集群地址）往往需要重启服务
- 更严重的是：如果 config 加载失败，Iris 会 panic 并退出整个进程，但你可能只想让消费者降级为本地内存队列（fallback）
真正该被 Iris config 管的，只有业务开关类参数，比如 enable_async_notification: true。
