JStorm 源码分析 - Nimbus

栏目: 编程工具 · 发布时间: 5年前

内容简介:拓扑会通过 Nimbus 分发给 supervisor, 那么 Nimbus 内部是怎么操作的? 这里以本地模式为例, 对拓扑的提交过程做一个分析.参考资料:TODO …

拓扑会通过 Nimbus 分发给 supervisor, 那么 Nimbus 内部是怎么操作的? 这里以本地模式为例, 对拓扑的提交过程做一个分析.

参考资料: 理解storm拓扑并行度

疑问:

  1. 在zk上建立task信息,这些信息是用来做什么的?
  2. notifyTopologyActionListener 做了什么?

启动

TODO …

命令的入口

所有命令的入口, 都是由 ServiceHandler 实现的, com.alibaba.jstorm.daemon.nimbus.ServiceHandler#submitTopologyWithOpts.

  1. 配置校验
  2. 判断拓扑是否已存在/重名/重复提交
  3. 标准化conifg
  4. 标准化topology (finalize component’s task parallism)
  5. 校验topology结构
    1. 校验 bolt/spout 的id 和 name
    2. 校验 bolt 的输入是否为空
  6. 拷贝代码二进制文件到集群
  7. 在zk上建立task信息 (supervisor会持续监控保存在zk的任务) JStorm 源码分析 - Nimbus
    1. 为bolt/spout等创建对应的 TaskInfo (多并行度的bolt/spout会创建出多个TaskInfo) com.alibaba.jstorm.cluster.Common#mkTaskMaker
    2. 注意, jstorm 的 setNumTasks 其实是无效的, 只有 paralleism 并行度会起作用.(见 jstorm作者之一cody的回答: https://stackoverflow.com/a/34316700/6275014 )
  8. StartTopologyEvent.pushEvent,
    1. 然后会异步地去执行 com.alibaba.jstorm.daemon.nimbus.TopologyAssign#mkAssignment
      1. com.alibaba.jstorm.schedule.default_assign.TaskScheduler#assign: 将task分配给worker, 在这里做了一些定制化, 如有的task要求分配在不同的worker上等.
      2. 创建好 Assign 后, 会发布到 zk 上.
  9. notifyTopologyActionListener

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

搜

(美)约翰·巴特利 / 张岩、魏平 / 中信出版社 / 2006-1 / 35.00元

这个世界需要什么?如何任何一家公司能回答好这个问题,它就掌握了控制商业社会,乃至整个人类文明的万能钥匙。在过去的几年中,Google正在为获得这把钥匙而努力。虽然Google并非搜索业务的最早开发者,但它凭借着简明、便利、实用的搜索技术和理念,逐渐击败雅虎、Alta Vista等搜索领域的先锋,成为搜索行业名副其实的王者。 本书描述了Google如何从斯坦福一个不起眼的公司迅速崛起为“......一起来看看 《搜》 这本书的介绍吧!

JS 压缩/解压工具
JS 压缩/解压工具

在线压缩/解压 JS 代码

随机密码生成器
随机密码生成器

多种字符组合密码

URL 编码/解码
URL 编码/解码

URL 编码/解码