storm集群的工作流程


1,客户端向nimbus提交任务请求;

2,nimbus接收到客户端的任务获取supervisor的空闲worker,开始分配任务;

3,supervisor集群通过监听zookeeper,获取到nimbus所分配的任务,开始启动worker;

4,supervisor集群中的worker中的spout开始获取要处理的数据,将数据分发给bolt1,各个集群中的bolt1开始对数据进行切割,互不干扰;

5,各个集群上的bolt1对数据进行切割完毕后,开始将数据分发给各个集群上的bolt2进行处理(统计);

6,bolt2将数据处理完后输出到数据库进行保存。

相关文章:

  • 2022-12-23
  • 2022-01-06
  • 2021-11-17
  • 2021-07-10
  • 2021-08-28
  • 2021-08-16
  • 2021-11-17
猜你喜欢
  • 2022-12-23
  • 2021-05-10
  • 2021-10-24
  • 2021-06-21
  • 2021-11-23
  • 2022-12-23
  • 2021-11-17
相关资源
相似解决方案