Redis Streams 怎么配置幂等消息生产

订单服务遇到网络抖动时，最容易出现的不是 Redis 丢消息，而是客户端超时后重试，导致同一个业务事件被 XADD 两次。现在的配置重点是：Redis 8.6 及以上优先使用 IDMP 或 IDMPAUTO；较旧版本则用业务幂等号做去重门闩。两种方案都只能约束生产阶段，不能自动让消费、落库和外部调用变成 exactly-once。

官方地址：https://redis.io/docs/latest/commands/xadd/

Redis Streams 的幂等生产先看版本与边界

官方 XADD 文档把 IDMP 和 IDMPAUTO 标为 Redis 8.6 起可用的能力。IDMP 由调用方传入 producer-id 和 idempotent-id；相同组合再次写入时，Redis 返回原 Stream entry ID，不再追加重复条目。IDMPAUTO 则让 Redis 自动生成幂等号，适合重试时消息字段保持一致的生产者。

因此，先把“同一事件”定义清楚。订单支付成功事件可以用 pay:{order_id}:{payment_id}，不要把每次 HTTP 请求的随机 request-id 当成幂等号。需要允许同一订单发生两次合法支付时，payment_id 必须参与组成，而不是只用 order_id。

Redis 8.6 及以上这样配置 IDMP

下面的示例把生产者固定为 payment-service，把支付事件号固定为 pay:1001:p9001。幂等能力只在自动生成 entry ID（即 *）时生效；不要同时手写一个可能变化的 Stream ID。

# 为近期重复请求设置保留时间和每个生产者的跟踪数量
redis-cli XCFGSET order-events IDMP-DURATION 3600 IDMP-MAXSIZE 100000

# 第一次写入：业务幂等号由生产者稳定生成
redis-cli XADD order-events IDMP payment-service pay:1001:p9001 '*' \
  order_id 1001 payment_id p9001 amount 99.00

# 重试同一个事件：返回第一次的 entry ID，不追加第二条消息
redis-cli XADD order-events IDMP payment-service pay:1001:p9001 '*' \
  order_id 1001 payment_id p9001 amount 99.00

# 如果业务字段本身就是重试判定依据，也可以让 Redis 自动生成幂等号
redis-cli XADD order-events IDMPAUTO payment-service '*' \
  order_id 1001 payment_id p9001 amount 99.00

IDMP-DURATION 和 IDMP-MAXSIZE 是保留窗口，不是永久唯一索引。重试可能跨过窗口时，仍应在业务数据库或长期去重表保留事件号。生产环境先用 XLEN、消费延迟和重试时间分布估算窗口，再决定 3600 秒是否足够。

旧版本用 SET NX 时要补上失败补偿

Redis 8.5 及更早版本没有上述 IDMP 参数，可以把稳定业务号放进一个短期去重键，用 SET ... NX EX 抢占写入资格，再执行 XADD：

# NX 只有在业务幂等键不存在时才成功，EX 防止门闩永久占用
redis-cli SET dedup:pay:1001:p9001 payment-service NX EX 3600

# 只有上一条返回 OK，才继续追加 Stream 事件
redis-cli XADD order-events '*' \
  event_id pay:1001:p9001 order_id 1001 payment_id p9001 amount 99.00

这个兼容方案要明确记录“门闩成功但 XADD 失败”的异常：不能简单删除门闩后无限重试，否则并发请求可能同时通过；也不能把门闩当作消息已经落盘。更稳妥的做法是把门闩状态、事件补偿和告警交给事务性 outbox，或者升级到支持原生 IDMP 的 Redis 版本。

生产幂等不等于消费端只执行一次

写入成功后，如果用消费者组读取，XREADGROUP 会把已投递但未确认的消息放进 Pending Entries List；业务处理成功后还要调用 XACK。消费者宕机、超时转移或人工重放都可能再次执行业务动作，所以支付状态更新、库存扣减、通知发送仍要使用业务唯一键或幂等记录。

常见问题

IDMP 能保证消息永远不重复吗？

不能。它受 IDMP-DURATION 和 IDMP-MAXSIZE 的保留范围限制，窗口外的相同事件号仍可能再次进入 Stream。

IDMP 能代替 XACK 吗？

不能。IDMP 处理生产阶段的重复写入，XACK 处理消费者组的确认，两者位于不同链路。

业务幂等号应该怎么生成？

使用跨重试保持不变、跨合法事件可区分的业务事实组合，例如支付单号或订单号加支付单号，不要使用每次请求都会变化的随机数。