消息队列中间件 - Docker安装RabbitMQ、AMQP协议、和主要角色

概述

不管是微服务还是分布式的系统架构中，消息队列中间件都是不可缺少的一个重要环节，主流的消息队列中间件有RabbitMQ、RocketMQ等等，从这篇开始详细介绍以RabbitMQ为代表的消息队列中间件

AMQP协议

• AMQP协议是一个提供统一消息服务的应用层标准协议，基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制。
• AMQP协议是一种二进制协议，提供客户端应用与消息中间件之间的异步、安全、高效的交互。
• AMQP作为中间层服务，把消息生产和消费分隔开来，当消费者产生出现异常，不影响消费者对消息的消费，当消费者异常时，生产者生产的消息可以存放到服务的内存或者磁盘，不会影响想消费的速率，同时，消息也可以基于路由的规则可以投递到指定的消费者消费。

AMQP协议重要角色

1.生产者和消费者

• 生产者是生产消息的主体，消费者是消费消息的主体
• 数据集成与系统解耦、异步处理与事件驱动、流量薛峰、事务消息与分布式事务的最终一致
• 生产者生产一条消息丢给消息代理，消息代理根据投递规则将消息传到消费者手上

2.交换机

• 交换机就像是消息代理的路由器，负责拿到一个消息之后，根据确定的规则(路由键)将它路由给一个或零个队列，交换机具备多种路由模式。
• 基于消息生产者和路由规则可以将消息投递到指定的Message Queue，交换机收到生产者投递的消息，基于路由规则及队列绑定关系匹配到投递对应的交换机或者队列进行分发，交换机不存储消息，只做转发

交换机类型：

• 直连交换机：根据路由键完全匹配的投递到对应的队列
• 扇形交换机：无视路由键，将消息进行拷贝，并路由到给绑定到它身上所有队列，提供了一个广播的效果。
• 主题交换机：根据路由键按模式匹配的投递到对应的队列
• 交换机也具备自己的属性，可以定义自己的名字，是否持久化等选项。

3.队列

• 队列是消息的暂存地，至少有一个消费者订阅了队列的话，消息会立即发送给这些订阅的消费者，但是如果消息到达了无人的订阅队列，消息会在队列中等待，等待有了消费者便进行分发。
• Exchange和Message Queue之间存在绑定关系，消息到了Exchange 后基于路由策略可以将消息投递到已绑定且符合路由策略的Message Queue。
• 消息队列会将消息存储到内存或者是磁盘中，并将这些消息按照一定顺序转发给一个或多个消费者，每个消息队列都是独立隔离的，相互不影响。
• 消息队列具有不同的属性(私有、共享、持久化、临时、客户端定义或者服务端定义等))，可以基于实际需求选择对应的类型

4.消息

• 消息是信息的载体，也是AMQP协议的一个实体，消息包含两部分
• 载荷：就是真正的信息，是你想要传输的任何内容，该部分内容对消息代理来说是透明的
• 元信息：包含路由键、内容类型、编码、是否持久化等消息属性，会被消息代理所解析，消息代理根据消息的属性对这条消息进行投递，存储等，这部分被消息代理所关系，而消费者对其是不关心的。

5.信道

• 网络信道，是建立在Connection链接之上的一种轻量级的链接，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道，客户端可以建立对各Channel，每个Channel代表一个会话任务。
• 一个Connection上可以创建任意数量的Channel

Docker安装RabbitMQ

1.查看Docker仓库里的RabbitMQ镜像

# 查询镜像
docker search rabbitmq

# 下载镜像
docker pull rabbitmq

2.启动MQ安装management

如果在云服务上部署需在安全组开通一下端口：15672(UI页面通信口)、5672(client端通信口)、25672(server间内部通信口)、61613(stomp 消息传输)、1883(MQTT消息队列遥测传输)。

docker run -d --name rabbit -e \
RABBITMQ_DEFAULT_USER=stark -e RABBITMQ_DEFAULT_PASS=1990@stark 
-p 15672:15672 \
-p 5672:5672 \
-p 25672:25672 \
-p 61613:61613 \
-p 1883:1883 rabbitmq:management

使用 http://127.0.0.1:15672访问，账号和密码就是参数RABBITMQ_DEFAULT_USER和RABBITMQ_DEFAULT_PASS设置的值。