如何创建既适合发送又适合消费的ZeroMQ套接字？

Question

请为以下场景提供ZeroMQ套接字体系结构建议：

1）端口上有服务器监听

2）有多个客户端同时连接服务器

3） 服务器接受来自客户端的所有连接，并为每个客户端提供双向队列，这意味着双方（客户端N或服务器）都可以发送或使用消息，即双方都可以是通信的发起方，另一方应该有一个回调来处理消息。

我们应该在每个接受的连接上创建额外的ZeroMQ套接字来从服务器推送消息吗？你能建议哪一个ZeroMQ套接字类型谷歌这样的架构？

Answer 1

我遇到了基本相同的问题。对我来说，问题似乎是即使在有GIL保护的python中，你也不能一次从两个线程操作一个套接字。这将导致解释器崩溃。因此，我们不能有发送和接收线程，而是一个线程，它必须能够同时接收和发送，而pyzmq无法同时轮询（）套接字和非套接字。

用户3666197也回答了我的问题，但是两个回答都没有帮助。尤其是因为不能假设为所有客户端连接生成主机套接字需要1000个空闲和开放端口。

有一个相对丑陋的解决方案。这是一个缺乏适当的NOWAIT标志等的草稿。make_process_pull_socket（）为进程内部的通信创建了一个套接字。如下：

class TwoWay(threading.Thread):
def __init__(self, ip_string, port, inque:queue.Queue):
    super(TwoWay, self).__init__()
    self.sock = cntxt.socket(zmq.ROUTER)
    addr = "tcp://{}:{}".format(ip_string, str(port))
    self.sock.bind(addr)
    self.pull = make_process_pull_socket(4456)
    self.push = make_process_push_socket(4456)
    self.inque = inque

def run(self):
    pl = zmq.Poller()
    pl.register(self.sock,zmq.POLLIN)
    pl.register(self.pull,zmq.POLLIN)
    while True:
        try:
            p = pl.poll(timeout=2000)
            if not p:
                continue
            s,i = p[0]
            if s == self.sock:
                a,m = s.recv_multipart()
                self.inque.put((a,m))
            if s == self.pull:
                r = s.recv()
                if len(r) > 5:
                    self.sock.send_multipart([r[:5], r[5:]])
        except Exception as e:
            print(e)

然后将传入消息放入作为参数提供的inque队列中，传出消息（带有标识符）可以双向发送。推发送（id消息）

Answer 2

在每个接受的连接上创建额外的ZeroMQ套接字，用于从服务器推送消息？

最简单的基于组合的设计——可扩展性和安全性

本机ZeroMQ原语（智能原语可扩展的正式通信模式原型）对我们来说就像一个乐高积木——我们在应用领域中的预期目标用途的消息/信令平面上组合它们的进一步用途。

问：对于这种架构，你能告诉谷歌哪种ZeroMQ套接字类型吗？

没有，因为没有提供此类建议的详细需求清单。一对PUSH/PULL-s本身不需要满足要求，临时执行的（偶发的）REQ/REP可能有助于客户机（重新）发现阶段，就像其他共存的、持久的或偶发的原型构成任何额外的系统/服务平面一样。