python - 在 zeromq/python 中使用 pyobj 子函数时设置主题

Question

我一直在查看 zeromq，我注意到有 socket.send_pyobj() 和 socket.recv_pyobj() 函数。

我的问题是，如果他们调用这个，将如何设置 PUB/SUB 的主题。在我看到的使用常规发送的示例中，它始终是两个字符串，中间有一个空格，第一个字符串将被视为一个主题。

topic = 'test'
msg = 'hello'
socket.send("%s %s" % (topic,msg))

有办法吗？或者也许我应该使用不同的端口来制作不同的主题？

Answer 1

非虚拟机。弄清楚该怎么做。如果我希望将主题和消息视为一个并过滤对象，我应该使用 send_multipart。

对于发布者。

   self.socket.send_multipart([b'status',pickle.dumps(msg2)])

对于接收者。

    socket.setsockopt(zmq.SUBSCRIBE, 'status')
    [topic,msg] = socket.recv_multipart()
    msg2 = pickle.loads(msg)
    print msg2['game']

我不知道为什么，但如果你使用他们的例子。 http://zguide.zeromq.org/py:psenvsub它显示我应该在 socketopt 上执行 b'status'，但如果我那样做它不会过滤 wya。