在之前的两篇文章中，分别讨论了storm-rabbitmq,storm-hbase集成的基本用法，为此我们写一个简单的测试项目用于整体测试。 测试环境: storm0.9.6 hbase1.0.0 rabbitmq3.4.4 代码思路： 1.rabbitmq获取消息，直接转换为字符串(方便我们在rabbitmq web客户端直接发送字符串测试) 2.ra
Storm-RabbitMQ的使用(一)
RabbitMQ是一款广为使用的企业级消息队列系统，采用erlang语言开发，支持多种语言的客户端访问，这也是我选择rabbitmq作为我接触的第一个MQ的原因。 在去年的项目，我使用Rabbit用来缓存生产者产生的消息，另一端采用java客户端来获取消息然后进行保存、过滤等处理，每天的消息量峰值在1000条/s，共3条队列，以消费者和生产者加起来只有不