RabbitMQ系列【13】优先级队列

深藏阁楼爱情的钟 2023-10-09 15:09 32阅读 0赞

> **有道无术，术尚可求，有术无道，止于术。**

#### 文章目录 ####

*   *  前言
     *  1. 设置优先级队列
     *  2. 消息设置优先级

### 前言 ###

`RabbitMQ`将消息写入队列中都是按顺序写的，消费时也是按顺序进行消费，队列中的消息是**先进先出(FIFO)**.。![在这里插入图片描述][86a8a5a23382431681f67c09669d7374.png]  
首先测试一下没有优先级的效果。先注释掉所有的消费者，不然发一个就消费一个，看不出优先级的效果，只有消息堆积在一起时，才能看到效果。

先发送10条消息：  
![在这里插入图片描述][9d5f72dd563242a3b85802a7187beddc.png]  
发送完成后，再开启消费者进行消费，没有设置优先级，那么先到达队列的消息先消费，收到的消息会从按照`0-9`的顺序消费。可以看到其时按照投递顺序消费，先进先出：  
![在这里插入图片描述][d73a817c3b484413b72ec7a358519be7.png]  
在一些场景中我们需要将某些消息优先处理，也就是设置`优先级`，优先级高的消息优先被消费。

### 1. 设置优先级队列 ###

可以直接在控制台，设置队列的最大优先级，优先级的取值范围为`0~255`，一般设置最大值为`10`。  
![在这里插入图片描述][ce00cc3e24f14ea49313aa2536b864c4.png]  
添加优先级后，可以在队列中看到`Pri`标记：  
![在这里插入图片描述][bd5b69d2f0ec4abebfde094e9d07f043.png]  
在代码中，可以添加`x-max-priority`参数设置：

@Bean("priorityQueue")
        public Queue priorityQueue() {
        
            Map<String, Object> arguments = new HashMap<>();
            arguments.put("x-max-priority", 10);
            return QueueBuilder.durable("priorityQueue").withArguments(arguments).build();
        }
    
    	@Bean("priorityExchange")
        public Exchange priorityExchange() {
        
            return ExchangeBuilder.directExchange("priorityExchange").durable(true).build();
        }
    
        @Bean("priorityBinding")
        public Binding priorityBinding(@Qualifier("priorityQueue") Queue priorityQueue, @Qualifier("priorityExchange") Exchange priorityExchange) {
        
            return BindingBuilder.bind(priorityQueue).to(priorityExchange).with("priority.key").noargs();
        }

也可以使用`maxPriority`方法设置：

@Bean("priorityQueue")
        public Queue priorityQueue() {
        
            // maxPriority 设置最大优先级
            return QueueBuilder.durable("priorityQueue").maxPriority(10).build();
        }

### 2. 消息设置优先级 ###

设置完优先级队列后，发送消息时，需要设置优先级。

这里循环发送十条消息，优先级从`0~9` 递增：

for (int i = 0; i < 10; i++) {
        
                MessageProperties messageProperties = new MessageProperties();
                messageProperties.setPriority(i); // 设置优先级
                System.out.println("发送消息，优先级为："+i);
                Message message = new Message(("消息优先级为："+i).getBytes(), messageProperties);
                TimeUnit.SECONDS.sleep(1);
                rabbitTemplate.send("priorityExchange", "priority.key", message);
            }

**发送消息：**

![在这里插入图片描述][9d5f72dd563242a3b85802a7187beddc.png]  
开启消费者消费，可以看到优先级高的优先被消费：  
![在这里插入图片描述][4bcc868e00154685b534cb08e3a1aa9f.png]

[86a8a5a23382431681f67c09669d7374.png]: https://img-blog.csdnimg.cn/86a8a5a23382431681f67c09669d7374.png
[9d5f72dd563242a3b85802a7187beddc.png]: https://img-blog.csdnimg.cn/9d5f72dd563242a3b85802a7187beddc.png
[d73a817c3b484413b72ec7a358519be7.png]: https://img-blog.csdnimg.cn/d73a817c3b484413b72ec7a358519be7.png
[ce00cc3e24f14ea49313aa2536b864c4.png]: https://img-blog.csdnimg.cn/ce00cc3e24f14ea49313aa2536b864c4.png
[bd5b69d2f0ec4abebfde094e9d07f043.png]: https://img-blog.csdnimg.cn/bd5b69d2f0ec4abebfde094e9d07f043.png
[4bcc868e00154685b534cb08e3a1aa9f.png]: https://img-blog.csdnimg.cn/4bcc868e00154685b534cb08e3a1aa9f.png