NSQ生产者需全局复用nsq.Producer实例，避免每次请求新建导致连接耗尽；Consumer连lookupd须用TCP端口4160而非HTTP的4161；消息可靠性依赖多实例与幂等设计；组件启动顺序为nsqlookupd→nsqd→nsqadmin。
NSQ生产者别每次发消息都新建
Go里用nsq.Producer最常踩的坑，就是把nsq.NewProducer写在业务函数里——每来一次HTTP请求就建一个Producer，很快耗尽TCP连接、触发too many open files错误，甚至让nsqd拒绝新连接。
- Producer内部维护长连接和缓冲区，必须全局复用（比如作为服务结构体字段）
- 初始化后要显式调用
Connect()，否则Publish会静默失败或panic - 务必监听
Err()通道，网络抖动时它会吐出io: read/write timeout等错误，不处理就会卡死 - 异步发布用
PublishAsync时，回调函数里不能做阻塞操作，否则拖慢整个Producer的发送队列
示例关键片段：
cfg := nsq.NewConfig()
cfg.DialTimeout = 2 * time.Second
p, _ := nsq.NewProducer("127.00.1:4150", cfg)
p.Connect() // 必须加
go func() {
for err := range p.Err() {
log.Printf("producer error: %v", err) // 这里该告警或降级
}
}()Consumer连不上nsqlookupd？先检查地址和协议
Consumer启动后没收到消息，90%是ConnectToNSQLookupd失败但被忽略——它返回err但很多教程直接panic(err)，而实际线上环境更该记录日志并重试。
-
nsqlookupd默认监听tcp://127.0.0.1:4160，但Consumer的ConnectToNSQLookupd方法传的是HTTP端口4161，传错就永远连不上 - 如果
nsqd启用了--broadcast-address，Consumer通过lookupd发现节点时，拿到的是这个广播地址，不是127.0.0.1；本地开发不设广播地址，就别加--lookupd-tcp-address - Channel名不是可选参数：同一个Topic下，不同Channel彼此隔离，消息不会重复投递；测试时改了Channel名却忘了清空旧Channel，就会“收不到消息”
验证方式：浏览器打开http://127.0.0.1:4161，看/nodes是否列出你的nsqd实例。
立即学习“go语言免费学习笔记（深入）”；
消息丢了？检查Producer配置和ACK机制
NSQ不保证“最多一次”，也不提供Kafka那种acks=all语义，但它有隐式确认机制：Producer发完不报错 ≠ 消息已落盘。网络中断、nsqd崩溃、磁盘满都可能导致丢失。
-
Publish是同步阻塞调用，但只保证写入本地TCP缓冲区成功，不校验nsqd是否真正接收 - 想提高可靠性，必须搭配
nsqlookupd+ 多个nsqd实例，并在Consumer里实现幂等（比如用msg.ID去重） - 别依赖
msg.Attempts自动重试：NSQ默认最多重试100次，但重试间隔指数退避，卡在中间某次失败就停了 - 紧急场景下，可以用
PublishDeferred延时投递，但注意延迟时间单位是纳秒，传5 * time.Second要小心类型转换
nsqd和nsqadmin本地跑不起来？三个命令顺序不能错
NSQ不是“下载即用”，三个组件有强依赖顺序：必须先起nsqlookupd，再起nsqd并指定lookupd地址，最后起nsqadmin连lookupd的HTTP端口。
- 常见错误：
nsqd --lookupd-tcp-address=127.0.0.1:4161—— 端口写成HTTP的4161，实际应为TCP的4160 -
nsqadmin连不上？检查它连的是--lookupd-http-address=127.0.0.1:4161，不是4160 - 启动后访问
http://localhost:4171打不开？大概率nsqadmin根本没起来，用ps aux | grep nsq确认进程存在 - Mac上用Homebrew装的NSQ，二进制默认在
/opt/homebrew/bin/，PATH没配就执行不了命令
正确最小启动链：
nsqlookupd & nsqd --lookupd-tcp-address=127.0.0.1:4160 --broadcast-address=127.0.0.1 & nsqadmin --lookupd-http-address=127.0.0.1:4161 &
消息无序、不保证Exactly-Once、没有事务——这些不是bug，是NSQ的设计取舍。用之前得想清楚：你要的是快速解耦，还是强一致。
