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 都能直接装 - 如果要最新
nngC 库特性(比如 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
正确姿势:
本文档主要讲述的是使用Python进行socket编程;作为一种解释性语言,Python 很容易使用,并且能够快速验证我们的想法和开发原型软件。Python 程序可以作为一个整体进行解释,也可以一行行地解释。有需要的朋友可以下载看看
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 能明显降低延迟。









