RabbitMQ入门_rabbitmqctl

一、RabbitMQ简介

        RabbitMQ是一个由erlang语言编写的、开源的、在AMQP基础上完整的、可复用的企业消息系统。支持多种语言，包括java、Python、ruby、PHP、C/C++等。

• MQ：message queue 的简称，即消息队列，是应用程序和应用程序之间通信的中间件。
• AMQP：advanced message queuing protocol ，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息并不受客户端/中间件不同产品、不同开发语言等条件的限制。

二、RabbitMQ的核心概念

RabbitMQ基础架构如下：

• Broker：接收和分发消息的应用，RabbitMQ Server就是 Message Broker
• Virtual host：出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQserver 提供的服务时，可以划分出多个vhost，每个用户在自己的 vhost 创建 exchange／queue 等
• Connection：publisher／consumer 和 broker 之间的 TCP 连接
• Channel：如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立 TCP Connection的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的 channel 进行通讯，AMQP method 包含了channel id 帮助客户端和message broker 识别 channel，所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销
• Exchange：message 到达 broker 的第一站，根据分发规则，匹配查询表中的 routing key，分发消息到queue 中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) andfanout (multicast)
• Queue：消息最终被送到这里等待 consumer 取走
• Binding：exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key。Binding 信息被保存到 exchange 中的查询表中，用于 message 的分发依据

三、RabbitMQ五种消息发送模式

1，简单队列

（1）生产者将消息发送到队列，消费者从队列获取消息。
（2）一个队列对应一个消费者。

2，工作队列

（1）一个生产者，多个消费者。
（2）一个消息发送到队列时，只能被一个消费者获取。
（3）多个消费者并行处理消息，提升消息处理速度。

3，发布/订阅模式(Publish/Subcribe)

   将消息发送到交换机，队列从交换机获取消息，队列需要绑定到交换机。
（1）一个生产者，多个消费者。
（2）每一个消费者都有自己的一个队列。
（3）生产者没有将消息直接发送到队列，而是发送到交换机。