RabbitMQ优先级队列需三步：声明队列时设x-max-priority（如10），发送消息时设priority值（≤上限）并持久化，消费者配置prefetch_count=1；否则插队失效。
Java 中在 RabbitMQ 实现优先级队列，关键不是改消费逻辑，而是让队列“天生支持分级”，再让消息“自带等级标签”。只要三步配对到位，高优消息自然插队，消费者照常收发即可。
声明带优先级能力的队列
普通队列完全忽略 priority 字段，必须显式启用。创建队列时通过 x-max-priority 参数指定最大支持级别：
- 推荐设为 5 或 10；设 255 不提升效果，反而增加内存和 CPU 开销
- 值为 0 或未设置 → 所有消息按 FIFO 处理，priority 被丢弃
- Spring AMQP 示例：
.withArgument("x-max-priority", 10)
.build();
原生 AMQP 示例：
Map<String, Object> args = new HashMap<>();args.put("x-max-priority", 10);
channel.queueDeclare("alert.queue", true, false, false, args);
发送时明确设置消息 priority 值
生产者需在消息属性中写入整数 priority，且不能超过队列声明的上限（超出会自动截断）：
立即学习“Java免费学习笔记（深入）”；
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 数字越大越紧急：如普通日志用 1，VIP 订单用 7，系统告警用 10
- 务必搭配 deliveryMode = 2（持久化），避免 Broker 重启后优先级信息丢失
- Java 客户端示例：
.priority(9)
.deliveryMode(2)
.contentType("text/plain")
.build();
channel.basicPublish("", "alert.queue", props, "CRITICAL_ALERT".getBytes());
Spring Boot 中也可用 MessageProperties.setPriority() 或在 convertAndSend 的回调里设置。
消费者配置 prefetch_count = 1 防阻塞
消费者无需重写业务代码，但有两个实操要点决定是否真正“优先”：
- 调用 basicQos(1)：防止一个消费者预取多个低优消息后长期占用，导致高优消息卡在队列里出不来
- 不关闭 autoAck 或谨慎处理手动 ack：若手动确认，失败时不要 nack 低优消息而让它反复重试，否则会堵住高优消息出队
- 同一优先级内仍按 FIFO，所以多个告警消息之间也保持“先发先处理”
注意这些常见失效原因
如果发了高 priority 却没看到插队效果，大概率是以下之一：
- 队列没声明 x-max-priority（控制台看不到 Pri 标识）
- 消息 priority 值 > 队列设置的上限（比如队列设 5，却发了 priority=8）
- 消费者 prefetch_count > 1，且正在处理一批低优任务
- 消息未持久化，Broker 重启后 priority 属性丢失（仅内存中保留）
已入队的低优消息无法动态提权，RabbitMQ 不支持运行时修改 priority。如需临时升级，得走死信重发或外部调度（如 Redis Sorted Set + 定时推送）。
