python - ZeroMQ PUB/SUB 过滤和性能

Question

我正在尝试使用 zeromq PUB/SUB(python eventlets)实现一个代理。 zeromq 2.1 似乎没有在发布者处实现过滤，所有消息都广播给所有订阅者，订阅者又应用过滤器。是否有某种解决方法可以在发布者处实现过滤。如果不是，如果有 ~25 个发布者和 25 个订阅者以每秒 200 条消息的最大速率交换消息，其中 msg_size ~= 5K 通过代理，那么性能有多糟糕。

是否有任何经过充分测试的开源零消息代理实现。？？

Answer 1

您有 3 个问题:

• 我可以在发布商处过滤自己吗？ - 是的
• 向 25 个节点发送 200 m/s 的性能有多糟糕？ - 这取决于您的消息有多大。但是不，在那个利率范围内，你永远不会有任何问题；当您开始最大化 IO 吞吐量时，问题就来了(1 gbit/s/8 = 125 MiB/s。125*.7(verhead)= 87 MiB/s。87 MiB/5 KiB(每条消息)= 17000 m/s 。在您开始填充 IO 限额之前，每个节点 712 msg/s。但是，如果您遇到这个问题，您最好使用 PGM 并以 17000 m/s 的速度进行多播。
• OSS ZMQ 代理实现情况如何？ - 他们不存在 afaik - 但指南描述了如何使用 Majordomo pattern 创建可靠的“经纪人” .

您需要在问题中提供更多详细信息:

• 要求？
• 对您来说“糟糕的表现”是什么？
• 邮件大小？
• 吞吐量要求？
• 主干网速度(10 gbit/s)？

就是说，如果您需要代理，为什么不直接使用 RabbitMQ 并将 RMQ 作为 ZMQ 设备与 RMQ 通信？