RabbitMQ进阶 - 优先级队列

Abel sun2022年12月24日

RabbitMQ
MQ

约 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

昵称

邮箱

网址

按正序
按倒序
按热度

RabbitMQ进阶 - 优先级队列

# RabbitMQ进阶 - 优先级队列

# 1. 简介

# 2. 代码实现

预览:

RabbitMQ进阶 - 优先级队列

1. 简介

2. 代码实现