MQ的基本概念
MQ概述
MQ全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。
小结:
- MQ，消息队列，存储消息的中间件
- 分布式系统通信两种方式：直接远程调用 和 借助第三方 完成间接通信
- 发送方称为生产者，接收方称为消费者
MQ的优势
- 应用解耦: 提高系统容错性和可维护性
- 异步提速: 提升用户体验和系统吞吐量
- 削峰填谷: 提高系统稳定性
MQ的劣势
- 系统可用性降低: 系统引入的外部依赖越多，系统稳定性越差。一旦 MQ 宕机，就会对业务造成影响
- 系统复杂度提高: MQ 的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过 MQ 进行异步调用。如何保证消息没有被重复消费？怎么处理消息丢失情况？那么保证消息传递的顺序性？
- 一致性问题: A 系统处理完业务，通过 MQ 给B、C、D三个系统发消息数据，如果 B 系统、C 系统处理成功，D 系统处理失败。如何保证消息数据处理的一致性
RabbitMQ
AMQP，即 Advanced Message Queuing Protocol（高级消息队列协议），是一个网络协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制.
Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。Erlang 语言由 Ericson 设计，专门为开发高并发和分布式系统的一种语言，在电信领域使用广泛
RabbitMQ 中的相关概念
- Broker: 接收和分发消息的应用，RabbitMQ Server就是 Message Broker
- Virtual host: 出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时，可以划分出多个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) and fanout (multicast)
- Queue: 消息最终被送到这里等待 consumer 取走
- Binding: exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key。Binding 信息被保存到 exchange 中的查询表中，用于 message 的分发依据
RabbitMQ工作模式
-
Hello World: 生产者直接向消费者发送消息
直接模式 -
Work queues: 生产者把消息发送到队列里面, 消费者从队列里面取出消息
工作队列模式 -
Publish/Subscribe: 生产者把消息发送到交换机, 交换机再分发给队列, 消费者再从队列里面取消息
发布/订阅模式 -
Routing: 生产者把消息发送到交换机, 交换机通过一定的路由规则把消息分发给队列, 消费者再从队列里面取消息
路由模式 -
Topics: 和路由模式差不多, 就是把路由规则设置成通配符规则
主题模式 -
RPC: 实际开发中用的不多
远程调用模式
RabbitMQ的安装
由于rabbitmq使用erlang语言编写, 所以要先安装erlang环境
RabbitMQ和Erlang语言的匹配: https://www.rabbitmq.com/which-erlang.html
Erlang下载地址: https://www.erlang.org/downloads
Windows上安装
下载地址: https://www.rabbitmq.com/install-windows.html
一旦安装了Erlang和RabbitMQ，就可以将RabbitMQ节点作为Windows服务启动
Linux上安装
下载地址: https://www.rabbitmq.com/install-rpm.html
docker上安装
docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
安装成功后可以访问 http://localhost:15672/#/ 管理界面, 默认的账号密码都是 guest
