在之前的两篇文章中,分别讨论了storm-rabbitmq,storm-hbase集成的基本用法,为此我们写一个简单的测试项目用于整体测试。
测试环境:
storm0.9.6
hbase1.0.0
rabbitmq3.4.4
代码思路:
1.rabbitmq获取消息,直接转换为字符串(方便我们在rabbitmq web客户端直接发送字符串测试)
2.rabbitmq spout接收到字符串之后,生成一个UUID,以及一个随机数,按照 id,str,num的fileds顺序依次发送生成的uuid,接收到的字符串,随机数
3.hbase-bolt接收到tuple之后,以id作为rowkey,c1列族存储str列,c2列族用于存储num
github项目地址:
https://github.com/mengzhiyi/rabbitmq-storm-hbase
注意事项:
下载代码后需要根据实际版本信息修改maven依赖,其中jms等依赖可能需要手动下载。
修改src/main/resources/config.properties中指定的参数
RabbitMQ-Storm-HBase测试项目