基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

package com.mzz.storm;

import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.StormSubmitter;
import org.apache.storm.generated.AlreadyAliveException;
import org.apache.storm.generated.AuthorizationException;
import org.apache.storm.generated.InvalidTopologyException;
import org.apache.storm.generated.StormTopology;
import org.apache.storm.topology.TopologyBuilder;

public class TopMain {
	public static void main(String[] args)
	{
		TopologyBuilder builder=new TopologyBuilder();
		builder.setSpout("spout", new RandomWordsSpout(),1);
		builder.setBolt("bolt",new PrintWordBolt(),3).shuffleGrouping("spout");
		StormTopology top = builder.createTopology();
		Config config = new Config();
		config.setNumWorkers(3);  //进程数
		LocalCluster cluster=new LocalCluster();
		//cluster.submitTopology("example", config, top);
        try {
			StormSubmitter.submitTopology("words_top3", config, top);
		} catch (AlreadyAliveException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (InvalidTopologyException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (AuthorizationException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
  

}