AMQP消息代理

AMQP（Advanced Message Queuing Protocol）即高级消息队列协议，是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件的不同产品、不同开发语言等条件的限制。

AMQP模型（AMQP Model）：一个由关键实体和语义表示的逻辑框架，遵从AMQP规范的服务器必须提供这些实体和语义。为了实现本规范中定义的语义，客户端可以发送命令来控制AMQP服务器。

消费者（Consumer）：一个从消息队列中请求消息的客户端应用程序。

生产者（Producer）：一个向交换器发布消息的客户端应用程序。

虚拟主机（Virtual Host）：一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。客户端应用程序在登录到服务器之后，可以选择一个虚拟主机。

交换器（Exchange）：服务器中的实体，用来接收生产者发送的消息并将这些消息路由给服务器中的队列。

交换器类型（Exchange Type）：基于不同路由语义的交换器类。

消息队列（Message Queue）：一个命名实体，用来保存消息直到发送给消费者。

绑定器（Binding）：消息队列和交换器之间的关联。

绑定器关键字（Binding Key）：绑定的名称。一些交换器类型可能使用这个名称作为定义绑定器路由行为的模式。

路由关键字（Routing Key）：一个消息头，交换器可以用这个消息头决定如何路由某条消息。

连接（Connection）：一个网络连接，比如TCP/IP套接字连接。

会话（Session）：端点之间的命名对话。在一个会话上下文中，保证“恰好传递一次”。

信道（Channel）：多路复用连接中的一条独立的双向数据流通道。为会话提供物理传输介质。

客户端（Client）：AMQP连接或者会话的发起者。AMQP是非对称的，客户端生产和消费消息，服务器存储和路由这些消息。

服务器（Server）：接受客户端连接，实现AMQP消息队列和路由功能的进程。也称为“消息代理”。

端点（Peer）：AMQP对话的任意一方。一个AMQP连接包括两个端点（一个是客户端，一个是服务器）。

搭档（Partner）：当描述两个端点之间的交互过程时，使用术语“搭档”来表示“另一个”端点的简记法。比如我们定义端点A和端点B，当它们进行通信时，端点B是端点A的搭档，端点A是端点B的搭档。

片段集（Assembly）：段的有序集合，形成一个逻辑工作单元。

段（Segment）：帧的有序集合，形成片段集中一个完整子单元。

帧（Frame）：AMQP传输的一个原子单元。一个帧是一个段中的任意分片。

控制（Control）：单向指令，AMQP规范假设这些指令的传输是不可靠的。

命令（Command）：需要确认的指令，AMQP规范规定这些指令的传输是可靠的。

异常（Exception）：在执行一个或者多个命令时可能发生的错误状态。

类（Class）：一批用来描述某种特定功能的AMQP命令或者控制。

消息头（Header）：描述消息数据属性的一种特殊段。

消息体（Body）：包含应用程序数据的一种特殊段。消息体段对于服务器来说完全透明——服务器不能查看或者修改消息体。

消息内容（Content）：包含在消息体段中的的消息数据。

持久存储（Durable）：一种服务器资源，当服务器重启时，保存的消息数据不会丢失。

临时存储（Transient）：一种服务器资源，当服务器重启时，保存的消息数据会丢失。

持久化（Persistent）：服务器将消息保存在可靠磁盘存储中，当服务器重启时，消息不会丢失。

非持久化（Non-Persistent）：服务器将消息保存在内存中，当服务器重启时，消息可能丢失。

RabbitMQ安装与配置

    本节我们使用AMQP的主要实现RabbitMQ讲解AMQP实例，因此需要事先安装RabbitMQ。又因为RabbitMQ是基于erlang语言开发的，所以安装RabbitMQ之前，先下载安装erlang。

一、安装与配置erlang

erlang语言的下载地址为https://www.erlang.org/downloads；下载的erlang语言版本是“otp_win64_21.2.exe”，

    运行erlang语言安装包“otp_win64_21.2.exe”，一直next即可完成安装erlang。

1.配置环境变量ERLANG_HOME如下图

2.环境变量path中新增 %ERLANG_HOME%\bin如下图

二、安装与配置 RabbitMQ    

 RabbitMQ的下载地址为https://www.rabbitmq.com/download.html。下载的RabbitMQ版本是“rabbitmq-server-3.7.9.exe”。  

运行RabbitMQ安装包“rabbitmq-server-3.7.9.exe”，一直next即可完成安装RabbitMQ。

1. 配置环境变量RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.9，如下图

2.环境变量path中新增%RABBITMQ_SERVER%\sbin，如下图

 3.  在cmd命令行窗口，进入到RabbitMQ的sbin目录下，运行rabbitmq-plugins.bat enable rabbitmq_management命令，打开RabbitMQ的管理组件，如图8.12所示。

4.   以管理员方式打开cmd命令，运行net start RabbitMQ命令，提示RabbitMQ服务已经启动。如图8.13所示。

三.   打开浏览器，在地址栏输入：localhost:15672, 进入如下图可视化管理页面

Spring Boot中对AMQP的自动配置

Spring Boot对AMQP的自动配置位于org.springframework.boot.autoconfigure.amqp包下，RabbitMQ是AMQP的主要实现。

在RabbitAutoConfiguration自动配置类中，为我们配置了连接的RabbitConnectionFactoryBean和RabbitTemplate，并且在RabbitAnnotationDrivenConfiguration配置类中开启了@EnableRabbit。

从RabbitProperties类中，可以看出RabbitMQ的配置可通过以“spring.rabbitmq”为前缀的属性进行配置，主要包含：

spring.rabbitmq.host=localhost #RabbitMQ服务器地址，默认为localhost

spring.rabbitmq.port=5672 #RabbitMQ端口，默认为5672

spring.rabbitmq.username=guest #默认用户名

spring.rabbitmq.password =guest #默认密码

                                  应用实例

【例8-2】使用RabbitMQ实现发布/订阅式异步消息通信。

    在本例中，创建一个发布者应用、两个订阅者应用。该实例中的三个应用都是使用Spring Boot默认为我们配置的RabbitMQ，主机为localhost、端口号为5672，所以无须在配置文件中配置RabbitMQ的连接信息。另外，三个应用需要使用Weather实体类封装消息，并且使用JSON数据格式发布和订阅消息。

1．创建发布者应用ch8_2Sender

2．创建订阅者应用ch8_2Receiver-1

3．创建订阅者应用ch8_2Receiver-2

4．测试运行