我正在尝试使用pyzmq的内置日志处理程序为我的分布式应用程序实现集中式日志记录服务器(请参阅here).
尽管从体系结构的角度我可以理解PUB / SUB模式的使用,但是我无法掌握这种系统的正确技术实现.
根据我到目前为止的了解,由于我将有N个单独的进程发布在N个单独的端口上,因此我确实需要N个单独的记录器才能捕获所有消息.
因此,这意味着我需要为系统上拥有的每个新发布者打开一个单独的“侦听器”过程吗?
编辑:
为了澄清这个问题:在pyzmq随附的工具的上下文中,如何实现集中式日志记录服务器?
解决方法:
使用发现的建议here解决了该问题:
One interesting aspect of the zmq.SUB sockets is that they can connect to multiple endpoints, so that they receive messages from all the publishers.
解决方案是使用一个“订阅”所有可用发布者的侦听器.