rabbitmq-02 rabbitmq五种队列

迈不过友情╰ 2022-02-09 14:15 252阅读 0赞

# 1.消息队列RabbitMQ的五种形式队列 #

*  点对点(简单)的队列
 *  工作(公平性)队列模式
 *  发布订阅模式(fanout)
 *  路由模式Routing
 *  通配符模式Topics

[官网][Link 1]

# 2.点对点(简单)的队列 #

![在这里插入图片描述][20190503153238460.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70]

## 2.1 代码实现 ##

### 2.1.1 添加依赖 ###

<dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>3.6.5</version>
    </dependency>

### 2.1.2 创建工具类 ###

*  [MQConnectionUtils][]

### 2.1.3 生产者 ###

*  [SimpleProducer][]

### 2.1.4 消费者 ###

*  [SimpleCustomer][]

# 3.工作(公平性)队列模式 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 2]

## 3.1 代码实现 ##

### 3.1.1 添加依赖 ###

*  同 2.1.1

### 3.1.2 生产者 ###

*  [WorkProducer][]

### 3.1.3 消费者 ###

*  [WorkCustomer][]

# 4.发布订阅模式(fanout) #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 4]  
这个可能是消息队列中最重要的队列了，其他的都是在它的基础上进行了扩展。  
功能实现：一个生产者发送消息，多个消费者获取消息（同样的消息），包括一个生产者，一个交换机，多个队列，多个消费者。

思路解读（重点理解）：

1.  一个生产者，多个消费者
2.  每一个消费者都有自己的一个队列
3.  生产者没有直接发消息到队列中，而是发送到交换机
4.  每个消费者的队列都绑定到交换机上
5.  消息通过交换机到达每个消费者的队列

该模式就是Fanout Exchange（扇型交换机）将消息路由给绑定到它身上的所有队列  
注意：交换机没有存储消息功能，如果消息发送到没有绑定消费队列的交换机，消息则丢失。

## 4.1 代码实现 ##

### 4.1.1 添加依赖 ###

*  同2.1.1

### 4.1.2 生产者 ###

*  [PSProducer][]

### 4.1.3 邮件消费者 ###

*  [PsConsumerEmailFanout][]

### 4.1.4 短信消费者 ###

*  [PsConsumerSmsFanout][]

# 5.路由模式Routing #

## 5.1 简介 ##

生产者发送消息到交换机并指定一个路由key，消费者队列绑定到交换机时要制定路由key（key匹配就能接受消息，key不匹配就不能接受消息）

![在这里插入图片描述][2019050315340268.png]

例如：我们可以把路由key设置为insert ，那么消费者队列key指定包含insert才可以接收消息，消费者队列key定义为update或者delete就不能接收消息。很好的控制了更新，插入和删除的操作。

采用交换机direct模式

## 5.2 代码实现 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 5]

### 5.2.1 添加依赖 ###

*  略

### 5.2.2 生产者 ###

*  [RoutingProducer][]

### 5.2.3 邮件消费者 ###

*  [RoutingConsumerEmailFanout][]

### 5.2.4 短信消费者 ###

*  [RoutingConsumerSmsFanout][]

# 6.主题模式(通配符模式) #

## 6.1 简介 ##

此模式实在路由key模式的基础上，使用了通配符来管理消费者接收消息。生产者P发送消息到交换机X，type=topic，交换机根据绑定队列的routing key的值进行通配符匹配；

*  符号\#：匹配一个或者多个词lazy.\# 可以匹配lazy.irs或者lazy.irs.cor
 *  符号\*：只能匹配一个词lazy.\* 可以匹配lazy.irs或者lazy.cor  
    ![在这里插入图片描述][20190503153432182.png]

## 6.2 代码实现 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 6]

### 6.2.1 添加依赖 ###

*  略

### 6.2.2 生产者 ###

*  [TopicProducer][]

### 6.2.3 邮件消费者 ###

*  [TopicConsumerEmailFanout][]

### 6.2.4 短信消费者 ###

*  [TopicConsumerSmsFanout][]

[Link 1]: http://www.rabbitmq.com/getstarted.html
[20190503153238460.png]: /images/20220206/544468bdcb8b45e387ab016cd80681e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70]: /images/20220206/34d903ed40ce4ec3a76aadfa9fa9d04c.png
[MQConnectionUtils]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/util/MQConnectionUtils.java
[SimpleProducer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/simple/SimpleProducer.java
[SimpleCustomer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/simple/SimpleCustomer.java
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 1]: /images/20220206/a5a5542e860640dfba97df6dc8a77072.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 2]: /images/20220206/936b68ab22a84ff69db213eb134ad3cc.png
[WorkProducer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/work/WorkProducer.java
[WorkCustomer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/work/WorkCustomer.java
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 3]: /images/20220206/3d8c63768d17464da8818bcddfe6e09f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 4]: /images/20220206/5615d722a44b40ba9c822736dbfee361.png
[PSProducer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/publishandsubscribe/PSProducer.java
[PsConsumerEmailFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/publishandsubscribe/PsConsumerEmailFanout.java
[PsConsumerSmsFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/publishandsubscribe/PsConsumerSmsFanout.java
[2019050315340268.png]: /images/20220206/0929a10b6baf42b3a7934264fe6f218d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 5]: /images/20220206/8449ba4e948b4591b5bf9e8a49f5df72.png
[RoutingProducer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/routing/RoutingProducer.java
[RoutingConsumerEmailFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/routing/RoutingConsumerEmailFanout.java
[RoutingConsumerSmsFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/routing/RoutingConsumerSmsFanout.java
[20190503153432182.png]: /images/20220206/406321f3454e4ff3a03bb42a2e7cca69.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxNDYzOTk5_size_16_color_FFFFFF_t_70 6]: /images/20220206/4d1bc05a5a1940c3b321811a30ad8f20.png
[TopicProducer]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/topic/TopicProducer.java
[TopicConsumerEmailFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/topic/TopicConsumerEmailFanout.java
[TopicConsumerSmsFanout]: https://gitee.com/itmyx/rabbitmq-demo/blob/master/rabbitmq-queue/src/main/java/com/grape/rabbitmq/queue/core/topic/TopicConsumerSmsFanout.java