你好,游客 登录 注册 搜索
背景:
阅读新闻

RabbitMQ-Storm-HBase测试项目

[日期:2016-03-08] 来源:Adamfei's Blog  作者: [字体: ]

  在之前的两篇文章中,分别讨论了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中指定的参数





收藏 推荐 打印 | 录入:elainebo | 阅读:
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数
点评:
       
评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款