拓展阅读：

 

 

1）Zookeeper注册中心 Storm集群

 

 

目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等

2）【应用场景】

异步处理，应用解耦，流量削锋和消息通讯四个场景。

 

3）【消息中间件示例】

电商系统 日志收集系统

 

4）【日志系统】

ELK Static(新浪kafka日志处理应用案例)

-- Kafka：接收用户日志的消息队列。

 

-- Logstash：做日志解析，统一成JSON输出给Elasticsearch。

 

-- Elasticsearch：实时日志分析服务的核心技术，一个schemaless，实时的数据存储服务，通过index组织数据，兼具强大的搜索和统计功能。

 

-- Kibana：基于Elasticsearch的数据可视化组件，超强的数据可视化能力是众多公司选择ELK stack的重要原因。

 

5）【Zookeeper】

Zookeeper 分布式服务框架是 Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等

 

6）【storm】

是一种 实现一个实时计算系统

 

7）【两种消息模式】

　　　　-- 点对点(P2P模式) ：
 
            　　a)每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)
              　b)发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列
            　　c)接收者在成功接收消息之后需向队列应答成功

  　　  -- 发布订阅(Pub/sub模式)

       　　 　 a)每个消息可以有多个消费者
         　　  b)发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息。
           c)为了消费消息，订阅者必须保持运行的状态。