storm启动类怎么定义

在storm中，每个应用程序都有一个主类，该主类继承自org.apache.storm.Config类。主类包含一个静态main方法，该方法使用StormSubmitter类将应用程序提交给Storm集群。

主要代码如下所示：

public class WordCountTopology { public static void main(String[] args) throws Exception { //定义拓扑 TopologyBuilder builder = new TopologyBuilder(); //设置spout，这个spout的名字叫做"spout"，设置并发度为5 builder.setSpout("spout", new RandomSentenceSpout(), 5); //设置bolt，这个bolt的名字叫做"split"，设置并发度为8，shuffleGrouping方法表明是随机分组 builder.setBolt("split", new SplitSentence(), 8).shuffleGrouping("spout"); //设置bolt，这个bolt的名字叫做"count"，设置并发度为12，fieldsGrouping方法表明是按照字段分组 //该bolt将接收到来自split bolt的数据，每个单词都会分配给一个count bolt实例进行计数 builder.setBolt("count", new WordCount(), 12).fieldsGrouping("split", new Fields("word")); //创建一个configuration，用来指定当前topology需要的worker的数量 Config config = new Config(); //设置worker的数量 config.setNumWorkers(2); //提交topology给storm集群运行 StormSubmitter.submitTopology("my-topology", config, builder.createTopology()); } }