如何编写一个ZeroMQ负载平衡服务器，它可以使用Logstash作为客户端并且是非阻塞的？

Question

我有一些使用ZeroMQ与微服务通信的logstash实例。当一个特定调用占用太多时间时，问题就会出现，服务器会阻塞并导致logstash端出现ZeroMQ超时。你知道吗

我一直在阅读here，发现有一些方法可以编写一个使用LRU（最近最少使用的）范例的服务器。有人能指出任何对这样一个用例有用的指针吗。你知道吗

我想强调的几点是：

1. 我对客户机的控制非常少（因为logstash不提供ZeroMQ的完整API）。

2. 服务器必须是非阻塞的、多线程的（或多进程的），并且应该在它的用例中处理这个问题。

This是我正在使用的参考代码。对于这样一个用例有什么有用的提示或指导吗？你知道吗