登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-03-14 12:45:25 466浏览 收藏

一分耕耘,一分收获!既然都打开这篇《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相关知识,快来关注吧!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>