在之前的两篇文章中,分别讨论了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测试项目
Tagged on:         

发表评论

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据