Advertisement

Jstorm源码中的kill及rebanlance及activate/deactivate方法运行流程

阅读量:

将这几个kill、rebanlance、activate、deactivate方法进行集中分析的原因在于,它们均基于nimbus所定义的通用状态转移机制实现功能。

复制代码
    transitionName
    

***********这里只具体分析kill方法

一:LocalCluster的初始化过程与拓扑提交方式相似,具体细节可参考大神http://www.maoxiangyi.cn/index.php/archives/734

二:在LocalCluster构建完成之后,可以通过调用killTopology或killTopologyWithOpts方法来终止拓扑运行。

这些方法的执行过程中,均会触发对nimbus相应功能的调用。若对nimbus的具体实现类进行追踪,即可发现killTopology与killTopologyWithOpts这两个方法的实际执行逻辑均被封装于killTopologyWithOpts之中

复制代码
 @Override

    
 	public void killTopology(String name) throws NotAliveException, TException {

全部评论 (0)

还没有任何评论哟~