首页 > 代码库 > 56.storm 之 hello world (集群模式)
56.storm 之 hello world (集群模式)
回顾
在上一小节,我们在PWTopology1 这一个java类中注解掉了集群模式,使用本地模式大概了解一下storm的工作流程。这一节我们注解掉本地模式相关的代码,放开集群模式相关代码,并且将项目打包,在实际环境中运行一下。
集群模式部署步骤
项目打包
pom.xml右键 --> run as --> maven clean --> maven install
将大好的jar包上传到 nimbus 的 /usr/local下
提交拓扑
storm jar storm01.jar bhz.topology.PWTopology1
运行上面的命令后结果是这样的,终点看一下画红框的地方:
查看拓扑是否运行
在nimbus 运行 :storm list
结果是这样的:
也可以到管控台看到上面的信息
再查看一下supervisor的状态:jps可以看到worker进程
也可以看一下logs目录下的worker-****.log文件:
这些信息就是PrintBolt类中打印出的信息(完整代码参考上一节):
不过还遇到一个未能解决的问题,就是其中一个supervisor报错:
重启虚拟机都没有用。。而且这个Supervisor并没有工作。暂时先用一个Supervisor吧,以后再考虑怎么解决这个问题
56.storm 之 hello world (集群模式)
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。