Advertisement

Storm:实时计数

阅读量:

软件版本:Storm:0.9.3 ,Redis:2.8.19;jedis:2.6.2;

代码及Jedis下载:Storm实时单词计数

Storm应用场景--实时单词计数,与《Getting Started with Storm》中chapter6所描述的现实应用案例存在一定相似性。

场景描述:

1. 通过一个Java程序,按照设定的时间间隔将数据写入Redis数据库A;

2. Storm的Spout组件负责从Redis数据库A中获取数据,并在读取完成后将对应的数据从Redis中清除;

3. Storm的SplitBolt组件接收Spout输出的内容,对其进行解析处理后继续传递;

4. Storm的CountBolt组件对SplitBolt所输出的数据进行统计处理,并按照预设的时间周期将结果保存至Redis数据库B;

5. 另一个Java程序则定期从Redis数据库B中提取数据并进行展示;

具体实现:

1. Java程序定时向Redis发送数据

复制代码
 while(true){// 每次发送3个数据

    
 			try {
    
 				Thread.sleep(200);// 每200毫秒产生一次数据
    
 			} catch (InterruptedException e) {
    
 				e.prin

全部评论 (0)

还没有任何评论哟~