Python nng 的 Python 绑定体验

pip install nng失败因nng是c库，无官方pypi wheel；应装pynng（活跃、带预编译wheel），禁用已停更的nanomsg-python；pynng异步需async=true；sub0必须显式subscribe()才收消息；性能瓶颈多源于协议选型或超时/nagle等参数配置。

pip install nng 失败或找不到模块

根本原因不是 Python 绑定没维护，而是 nng 本身是 C 库，官方不提供 PyPI 上开箱即用的 wheel；你 pip 装的其实是第三方绑定 pynng 或 nanomsg-python（后者已停更），不是原生 nng 的 Python 接口。

实操建议：

• 优先用 pip install pynng —— 它是目前最活跃、支持 Python 3.8–3.12、自带预编译 wheel 的绑定，windows/macos/linux 都能直接装
• 如果要最新 nng C 库特性（比如 TLS、device 模式），得自己编译：先 git clone https://github.com/cjpatton/nng，mkdir build && cd build && cmake .. && make，再让 pynng 找到本地库路径（设 NNG_LIBRARY_PATH 环境变量）
• 别碰 nanomsg-python：它绑的是老版 nanomsg，和 nng 协议不兼容，连 nn_socket 和 nng_socket 都不是一回事

pynng 的异步 API 为什么总卡住或报 RuntimeError

pynng 默认走同步阻塞 I/O，但提供了 asyncio 支持——关键在 socket 创建时加 async=True，否则 arecv()/asend() 会直接抛 RuntimeError: not an async socket。

常见错误现象：

立即学习“Python免费学习笔记（深入）”；

• 调 await sock.arecv() 却没传 async=True → 报错
• 混用同步和异步方法（比如 sock.recv() 和 await sock.arecv() 在同一 socket）→ 行为未定义，可能死锁
• 在非 asyncio Event loop 环境里用 async socket（比如普通脚本里直接 await）→ loop not running

正确姿势：

import asyncio import pynng  async def main():     with pynng.Pair0(listen='tcp://127.0.0.1:5555', async=True) as sock:         await sock.asend(b'hello')         msg = await sock.arecv()

用 pynng 做 pub/sub 时收不到消息

不是代码写错了，是 Sub0 默认不订阅任何主题——它必须显式调用 subscribe()，哪怕你想收空主题（即所有消息），也得 sub.subscribe(b'')，否则直接静默丢弃。

使用场景注意点：

• Pub0 发送时，消息体前面不会自动加 topic；Sub0 收的时候只比对前 N 字节是否匹配 subscribe() 的字节串
• 如果你 sub.subscribe(b'foo')，但 pub.send(b'bar')，肯定收不到；想收全部，就 sub.subscribe(b'')
• 多个 Sub0 连同一个 Pub0，只要各自 subscribe() 正确，互不影响；但 Pub0 不保证消息投递顺序跨连接

性能差？别怪 pynng，先看你的模式和参数

pynng 本身封装很薄，瓶颈通常出在协议选型或 socket 配置上。比如 Pair0 是严格一对一，多对一就丢消息；ReqRep 有隐式队列但超时默认 60 秒，卡住时你以为是慢，其实是等超时。

关键参数影响：

• send_timeout/recv_timeout：单位毫秒，不设就是永久阻塞；生产环境务必设（如 send_timeout=5000）
• linger：socket 关闭后等待未发完消息的时间，默认 -1（无限），测试时容易卡进程
• max_retries（仅 ReqRep）：重试次数，设太高会让请求延迟翻倍，设 0 则失败立即返回

一个常被忽略的点：TCP_NODELAY 默认关着，小包会 Nagle，加 tcp_nodelay=True 能明显降低延迟。