本地模式是一种在本地进程中模拟 Storm 集群的工作模式,对于开发和测试拓扑很有帮助。在本地模式下运行拓扑与在集群模式下运行拓扑的方式很相似。
创建一个进程内的“集群”只需要使用 LocalCluster
类即可,例如:
import backtype.storm.LocalCluster;
LocalCluster cluster = new LocalCluster();
随后,你就可以使用 LocalCluster
中的 submitTopology
方法来提交拓扑了。与 StormSubmitter 中相应的方法相似,submitTopology
接收一个拓扑名称、拓扑配置以及拓扑对象作为输入参数。你也可以以拓扑名称为参数,使用killTopology
方法来 kill 掉对应的拓扑。
使用以下语句关闭本地模式集群运行:
cluster.shutdown();
本地模式的常用配置
你可以在这里找到完整的配置项列表。以下是几个比较有用的配置项说明:
原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/118162.html