如何修改pyzmq代码以成功使用inproc传输实现发布订阅？

嘿，你遇到的问题其实是对ZeroMQ的inproc传输机制理解有误——inproc是专门用于进程内通信的，只能在同一个Python进程里的不同线程之间使用，你现在把发布者和订阅者分成了两个独立的脚本（也就是两个完全分开的进程），这就完全超出了inproc的能力范围，所以肯定连不上。

下面给你两种可行的修改方案，根据你的需求选就行：

方案一：合并到同一个进程（用线程实现pub/sub） #

如果你的场景允许把pub和sub放到同一个进程里，那可以用Python的线程来分开运行发布和订阅逻辑，这样就能正常使用inproc了。注意要让pub和sub共享同一个zmq.Context实例（inproc依赖Context来识别端点）：

import zmq
import time
import threading

def run_publisher(context):
    # 发布者socket绑定inproc端点
    pub_socket = context.socket(zmq.PUB)
    pub_socket.bind("inproc://stream")
    print("发布者已启动，开始发送消息...")
    while True:
        pub_socket.send_string("Hello")
        time.sleep(1)

# 创建全局Context，供pub和sub共享
main_context = zmq.Context()

# 启动发布者线程，设置为守护线程，主程序退出时自动结束
publisher_thread = threading.Thread(target=run_publisher, args=(main_context,), daemon=True)
publisher_thread.start()

# 订阅者逻辑（主线程运行）
sub_socket = main_context.socket(zmq.SUB)
sub_socket.setsockopt_string(zmq.SUBSCRIBE, '')
sub_socket.connect("inproc://stream")

print("订阅者已启动，等待接收消息...")
for _ in range(5):
    msg = sub_socket.recv_string()
    print(f"收到消息: {msg}")

运行这个单脚本就能看到订阅者正常收到5条"Hello"消息。

方案二：保持两个独立脚本，改用跨进程传输机制 #

如果你必须把pub和sub分成两个独立的脚本，那绝对不能用inproc，换成ipc（本地进程间通信）或者你之前用的tcp就行。这里推荐用ipc，比tcp更适合本地跨进程场景：

修改后的pub_server.py #

import zmq
import time

context = zmq.Context()
socket = context.socket(zmq.PUB)
# 改用ipc端点，路径可以自定义，注意权限问题（一般/tmp目录没问题）
socket.bind("ipc:///tmp/zmq_stream")
while True:
    socket.send_string("Hello")
    time.sleep(1)

修改后的sub_client.py #

import zmq

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.setsockopt_string(zmq.SUBSCRIBE, '')
# 连接同一个ipc端点
socket.connect("ipc:///tmp/zmq_stream")

for _ in range(5):
    msg = socket.recv_string()
    print(msg)

先启动pub_server.py，再启动sub_client.py，就能正常通信了。

关键知识点回顾 #

• inproc://：进程内线程间通信，必须满足同一进程、同一Context实例两个条件，性能是所有传输里最高的，但只能在进程内用。
• ipc://：本地跨进程通信，适合同一台机器上的不同进程使用，性能比tcp好。
• tcp://：跨机器/跨进程都能用，通用性最强，但性能略低于前两者。

内容的提问来源于stack exchange，提问作者juiceb0xk