@@ -1,58 +0,0 @@ RabbitMQ进阶 - 优先级队列 | 凤凰涅槃进阶之路

RabbitMQ进阶 - 优先级队列

Abel sun2022年12月24日
约 184 字小于 1 分钟

RabbitMQ进阶 - 优先级队列

1. 简介

优先级高的消息具备 优先被消费 的特权。

2. 代码实现

在定义队列时,可通过参数 x-max-priority 来指声明此队列的最大优先级别。在发送消息时,给消息设置的最大级别不能超过这个值

// 定义队列支持的最大级别
final HashMap<String, Object> arguments = new HashMap<>();
arguments.put("x-max-priority", 10);
channel.queueDeclare("queue.priority", true, false, false, arguments);

// 发送消息时设置消息的优先级
final AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties().builder();
builder.deliveryMode(2); // 持久化消息
builder.priority(5);  //设置消息的优先级别
channel.basicPublish(EXCHANGE_NAME,
                     "",
                     builder.build(),
                     "test".getBytes()
                    );

 

在 web 中展示的竖线是 Pri

image-20220923204004494

评论
  • 按正序
  • 按倒序
  • 按热度
Powered by Waline v2.9.1