本地开发优先用带缓冲的chan模拟队列，Docker起RabbitMQ（5672/15672端口）配合官方客户端，Go中复用amqp.Connection、配心跳、隔离Channel；Kafka需设RequiredAcks=WaitForAll、匹配Version、用ByteEncoder。
不需要一上来就装 Kafka 或 RabbitMQ —— 大部分本地开发、原型验证、单元测试，用 chan 就够了；真要对接真实 MQ，优先选 Docker 起服务 + 官方客户端库，别自己手写连接池或重连逻辑。
本地快速验证：用 chan 模拟队列，零依赖起步
适合单进程内解耦（比如 HTTP handler 触发异步任务）、写测试、理解生产/消费模型。它不是“真 MQ”，但能帮你跳过所有运维干扰，专注逻辑。
-
常见错误现象：
fatal error: all goroutines are asleep - deadlock，通常因为没开 goroutine 消费，或缓冲区满后生产者阻塞且没加超时 -
必须带缓冲：
jobs := make(chan string, 100)，否则无缓冲 channel 会同步阻塞，主流程直接卡死 -
消费者必须异步启动：
go func() { for job := range jobs { ... } }()，不能直接for range写在 main 里 -
加 context 控制生命周期：用
context.WithTimeout包裹消费循环，避免 goroutine 泄漏；别依赖defer关 channel ——close()要由生产者调，且只能 close 一次
Docker 起 RabbitMQ：5672 和 15672 端口别暴露错
这是最省心的开发环境起点。RabbitMQ 官方镜像自带管理界面，localhost:15672 可视化查队列、发测试消息，比命令行快得多。
-
启动命令必须含
-p 5672:5672和-p 15672:15672：前者是 AMQP 协议端口（Go 客户端连这里），后者是 Web 管理界面端口；少一个就等于没跑通 -
默认用户
guest/guest在 3.3+ 版本仅限localhost：如果你用 Docker Desktop on Mac/Windows，Go 程序在容器里运行时，得把地址改成host.docker.internal:5672，否则连不上 -
别跳过权限检查：
telnet localhost 5672或nc -zv localhost 5672先试连；防火墙、SELinux、Docker network 都可能静默拦截
Go 连 RabbitMQ：amqp.Dial 必须复用，Channel 必须隔离
反复 amqp.Dial() 是线上事故高发点 —— 连接数暴涨、端口耗尽、RabbitMQ 主动断连，全由此起。连接和 Channel 的生命周期管理，比业务逻辑还关键。
立即学习“go语言免费学习笔记（深入）”；
-
*amqp.Connection必须单例：全局只 dial 一次，封装成包级变量或 DI 注入；每次发消息都 dial，等于每秒创建 TCP 连接，撑不死 RabbitMQ 也会撑死自己 -
心跳必配：
amqp.Config{Heartbeat: 10 * time.Second}，否则云厂商 LB 或 K8s Service 会在空闲 30 秒后掐断连接，现象是“突然收不到消息”，日志却没报错 -
每个操作独立
conn.Channel()：Channel 不是线程安全的，跨 goroutine 复用会 panic；用完立刻ch.Close()，别想着“留着下次用” -
ch.QueueDeclare参数不能偷懒：durable: true（重启不丢元数据）、autoDelete: false（最后一个消费者退出不删队列）、exclusive: false（允许多实例共用）
对接 Kafka：Sarama 的 RequiredAcks 和 Version 别用默认值
Kafka 客户端配置错一个，就会出现“日志显示发送成功，但消息永远查不到”的静默失败。这不是 Go 语言的问题，是 Kafka 协议层语义太重。
-
config.Producer.RequiredAcks默认是sarama.NoResponse：Broker 收到请求就回包，不等写磁盘、也不等副本同步 —— 线上必须设为sarama.WaitForAll -
config.Version必须匹配 Kafka 服务端版本：比如 Kafka 3.6 用sarama.V3_6_0；配低了（如 V2_8_0_0）可能功能缺失，配高了直接报UNKNOWN_TOPIC_OR_PARTITION -
Topic 创建别用 shell 脚本：本地
kafka-topics.sh创建的 topic，在多节点集群中常分区不均；生产环境必须用sarama.NewClusterAdmin创建，它会校验 ISR 数、ReplicationFactor 是否合法 -
别用
sarama.StringEncoder传二进制数据：遇到\x00字节会截断；一律用sarama.ByteEncoder([]byte{})
真正难的不是写几行 Publish 或 Consume，而是搞清每个配置项背后的协议约束和运维边界 —— 比如 RabbitMQ 的 durable 只保队列元数据，消息是否持久还得看 DeliveryMode；Kafka 的 WaitForAll 要求 ISR ≥ 2，否则根本发不出去。这些细节不踩一遍坑，文档里根本不会写清楚。
