【问题标题】:zeromq pattern for multi client pull receive from one server pushing socketzeromq 模式,用于多客户端从一台服务器推送套接字拉接收
【发布时间】:2016-01-10 18:51:16
【问题描述】:

我想对标记为 1...n 的多个客户端使用 zeromq,以便在服务器推送包含一个字段作为客户端 ID 的消息时从同一个套接字接收接收。服务端推送标签为 1 的消息时,只有客户端 1 接收到。

一种方法是为客户端生成相同数量的服务器套接字进行一一连接,我认为这可能有更好的解决方案。非常感谢。

【问题讨论】:

    标签: zeromq


    【解决方案1】:

    使用“发布/订阅”模式并设置用于过滤消息的套接字选项。

    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

    更新

    你可以使用的另一种模式Router-Req。 共同理念:

    pythonhere的示例

    【讨论】:

    • pub/sub 模式可能会丢失不适合此处的消息。有没有基于推/拉的模式?
    • @ZFY,可以试试路由器/经销商模式
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2013-08-06
    • 1970-01-01
    • 2013-09-06
    • 1970-01-01
    • 1970-01-01
    • 2021-12-04
    • 1970-01-01
    相关资源
    最近更新 更多