storm实时单词计数

K天熟悉Apache Storm （三）的示例代码，实时单词计数应用场景

package wc.redis;

import wc.redis.bolt.CountBolt;
import wc.redis.bolt.SplitBolt;
import wc.redis.spout.WCSpout;
import backtype.storm.Config;
import backtype.storm.StormSubmitter;
import backtype.storm.generated.AlreadyAliveException;
import backtype.storm.generated.InvalidTopologyException;
import backtype.storm.topology.TopologyBuilder;
import backtype.storm.tuple.Fields;
/**
 * 功能：
 * 使用java程序定时向Redis数据库A中插入数据
 * 使用Spout定时读取Redis中的数据
 * 使用SplitBolt把数据分为单词
 * 使用CountBolt对单词计数，同时定时向Redis数据库B中插入单词计数
 * 使用java程序定时读取Redis数据库B中的数据，进行打印
 * 
 * @author fansy
 * @date 2015/3/25 23:31
 */
public class WCTopology {

	/**
	 * @param args
	 * @throws InvalidTopologyException 
	 * @throws AlreadyAliveException 
	 */
	public static void main（String[] args） throws AlreadyAliveException InvalidTopologyException {
		if（args.length!=7）{
			System.out.println（“\nwc.redis.WCTopology  “ +
					“    “+
					“ “）;
		}
		 //Topology definition
		TopologyBuilder builder = new TopologyBuilder（）;
		builder.setSpout（“wc-spout“new WCSpout（）Integer.parseInt（args[2]））;
		builder.setBolt（“split-bolt“ new SplitBolt（）Integer.parseInt（args[3]））
			.shuffleGrouping（“wc-spout“）;
		builder.setBolt（“count-bolt“ new CountBolt（）Integer.parseInt（args[4]））
			.fieldsGrouping（“split-bolt“ new Fields（“word“））;
		
		// 定义Configuration
		Config conf = new Config（）;
		conf.put（“storeFrequent“ Long.parseLong（args[0]））;
		conf.put（“slow_fast“ args[5]）;
		conf.put（“printWC“ args[6]）;
		conf.setNumWorkers（Integer.parseInt（args[1]））;
		// 提交任务
		StormSubmitter.submitTopology（“wc-redis-14“ confbuilder. createTopology（））;
	}

}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件        767  2015-03-24 16:02  StormTest1.4\.classpath

     文件        388  2015-03-26 21:57  StormTest1.4\.project

     文件        629  2015-03-19 00:21  StormTest1.4\.settings\org.eclipse.jdt.core.prefs

     文件       4449  2015-03-26 21:58  StormTest1.4\bin\wc\redis\bolt\CountBolt.class

     文件       3188  2015-03-26 21:57  StormTest1.4\bin\wc\redis\bolt\SplitBolt.class

     文件       2929  2015-03-26 21:58  StormTest1.4\bin\wc\redis\insert_get\RandomRedisInsert.class

     文件       3279  2015-03-26 21:58  StormTest1.4\bin\wc\redis\insert_get\RedisGetTest.class

     文件       3305  2015-03-26 21:58  StormTest1.4\bin\wc\redis\insert_get\RedisGetTest2.class

     文件       4145  2015-03-26 22:12  StormTest1.4\bin\wc\redis\spout\WCSpout.class

     文件       2078  2015-03-26 21:58  StormTest1.4\bin\wc\redis\util\RedisUtils.class

     文件       2588  2015-03-26 22:15  StormTest1.4\bin\wc\redis\WCTopology.class

     文件       2862  2015-03-26 17:57  StormTest1.4\src\wc\redis\bolt\CountBolt.java

     文件       2154  2015-03-26 17:21  StormTest1.4\src\wc\redis\bolt\SplitBolt.java

     文件       2108  2015-03-26 17:11  StormTest1.4\src\wc\redis\insert_get\RandomRedisInsert.java

     文件       1606  2015-03-25 23:23  StormTest1.4\src\wc\redis\insert_get\RedisGetTest.java

     文件       1707  2015-03-26 00:57  StormTest1.4\src\wc\redis\insert_get\RedisGetTest2.java

     文件       2797  2015-03-26 22:12  StormTest1.4\src\wc\redis\spout\WCSpout.java

     文件       1152  2015-03-26 21:58  StormTest1.4\src\wc\redis\util\RedisUtils.java

     文件       1862  2015-03-26 22:15  StormTest1.4\src\wc\redis\WCTopology.java

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc\redis\bolt

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc\redis\insert_get

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc\redis\spout

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc\redis\util

     目录          0  2015-03-26 21:57  StormTest1.4\src\wc\redis\bolt

     目录          0  2015-03-26 21:57  StormTest1.4\src\wc\redis\insert_get

     目录          0  2015-03-26 21:57  StormTest1.4\src\wc\redis\spout

     目录          0  2015-03-26 21:57  StormTest1.4\src\wc\redis\util

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc\redis

     目录          0  2015-03-26 21:57  StormTest1.4\src\wc\redis

     目录          0  2015-03-26 21:57  StormTest1.4\bin\wc

............此处省略10个文件信息