ZMQ 的正确工作模式是什么？

一分耕耘，一分收获！既然都打开这篇《ZMQ 的正确工作模式是什么？》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

我正在尝试构建一个 ZeroMQ 模式，

1. 可以有多个客户端连接到单个服务器端点
2. 服务器会将传入的客户端任务分配给可用的工作人员（将映射到服务器上的核心数量）
3. 这些任务运行时间较长（以小时为单位），并且需要执行大量本地 I/O
4. 在每次任务执行（迭代）期间，都会在客户端和服务器工作线程之间来回发送数据/消息（可能按 [GB]s 的顺序）
5. 客户端和服务器工作人员需要知道对等端是否出现故障/错误，以便他们可以恢复（重试）或正常关闭并稍后再试

基于上述内容，我认为 ROUTER/DEALER 模式会很有用。 PUB/SUB 被丢弃，因为我需要知道对等方是否失败。

我尝试使用 ROUTER/DEALER 模式的各种组合，但无法确保来自客户端的多条消息在迭代中到达同一工作人员。我知道我需要实现一个代理/转发器/设备，将传入消息路由到正确的接收者/处理程序/工作人员。但我无法在代理中映射前端和后端套接字。我正在研究 MajorDomo 模式，但我想必须有一个更简单的代理模型，可以将消息路由到指定的工作人员。 （没有真正进入服务）

我正在寻找一些例子，看看是否有任何关于我可能缺少的内容的指导。我正在尝试在 Golang 中构建它。

解决方案

基于第 1 - 5 项下发布的所有要求的复杂组成，我敢说，正确的不是使用单个标准的、内置的、ZeroMQ 简单的原始通信原型模式，而是创建一个多层的特定于应用程序的组合（M + N + 1 热备用）足够健壮？）（自我弹性？）信令消息传递基础设施，涵盖了您当前的所有（并且可能可扩展为任何未来的）应用程序级别的需求，就像这里描述的一种更简单的 distributed-computing 用例一样，其中只有一个实现了简单的远程 SigKILL。

是的，最好的办法是创建（并维护）您自己的形式化信号，应用程序级别可以处理该信号并进行交互——例如用于检测死亡工人的心跳+允许重新启动此类失败的作业正好检测到故障（最有可能重新定位和/或重新安排发生，并且相应的资源不是静态预先映射的，但在恢复时物理上最可行 - 因此甚至更多遥测信号将帮助您决定恢复此类失败的微作业）。

ZeroMQ 是一个极好的框架，适合如此复杂的信令和消息传递层次结构，因此系统架构师的想象力是这个概念的唯一上限。

ZeroMQ 将承担剩下的工作，轻松轻松地完成所有艰苦的工作。

终于介绍完啦！小伙伴们，这篇关于《ZMQ 的正确工作模式是什么？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！