如何使用 pyzmq 发送带有 PUB/SUB 模式的字典？

Question

我正在尝试发送 python 字典，使用类似：

import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % port
socket.send_pyobj({'hello':'world'})

并使用以下方式接收它：

socket.connect ("tcp://localhost:%s" % port)
topicfilter = "1"

socket.setsockopt_string(zmq.SUBSCRIBE, topicfilter)

while True:
    print(socket.recv_pyobj())

问题：

1. 我似乎不知道如何为send_pyobj() 设置主题。
2. 不用说，我在另一端没有收到任何东西。我设法让它与字符串和send_string() 一起使用，所以它肯定是连接的。我做错了什么？
3. 我可以有很多 PUB 服务器广播吗？从而创建了一种多对多的方式，其他应用可以参与其中吗？

Answer 1

1. 我可以有多台PUB服务器广播吗？

是的，你可以

简单。

---

1. 我在另一端没有收到任何东西...我做错了什么？

不要订阅 "1"，如果它永远不会出现

这个单一的原因支持“没有收到任何东西”（除非它以 "1" 开头，它显然从未这样做过，因为有效负载是由 socket.send_object( ... ) 并且从来没有一个 "1" 可以匹配类似字符串的字节 [0] 的位置。

---

1. ...send_pyobj()如何设置主题？

嗯，你永远不知道

这应该使用其他方式设置，而不是猜测几个字节，“匹配”对象字节字符串表示的初始部分。

最简单的方法是像这样在发送方“添加”一个受控值：

import dill as pickle

aConstantNbytesPUB_TOPIC_FILTER_PREFIX = "{UUID:0000-0000-0000-1111-2222}"

socket.send( aConstantNbytesPUB_TOPIC_FILTER_PREFIX
           + pickle.dumps( anObjectToSEND )
             )
...

aMSG = socket.recv()
print( pickle.loads( aMSG[ len( aConstantNbytesPUB_TOPIC_FILTER_PREFIX ):]
                     )
       )

也可以使用多部分消息组合，但在这里演示这个概念的时间要长一些。

pickle 和 dill 的 SER/DES 策略都受限于对象分解/遍历/恢复功能和众所周知的安全警告小心点。