RabbitMQ的confirm+manual ack仅保障消息链路可靠，无法确保业务语义一致；必须搭配Redis作为状态快照中心，用SETNX原子记录message_id→"done"，实现生产者业务完成确认与消费者幂等消费的协同。
不能靠 RabbitMQ 单独扛住大并发下的事务一致性，必须搭配 Redis 做状态协同——否则消息发出去了、本地事务回滚了，消费者照常消费，数据就错乱了。
为什么 RabbitMQ 的 confirm + manual ack 不足以支撑最终一致性
RabbitMQ 自带的 publisher-confirms 和 acknowledge-mode=manual 只解决「链路可靠」，不解决「业务语义一致」。比如：
- 生产者本地事务提交成功，但网络抖动导致
confirm未收到，重发时可能重复落库； - 消费者收到消息、处理成功、发了
ack，但下游服务写库失败，此时 RabbitMQ 已认为该消息完成； - 没有全局唯一的状态标记，无法判断「这条消息对应的操作是否已在业务侧真实生效」。
所以必须引入 Redis 作为轻量、高吞吐的「业务状态快照中心」，用它记录「哪些消息已确认业务完成」。
Redis 存什么？怎么存才扛得住大并发
核心只存一个东西：message_id → status，且 status 必须是原子可判的。推荐用 SETNX + 过期时间，而不是先 GET 再 SET：
立即学习“Java免费学习笔记（深入）”；
- 避免查-改非原子操作带来的竞态（比如两个线程同时查到不存在，都去执行业务）；
- 用
SET message_id success EX 3600 NX一条命令完成「首次设置成功即代表业务已确认」； - 过期时间设为略大于最大业务处理耗时（如 1 小时），防止死锁或脏状态长期残留；
- 不要存完整消息体或 JSON，只存 ID 和固定字符串值（如
"done"），减少序列化开销和内存压力。
示例代码片段（Jedis）：
String messageId = "msg_abc123";
String result = jedis.set(messageId, "done", SetParams.setParams().nx().ex(3600));
if ("OK".equals(result)) {
// 首次设置成功：说明这是第一次真正完成业务，可放心发 MQ
rabbitTemplate.convertAndSend(exchange, routingKey, payload);
} else {
// 已存在：说明业务已成功过，跳过发送（防重）
}
消费者如何安全幂等地消费
消费者不是无脑处理消息，而是「先查 Redis，再执行业务，最后删或更新状态」：
- 收到消息后，立即用
message_id查询 Redis：jedis.get(messageId)； - 如果返回
null或不是"done"，说明生产者还没确认业务完成 → 暂缓处理，可nack并延迟重试（比如 5s 后）； - 如果返回
"done"，再检查本地数据库是否已存在对应业务记录（双重保险）； - 只有「Redis 确认 + DB 未存在」才执行业务逻辑，完成后更新 DB，并可选地用
DEL清除 Redis 中的临时标记（或留着供审计）。
关键点：Redis 查的是「生产者是否已 commit 业务」，不是「消息是否发过」。这层语义隔离，才是跨服务一致性的锚点。
大并发下容易被忽略的三个硬伤
很多人卡在压测阶段才发现问题，本质是没对齐边界：
-
message_id必须全局唯一且业务可追溯（不能用 UUID.randomUUID()，建议拼接 service + traceId + timestamp）； - Redis 连接池必须调大（
maxTotal≥ 200），否则高并发下SETNX阻塞会拖垮整个消息链路； - RabbitMQ 的
prefetchCount要设小（如 1～10），避免消费者一次性拉太多消息却卡在 Redis 查询上，造成堆积和超时。
最终一致性不是“等它自己好”，而是用 Redis 把「业务完成」这个动作显式暴露出来，让所有参与方都基于同一个事实做决策。这点一旦漏掉，再多的重试和死信队列都救不回数据错位。
