首页 > 代码库 > storm如何部署拓扑

storm如何部署拓扑

storm集群搭建

  • 比较简单,参考官方文档即可http://storm.apache.org/releases/1.0.2/Setting-up-a-Storm-cluster.html

  • 启动Nimbus

./bin/storm nimbus &
  • 启动Storm UI,方便对集群状态的监控。
./bin/storm ui &
  • 启动supervisor
./bin/storm supervisor &

更新git代码

git pull --rebase

maven命令打包,xxx-0.0.1-SNAPSHOT.jar

mvn package

提交拓扑

  • 上传jar包并部署到Nimbus主机,并执行如下命令,
./bin/storm jar myTopology/xxx-0.0.1-SNAPSHOT.jar com.oplan.storm.topology.InsightTopology  201609071857

查看监控图,

  • 在Topology Summary栏目下能看到刚刚部署的拓扑的状态,Supervisor Summary则是supervisor的状态。

技术分享

  • 可以看到拓扑的所有spout和所有bolt状态。

技术分享

删除拓扑

  • storm kill {toponame}
  • 或直接在监控页面上kill按钮

最终展示实时运算结果

技术分享

<script type="text/javascript"> $(function () { $(‘pre.prettyprint code‘).each(function () { var lines = $(this).text().split(‘\n‘).length; var $numbering = $(‘
    ‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); }); </script>

    storm如何部署拓扑