如何从不同线程发送到zmq套接字

Question

我有大约20个服务器，其中有一个订阅和一个发布套接字。另一个客户端有1个订阅和1个发布套接字。客户端通过轮询从服务器接收和发送ZeroMQ消息 服务器在主循环中发送消息，大约每40毫秒从不同的线程发送一次消息（每个服务器都有第二个线程）

我的问题是：服务器不能得到所有的客户端消息！我明白了，线程向客户机发送了太多的消息，但有些客户机根本没有收到消息。如何正确使用zeroMQ套接字？你知道吗

现在我使用mutex = threading.Lock()，所以我使用mutex.acquire来处理客户机消息。进程意味着我从PUB套接字获取消息，可能是做一些计算或什么都不做，然后将应答消息发送到子套接字。然后我使用mutex.release。你知道吗