消费者模式与并发专题
专题说明
本专题系统讲解 RabbitMQ 消费者的各种工作模式及并发处理机制，包括预取值调优、多线程消费、批量处理等核心内容，帮助构建高性能的消息消费系统。
学习目标
- 理解 RabbitMQ 各种消费者模式的特点与适用场景
- 掌握预取值（prefetch）的配置与调优策略
- 掌握多线程并发消费的实现方式与注意事项
- 能够设计高吞吐、低延迟的消息消费方案
学习建议
建议结合实际压测数据理解预取值和并发数对消费性能的影响。
📝 配套习题（20 题）
💡 参考答案在文末
判断题
1
启用并发消费者后，同一队列中的消息仍然能严格按照发送顺序被处理。
2
使用批量确认时，如果消费者在调用 basicAck(deliveryTag, true) 之前崩溃，所有未确认的消息（包括已成功处理但尚未确认的消息）都会重新入队等待再次消费。
3
在手动确认模式下，如果消费者在处理消息时开启了数据库事务，应该在数据库事务提交成功后再调用 basicAck 确认消息。
4
basicQos 设置后，只对设置之后新创建的消费者生效，对已存在的消费者不生效。
单选题
5
在 Spring AMQP 中，以下哪种配置能实现消息并发消费？
6
关于手动确认（manual acknowledgment），以下哪种做法是最佳实践？
7
RabbitMQ Java 客户端的 ConnectionFactory 默认启用了 Connection 自动恢复功能，以下关于自动恢复的说法正确的是：
8
关于 RabbitMQ 消费者预取数量（prefetch count），以下说法正确的是：
9
使用 basicAck(deliveryTag, true) 进行批量确认时，以下说法正确的是：
多选题
10
关于预取数量（prefetch count）对系统性能的影响，以下说法正确的有哪些？
11
在 Java 客户端实现并发消费者模型时，以下说法正确的有哪些？
12
在实现消费者异常恢复时，以下哪些做法有助于提高系统的可靠性？
13
以下哪些情况可能导致消息在手动确认模式下被重复消费？
14
关于批量确认的性能优化效果，以下说法正确的有哪些？
15
消费者崩溃后需要实现自动恢复，以下哪些是必须包含的恢复步骤？
填空题
16
Java 客户端中 channel.basicQos(____________, 10, ____________) 表示设置全局预取数量为 10，第三个参数的含义是是否将 QoS 设置应用到整个 ____________ 而非单个消费者。
17
在实际业务中，如果消费者按批次处理消息（每批 50 条），批量确认的实现模式通常为：在处理完一批消息后，调用 basicAck(____________, true) 一次性确认本批所有消息。这种模式下需要确保每批消息的处理是 ____________ ，否则部分消息处理失败但已被确认。
18
Java 客户端中 channel.basicAck(____________, ____________) 用于确认消息，其中第一个参数表示消息的 ____________ ，第二个参数 false 表示不启用 批量确认 。
19
在 Java 客户端中，可以通过 connection.addShutdownListener(____________) 或 channel.addShutdownListener(____________) 注册关闭监听器来感知连接或通道的异常关闭，并在监听器回调中执行自定义的 ____________ 。
简答题
20
某系统需要实现订单消息的并发处理，请描述使用 RabbitMQ Java 客户端实现并发消费者模型的最佳实践架构。
参考答案
1.错误
2.正确
3.正确
4.错误
5.A
6.B
7.C
8.A
9.C
10.A;B;C;D
11.A;C
12.A;B;C;D
13.A;B;C
14.A;B;D
15.A;B;C;D
16.0;false;通道(channel)
17.本批最大 deliveryTag;原子的/要么全部成功要么全部失败
18.deliveryTag;false;投递标签## 解析
`basicAck` 方法的参数说明：
1. **deliveryTag**：消息的投递标签（唯一标识符），由 RabbitMQ 在投递消息时自动分配。消费者通过 deliveryTag 标识要确认的具体消息。
2. **multiple**：是否批量确认。
- `false`：仅确认 deliveryTag 对应的单条消息。
- `true`：确认所有 deliveryTag 小于等于当前值且未确认的消息（批量确认）。
典型用法：
```java
// 确认单条消息
channel.basicAck(deliveryTag, false);
// 批量确认（确认所有未确认的、deliveryTag <= 当前值的消息）
channel.basicAck(deliveryTag, true);
```
注意：deliveryTag 是 Channel 级别的递增整数，不同 Channel 的 deliveryTag 独立。
19.shutdownListener;shutdownListener;恢复逻辑/重连逻辑
20.略
想在手机上练习这套专题？
使用微信卷王开发者小程序，打开首页顶部扫码功能识别二维码
