zmq4不是纯Go实现，而是对C版ZeroMQ 4.x的CGO封装，必须预先安装系统级libzmq并启用CGO；创建上下文后须defer ctx.Terminate()；REQ/REP需严格配对收发；PUB/SUB中SUB须先Connect再SetSubscribe；Send/Recv默认阻塞，需手动设超时。
ZeroMQ 在 Go 中需要 cgo 支持，不能纯 Go 编译
Go 的 github.com/pebbe/zmq4 是最常用的 ZeroMQ 绑定，但它底层调用 C 的 libzmq，所以构建时必须启用 cgo。如果你禁用了 cgo（比如设置了 CGO_ENABLED=0），编译会直接失败，报错类似：zmq4.go:12:2: cannot find package "C"。
确保环境满足以下条件：
- 系统已安装 libzmq 开发库（如 Ubuntu 上执行
sudo apt install libzmq3-dev；macOS 用brew install zeromq） -
CGO_ENABLED=1（默认开启，但交叉编译或某些 CI 环境可能关闭） - Go 版本 ≥ 1.16（
zmq4对较老版本支持不稳定）
用 zmq4.NewContext() 创建上下文，别在 goroutine 里反复 new
ZeroMQ 的 Context 是线程安全的、进程级资源，一个进程通常只需要一个。它管理底层 I/O 线程和 socket 生命周期。常见错误是每次发消息都 zmq4.NewContext() + ctx.NewSocket() + socket.Close() + ctx.Destroy()，这不仅慢，还可能触发文件描述符泄漏或 Address already in use 错误（尤其用 tcp://* 绑定时端口未及时释放）。
正确做法：
- 全局或包级初始化一次
ctx, _ := zmq4.NewContext() - 每个 socket 用完后显式调用
socket.Close()，但不要频繁销毁 context - 进程退出前调用
ctx.Destroy()（可配合os.Interrupt信号捕获）
示例片段：
ctx, _ := zmq4.NewContext() sock, _ := ctx.NewSocket(zmq4.REQ) defer sock.Close() // 不 defer ctx.Destroy()
选择 socket 类型要匹配通信模式，REQ/REP 必须严格配对
ZeroMQ 不是“发了就完”，而是靠 socket 类型强制交互契约。比如 REQ 发送后必须 Recv() 等待响应，否则下一次 Send() 会阻塞或 panic；REP 则必须先 Recv() 再 Send()。如果客户端用 REQ 而服务端用 PUB，连接能建，但消息永远收不到——ZeroMQ 不报错，只是静默丢弃。
典型搭配：
- 点对点请求-应答：client
REQ↔ serverREP - 一对多通知：server
PUB→ 多个 clientSUB（注意SUB默认不订阅任何主题，需调用SetSubscribe("")接收所有） - 任务分发：server
PUSH→ 多 workerPULL
调试时加超时避免卡死：sock.SetRcvTimeout(5000)（单位毫秒）
字符串消息要用 string([]byte) 转换，二进制数据直接传 []byte
ZeroMQ socket 的 Send() 和 Recv() 操作只接受 []byte。Go 字符串是只读的，直接 sock.Send([]byte(s), 0) 没问题，但反过来 data, _ := sock.Recv(0) 得到的是 []byte，若要转成字符串，得用 string(data)，而不是 string(*(*string)(unsafe.Pointer(&data))) 这类危险转换。
注意事项：
- UTF-8 安全：ZeroMQ 不关心编码，
string(data)是合法且零拷贝的（Go 1.22+ 更安全） - 大消息：避免把整个
[]byte塞进 channel 或长期持有，容易引发内存堆积 - 协议头：如需结构化通信，建议用
encoding/gob或protobuf序列化后发送，不要手拼字节
简单文本通信够用：
sock.Send([]byte("hello"), 0)
msg, _ := sock.Recv(0)
fmt.Println(string(msg))
进程间通信真正难的不是连通，而是异常路径：对端崩溃、网络中断、消息背压、序列化不一致。ZeroMQ 的 socket 类型和生命周期管理一旦写错，表现往往是“有时行有时不行”，排查起来比 TCP 连接更隐蔽。务必在启动阶段验证 socket 是否成功绑定/连接，并为每个 Send/Recv 加上超时和错误检查。 
