CODE 项目整体迁移至码云平台(https://gitee.com)公告
blogchong / DataOptTopology Java

完整的storm应用实例。

http://www.blogchong.com/

storm 实时处理 应用实例
拷贝地址

README.md

功能说明:提供一个完整的storm处理流程实例,包括其他各种功能节点的实现(包含wordcount实例)

代码主页:http://www.blogchong.com/ (更多代码对应的文档,包括设计文档,演示文档以及其他相关文档)

项目中所有依赖lib下载地址:http://pan.baidu.com/s/1jGDrxaQ

使用说明:下载lib依赖,在项目中添加外部依赖; 在mysql中创建storm库,将mysql目录下的建表脚本导入; 本地运行即可,需要在集群中跑的,需要打包,并且将集群中没有的lib包导入storm下的lib中; 创建一个storm数据库,并且将mysql下的脚步文件导入即可使用mysqlbolt;

功能列表: 提供了LogLogSpout读取数据的Spout接入源; 提供了MetaqSpout数据接入接口Spout; 提供了MonitorBolt接口,包括了普通匹配、范围匹配、正则匹配等过滤方式; 提供了MetaBolt即Metaq回写接口,将数据回写到消息队列中,即生产者模式; 提供了MysqlBolt,Mysql落地接口; 实现了拓扑的动态配置,即在不停止拓扑的情况下修改配置生效; 实现了一个单独的wordcount实例功能,即storm级的helloworld实例;