rabbitmq的work queues模式本质是一个队列由多个消费者竞争消费，实现任务分发与负载均衡；消息直投队列、每条仅被一个消费者处理，需配置队列持久化（durable=true）及消息持久化才能真正防丢失，并通过手动ack与prefetchcount=1保障公平分发与可靠性。
RabbitMQ 的 Work Queues 模式本质是“一个队列 + 多个消费者”，通过竞争消费实现任务分发与负载均衡。它不依赖交换机，消息直接投递到指定队列，由多个消费者争抢处理，每条消息只被一个消费者接收并确认。
核心配置：声明持久化队列
队列需设为持久化（durable=true），确保 RabbitMQ 重启后队列结构和未确认消息不丢失。注意：仅队列声明持久化还不够，还需配合消息持久化（设置 MessageProperties.DELIVERY_MODE_PERSISTENT）才能真正防止消息丢失。
- Java 原生客户端示例：
channel.queueDeclare("work.queue", true, false, false, null) - Spring AMQP 推荐写法：
QueueBuilder.durable("work.queue").build() - 避免使用
exclusive或autoDelete，否则多消费者无法共用该队列
生产者：发送任务消息
生产者无需特殊逻辑，只需将任务封装为消息，发布到已声明的队列即可。关键点在于启用消息持久化，让 RabbitMQ 将消息写入磁盘。
- 原生客户端：调用
basicPublish时传入MessageProperties.PERSISTENT_TEXT_PLAIN - Spring Boot 中：RabbitTemplate 默认不持久化，需手动设置
message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT) - 建议在消息体中携带任务元数据（如任务类型、重试次数、超时时间），便于消费者灵活处理
消费者：并发处理与可靠确认
启动多个相同逻辑的消费者进程（或线程），它们监听同一个队列。RabbitMQ 默认采用轮询（Round-Robin）分发，但前提是关闭自动确认（autoAck=false），启用手动 ACK。
- 必须调用
channel.basicAck(deliveryTag, false)显式确认，否则消息不会从队列删除 - 若处理失败，可调用
channel.basicNack并设置requeue=true让消息重回队尾重试 - 推荐设置
prefetchCount=1（QoS），防止某个消费者堆积过多未确认消息，导致其他消费者空闲
实际运行注意事项
Work Queues 看似简单，但几个细节常被忽略：
- 多个消费者应部署在不同机器或进程，避免单点故障；同一 JVM 内启多线程消费者需注意资源隔离
- 消费者处理逻辑必须幂等，因网络中断或异常可能导致重复投递（至少一次语义）
- 监控队列长度、消费者数量、未确认消息数（
messages_unacknowledged），及时发现处理瓶颈 - 不要依赖轮询绝对均等——若消费者处理速度差异大，可用
basicQos+ 手动 ACK 实现更公平的“能者多劳”
