使用 ZeroMQ 实现消息总线

Question

我必须开发一个消息总线，供进程相互发送、接收消息。目前，我们在 Linux 上运行，以便以后移植到其他平台。

为此，我在 TCP 上使用 ZeroMQ。模式是带有转发器的 PUB-SUB。我的总线作为一个单独的进程运行，所有客户端都连接到 SUB 端口以接收消息，并连接到 PUB 以发送消息。每个进程通过一个唯一的标签订阅消息。来自进程的send 调用向所有人发送消息。 receive 调用将获取该进程标记有该进程标记的消息。这工作正常。

现在我需要包装 ZeroMQ 的东西。我的客户只需要提供一个独特的标签。我需要维护标签与 ZeroMQ 上下文和套接字详细信息的全局列表。当客户说， initialize_comms("name"); 总线需要检查这个名字是否唯一，创建 ZeroMQ 上下文和套接字。同样，如果客户端说receive("name");，总线需要获取带有该标签的消息。

总结一下我面临的问题；

1. 有没有办法使用 ZeroMQ 提供的工具来实现这一点？
2. ZeroMQ 是解决此问题的正确工具吗，还是我应该寻找类似 nanomsg 的工具？
3. 带有转发器的 PUB-SUB 是正确的模式吗？
4. 或者，我在这里遗漏了什么？

Answer 1

答案

1. 是的，ZeroMQ 能够满足这一需求

2. 是的。 ZeroMQ 是一个合适的工具（相当强大的低延迟组件工具箱）。虽然nanomsg 有一个直接的总线原语，但核心分布式逻辑可以集成到ZeroMQ 框架中

3. 是与否。上面给出的 PUB-SUB 可以用于模拟“shout-cast”到总线，并建立在使用订阅密钥的 SUB 副作用之上。必须重新考虑和设计逻辑的整个 REST，以便整个制造范围符合您的计划（参考下文）。还请记住，ZeroMQ 的初始版本操作 PUB/SUB 原语作为在接收方完成的传入消息流的“订阅过滤”，因此大规模设计应检查 traffic-volumes / risk-of-大规模的洪水/流程效率低下......

4. 是的。 ZeroMQ 是一个经过良好调整的原始元素基础（就架构的讨论而言，而不是其功能和性能），以构建更聪明、更健壮和几乎线性可扩展的正式通信模式。一旦草绘架构，就不要拘泥于 PUB/SUB 或 PAIR 基元。 如果忘记了真正的力量从何而来，任何设计都会变得糟糕。

是迈向可扩展且具有故障恢复能力的总线的下一步的好地方

因此，最好的下一步是恕我直言，以获得更多的全局视图，这对于尝试使用 ZeroMQ 编码的前几件事来说可能听起来很复杂，但如果您 at least jump to the page 265 Code Connected, Volume 1，如果不是这样一步一步地阅读的话。

有史以来最快的学习曲线是首先在 图 60 重新发布更新和 图 62 上获得未公开的视图strong> HA 克隆服务器对实现可能的高可用性方法，然后回到根源、元素和细节。

Answer 2

这是我最终设计的，如果有人感兴趣的话。感谢大家的提示和指点。

1. 我有一个使用 ZeroMQ（和 CZMQ）作为单独进程运行的消息总线。
2. 模式是带有 LISTENER 的 PUBLISHER-SUBSCRIBER。它们使用代理连接。
3. 此外，还有一个使用新分支线程调用的 ROUTER。
4. 这三个端点在 TCP 上运行，并绑定到客户端知道的预定义端口。
5. PUBLISHER 接受来自客户端的所有消息。
6. SUBSCRIBER 向已订阅该标签的客户端发送带有唯一标签的消息。
7. LISTENER 监听所有通过的消息。目前，这是为了记录测试和目的。
8. ROUTER 为客户端提供单独的通信通道。诸如控制命令之类的消息被定向到这里，这样它们就不会被传递到下游。
9. 客户端连接到，
   1. PUBLISHER 发送消息。
   2. 订阅接收消息。订阅使用了唯一标签。
   3. ROUTER 发送命令（检查标签唯一性等）

我仍在执行，因此可能存在看不见的问题，但现在它工作正常。另外，可能还有更优雅的方式，但我不想扔掉我构建的 PUB-SUB 东西。