RabbitMQ笔记整理.md · 辰星/rabbitmq_homework

# 							*RabbitMQ*

# **一、JMS规范和AMQP协议**

### 	**JMS**：java的消息服务，是java平台中关于面向消息中间件的API，用于两个应用程序之间，或分布式系统中发送消息，进行异步通信。 类似JDBC

### 	**消息类型**（消息头、消息体）

消息头（必须）：包含消息寻找路由的操作设置;

消息体（可选）：允许用户创建5种消息类型（文本消息、映射消息、字节消息、流消息、对象消息）

### 	**体系架构：**

1、JMS供应商产品; 2、JMS Client; 3、JMS Producer ;

4、JMS Consumer; 5、JMS Message; 6、JMS Queue;

7、JMS Topic;

### 	**对象模型**:

connectionFactory-->connection-->destination-->session-->messageConsumer、messageProducer-->message(消息头、消息属性、一个消息体)

### 	**模式**:

1、点对点队列模式;

2、发布、订阅模式;

消息传递的持久化和非持久化;

## AMQP协议（高级的消息队列协议）:

publisher、consumer、server（broker）、virtual host、exchange、routingkey

bindings、message queue

# **二、RabbitMQ整体逻辑架构**：

![](C:\Users\Administrator\AppData\Roaming\Typora\typora-user-images\image-20210428145828619.png)

### **RabbitMQ Exchange类型**：fanout（风扇）、direct（完全匹配）、topic（模糊匹配）、headers（headers属性，键值对完全匹配）；

### RabbitMQ数据存储：

### 	1，持久化消息（在持久化消息达到队列时写入磁盘，同时会在内存中保存一份备份，内存吃紧时则清楚来提供性能）；

### 	2，非持久化消息只存在内存中，当内存压力大时刷盘处理，以节省内存空间；

### 	RabbitMQ存储层包含两个部分：队列索引和消息存储；

### **生产者发送消息的流程**

1，连接rabbitmq，建立tcp连接，开启channel。

2，声明Exchange交换器，并设置相关属性（类型持久化等）。

3，声明队列并设置相关属性（排他、持久化、自动删除等）。

4，通过bindingkey将交换器和队列绑定起来。

5，生产者发送消息到rabbitmq broker（路由键、交换器）。

6，响应的交换器根据接收的routingkey查找匹配的队列。

7，找到则把消息存入相对应的队列中。

8，没有找到则根据配置的属性选择丢弃还是回退给生产者。

9，关闭信道。

10，关闭连接。

### **消费者接收消息的过程**：

辰星/rabbitmq_homework

简介

发行版

贡献者

近期动态

辰星/rabbitmq_homework .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

辰星/rabbitmq_homework