RabbitMQ 优先级队列

1. 概念

在 RabbitMQ 中，优先级队列的作用是通过为消息指定一个优先级值，让队列根据消息的优先级进行排序。优先级较高的消息会比优先级较低的消息更早被消费者接收，即使后者先到达队列。

2. 示例

要启用 RabbitMQ 优先级队列，需要以下步骤：

1. 定义队列时设置最大优先级

   在声明队列时，设置队列支持的最大优先级值（通常为 1 到 255 之间）。

   @Configuration
   public class RabbitMQConfig {
       private static final String PRIORITY_QUEUE = "priority_queue";
   
       @Bean
       public Queue priorityQueue() {
           return QueueBuilder.durable(PRIORITY_QUEUE)
                   .maxPriority(10) // 定义优先级队列，最大优先级设置为 10
                   .build();
       }
   }

2. 发送消息时设置优先级

   在向队列发送消息时，设置消息的优先级。

   @Service
   public class MessageProducer {
       private final RabbitTemplate rabbitTemplate;
   
       public MessageProducer(RabbitTemplate rabbitTemplate) {
           this.rabbitTemplate = rabbitTemplate;
       }
   
       public void sendMessage(String message, int priority) {
           rabbitTemplate.convertAndSend("priority_queue", message, msg -> {
               msg.getMessageProperties().setPriority(priority); // 设置优先级
               return msg;
           });
       }
   }

3. 消费者按优先级接收消息

   消费者无需额外配置，当它从优先级队列中获取消息时，RabbitMQ 会自动将优先级高的消息优先分发。

3. 优先级队列的注意事项

1. 最大优先级值

   • x-max-priority 参数定义了队列的最大优先级。如果不设置此参数，队列将不支持优先级功能；
   • 一旦设置了最大优先级，RabbitMQ 会根据优先级进行排序，但这可能会导致更高的内存使用；

2. 优先级的默认值

   • 如果消息没有显式设置优先级，则默认优先级为 0；
   • 数字越大，优先级越高；

3. 性能影响

   启用优先级队列可能会增加 RabbitMQ 的开销，特别是高并发情况下，因为队列需要对消息进行排序。

4. 优先级值的范围

   虽然最大优先级可以设置到 255，但通常实际使用的优先级值范围较小（例如 1 到 10），以减少排序开销。