当前位置: 首页 > 知识库问答 >
问题:

Storm:多个工人会怎样?

阴福
2023-03-14

如果我的理解是正确的,那么我的问题就来了。假设bolt是由Python实现的。由于storm通过stdout/stdin在多个lang bolt之间传输数据,如果两个worker运行在不同的主机上,spout如何将数据发送到位于另一个主机上的bolt?

共有1个答案

爱亮
2023-03-14

对你的问题稍作澄清。Storm使用各种类型的队列在拓扑结构的各个组件之间传输数据/元组

示例:

1)Storm中的工作人员内部通信(同一Storm节点上的线程间通信):LMAX Distruptor

 类似资料:
  • 我有一个从Kafaka队列订阅事件的storm拓扑。在配置工作进程数时,拓扑工作正常。setNumWorkers设置为1。当我将worker的数量更新为一个或两个以上时,KafkaSpout在查看storm UI时无法确认消息。可能的原因是什么,我无法弄清楚,问题的精确性。 我有一个3节点的集群,运行一个nimbus和两个管理器。

  • 我正在研究一个storm拓扑,需要为不同的客户端位置构建多个拓扑。 谢谢你的回复。

  • 让我从一句来自1950年的引言开始吧。当时的世界是个简单得多的地方。电视是黑白的。喷气式飞机尚未进入民用领域。硅晶体管还没发明问世。全世界一共只有十来台电脑。每台都是满满当当的真空管、继电器、插接板和电容器的华丽组合,能塞满整个房间。 因此,只有一个胆量十足的人才敢预测说:我相信,到了20世纪末,语言的用法和受过教育者的普遍观点将会出现重大转变,人可以说 机器在思考,且不认为这自相矛盾。多么大胆的

  • 对于我的拓扑--我在一个任务上的负载为90%,而第二个任务的负载为0%。 为什么对多个工人来说这是不同的。

  • 外部参会人可以选择使用客户端加入会议或使用web浏览器加入会议; 1、 使用客户端加入会议(推荐):登录官网https://infoflow.baidu.com/,下载对应版本客户端注册登录后,点击内部组织方所发送的会邀信息,即可进入会议中; 2、 使用web参会,点击内部组织方所发送的会邀信息,进行web页面,点击使用浏览器加入会议。

  • 问题内容: 我正在使用Spring和Hibernate,Spring的配置如下。如何配置两个数据源,会话工厂。使用注释管理事务。请指教 问题答案: 在Hibernate DAO中,我们可以使用@Qualifier注释,如下所示连接2个会话工厂