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)
还没有任何评论哟~
