【发布时间】:2016-01-10 18:51:16
【问题描述】:
我想对标记为 1...n 的多个客户端使用 zeromq,以便在服务器推送包含一个字段作为客户端 ID 的消息时从同一个套接字接收接收。服务端推送标签为 1 的消息时,只有客户端 1 接收到。
一种方法是为客户端生成相同数量的服务器套接字进行一一连接,我认为这可能有更好的解决方案。非常感谢。
【问题讨论】:
标签: zeromq
我想对标记为 1...n 的多个客户端使用 zeromq,以便在服务器推送包含一个字段作为客户端 ID 的消息时从同一个套接字接收接收。服务端推送标签为 1 的消息时,只有客户端 1 接收到。
一种方法是为客户端生成相同数量的服务器套接字进行一一连接,我认为这可能有更好的解决方案。非常感谢。
【问题讨论】:
标签: zeromq
使用“发布/订阅”模式并设置用于过滤消息的套接字选项。
SUB 端代码:
context = zmq.Context()
socket = context.socket(zmq.SUB);
socket.connect ("tcp://localhost:%s" % port)
topicfilter = "10001"
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)
string = socket.recv()
PUB 端代码:
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % port)
topic = 10001
messagedata = random.randrange(1,215) - 80
socket.send("%d %d" % (topic, messagedata))
示例和模式描述here
更新
pythonhere的示例
【讨论】: