storm-hbase的使用

在之前的文章里，我使用了rabbitmq作为storm-topololy中spout的数据来源，使用storm-rabbitmq作为spout直接使用。通常我们的业务逻辑如下： 在bolt对tuple进行处理之后，通常要将数据缓存到redis,memcached等内存数据库中，对于数据量小的，可以缓存到内存中，但是对于大量持久化的数据，更多时候需要存储到

Storm-RabbitMQ的使用(一)

RabbitMQ是一款广为使用的企业级消息队列系统，采用erlang语言开发，支持多种语言的客户端访问，这也是我选择rabbitmq作为我接触的第一个MQ的原因。 在去年的项目，我使用Rabbit用来缓存生产者产生的消息，另一端采用java客户端来获取消息然后进行保存、过滤等处理，每天的消息量峰值在1000条/s，共3条队列，以消费者和生产者加起来只有不