核心是通过RabbitMQ的QoS机制+手动签收+合理预取值实现消费端限流，必须设autoAck=false、显式调用basicAck/Nack，推荐prefetchCount=1，Spring AMQP中配置prefetch和acknowledge-mode，并监控unacked消息数防阻塞。
核心思路是：**不让消费者一次性扛太多消息，靠 RabbitMQ 的 QoS 机制 + 手动签收 + 合理预取值，把流量“匀”着给**。这不是生产端控速，而是消费端主动要多少、处理完再要多少。
必须开启手动签收（autoAck = false）
这是限流生效的前提。自动签收（autoAck=true）下，RabbitMQ 一推送就认为消费成功，basicQos 完全不生效。
- 创建消费者时，Channel.basicConsume 的第 2 个参数 autoAck 必须设为 false
- 后续每条消息处理完后，必须显式调用 channel.basicAck(deliveryTag, false)
- 若处理失败，可用 channel.basicNack 拒绝并决定是否重回队列
用 basicQos 设置预取数量（prefetchCount）
这是限流的主开关。它告诉 RabbitMQ：“我最多只同时处理 N 条未确认的消息，满了就暂停推送”。
OpenClaw Docker Setup
下载
在 Linux 上通过 Docker 运行 OpenClaw，并使用 Tailscale 实现远程访问。⚠️ 涉及 sudo、Docker、Tailscale和凭证挂载——请先查阅安全章节...
- 推荐写法：channel.basicQos(1) —— 最保守，一次只拿 1 条，确认后再拿下一条
- 中等压力可设为 channel.basicQos(5) 或 10，视单条处理耗时和内存占用而定
- 注意：prefetchCount 是 per-consumer 级别（global=false 默认），不是 channel 级别
- prefetchSize（按字节限）基本不用，设 0 即可
配合 Spring AMQP 的配置方式（推荐生产使用）
如果用 Spring Boot + spring-boot-starter-amqp，直接在配置文件里控制更清晰：
立即学习“Java免费学习笔记（深入）”；
- application.yml 中设置：
spring:
rabbitmq:
listener:
simple:
prefetch: 1
acknowledge-mode: manual - 消费者方法上加 @RabbitListener，参数含 Channel 和 Message
- 业务逻辑结束后调用 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false)
避免常见陷阱
光设了 QoS 不代表万事大吉，还得防住几个典型问题：
- 不要让消费逻辑阻塞或超时太久：长时间不 ack，会导致 prefetch 被占满，后续消息卡住
- 异常必须捕获并合理 Nack 或 Reject：不能让未处理消息“悬空”，否则 prefetch 一直不释放
- 单消费者吞吐不够时，优先横向扩消费者实例，而不是盲目调高 prefetch
- 监控 unacked 消息数：通过 RabbitMQ 管理界面或 API 查看 queue 的 messages_unacknowledged，持续高位说明限流没起效或消费太慢
