# springboot-RabbitMQ

**Repository Path**: juniorshy/springboot-RabbitMQ

## Basic Information

- **Project Name**: springboot-RabbitMQ
- **Description**: RabbitMQ整合
1. 引入 spring-boot-starter-amqp
2. application.yml配置
3. 测试RabbitMQ
1. AmqpAdmin：管理组件
2. RabbitTemplate：消息发送处理组件
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2018-10-25
- **Last Updated**: 2024-03-13

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# springboot-amqp

#### 项目介绍
RabbitMQ整合
1. 引入 spring-boot-starter-amqp
2. application.yml配置
3. 测试RabbitMQ
1. AmqpAdmin：管理组件
2. RabbitTemplate：消息发送处理组件

#### 笔记
1. 大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力
2. 消息服务中两个重要概念：
消息代理（message broker） 和目的地（destination）
当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目
的地。
3. 消息队列主要有两种形式的目的地
1. 队列（queue） ：点对点消息通信（point-to-point）
2. 主题（topic） ：发布（publish） /订阅（subscribe）消息通信
![yibuchuli](https://images.gitee.com/uploads/images/2018/1025/151300_d76392b3_1394856.png "yibuchuli.png")
 
  

4. 点对点式： – 消息发送者发送消息，消息代理将其放入一个队列中，消息接收者从队列中获取消息内容， 消息读取后被移出队列 – 消息只有唯一的发送者和接受者，但并不是说只能有一个接收者
5. 发布订阅式： – 发送者（发布者）发送消息到主题，多个接收者（订阅者）监听（订阅）这个主题，那么 就会在消息到达时同时收到消息
6. JMS（Java Message Service） JAVA消息服务： – 基于JVM消息代理的规范。 ActiveMQ、 HornetMQ是JMS实现
7. AMQP（Advanced Message Queuing Protocol） – 高级消息队列协议，也是一个消息代理的规范，兼容JMS – RabbitMQ是AMQP的实现    


![image03](https://images.gitee.com/uploads/images/2018/1025/151355_89bf1984_1394856.png "image03.png")
8. Spring支持 – spring-jms提供了对JMS的支持 
   1.  – spring-rabbit提供了对AMQP的支持
   2.  – 需要ConnectionFactory的实现来连接消息代理 
   3. – 提供JmsTemplate、 RabbitTemplate来发送消息
   4.  – @JmsListener（JMS）、 @RabbitListener（AMQP）注解在方法上监听消息代理发 布的消息 – @EnableJms、 @EnableRabbit开启支持
9. Spring Boot自动配置 – JmsAutoConfiguration – RabbitAutoConfiguration    



## #RabbitMQ笔记

RabbitMQ： RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue Protocol)的开源实现。 

核心概念 

**Message** 消息，消息是不具名的，它由消息头和消息体组成。消息体是不透明的，而消息头则由一系列的可选属性组 成，这些属性包括routing-key（路由键）、 priority（相对于其他消息的优先权）、 delivery-mode（指出 该消息可能需要持久性存储）等。

 **Publisher** 消息的生产者，也是一个向交换器发布消息的客户端应用程序。

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

 Exchange有4种类型： direct(默认)， fanout, topic, 和headers，不同类型的Exchange转发消息的策略有 所区别   

**Queue** 消息队列，用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息 可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将其取走。    

**Binding** 绑定，用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连 接起来的路由规则，所以可以将交换器理解成一个由绑定构成的路由表。 Exchange 和Queue的绑定可以是多对多的关系。 **Connection** 网络连接，比如一个TCP连接。 

**Channel** 信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚 拟连接， AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这 些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销，所 以引入了信道的概念，以复用一条 TCP 连接。    

**Consumer** 消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。 Virtual Host 虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加 密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有 自己的队列、交换器、绑定和权限机制。 vhost 是 AMQP 概念的基础，必须在连接时指定， RabbitMQ 默认的 vhost 是 / 。    

**Broker** 表示消息队列服务器实体   

![image04](https://images.gitee.com/uploads/images/2018/1025/151721_1368befd_1394856.png "image04.png")
## RabbitMQ运行机制    

AMQP 中的消息路由 • AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别， AMQP 中增加了 Exchange 和 Binding 的角色。生产者把消息发布到 Exchange 上，消息最终到达队列并被 消费者接收，而 Binding 决定交换器的消息应该发送到那个队列。    


![image05](https://images.gitee.com/uploads/images/2018/1025/151416_0d68d061_1394856.png "image05.png")
**Exchange 类型**    

Exchange分发消息时根据类型的不同分发策略有区别，目前共四种类型： direct、 fanout、 topic、 headers 。 headers 匹配 AMQP 消息的 header 而不是路由键， headers 交换器和 direct 交换器完全一致，但性能差很多， 目前几乎用不到了，所以直接看另外三种类型：    

![消息中的路由键](https://images.gitee.com/uploads/images/2018/1025/151448_d8b5d314_1394856.png "direct.png")

![fanoutAndtopic](https://images.gitee.com/uploads/images/2018/1025/151516_b16a420c_1394856.png "fanoutAndtopic.png")