PHP消息幂等消费 先说问题 消息队列重试机制 → 同一条消息可能投递多次 订单消息消费两次 → 扣款两次 → 用户投诉 ↑ 必须保证"处理多次 = 处理一次"---幂等的三个层面1.最简单-Redis 去重classIdempotentConsumer{publicfunctionconsume(array$message):void{$msgId=$message['id'];// 消息唯一ID（MQ自带或业务生成）$key="consumed:$msgId";// SET NX = 只有不存在时才设置，原子操作$isNew=$this->redis->set($key,1,['NX','EX'=>86400]);if(!$isNew){return;// 重复消息，直接跳过}$this->process($message);// 真正处理}}问题：process()失败了，但 Redis 已标记"已消费"→ 消息丢失---2.正确姿势-先执行后标记+数据库唯一键publicfunctionconsume(array$message):void{$msgId=$message['id'];try{$this->pdo->beginTransaction();// 唯一键冲突 = 重复消息，直接忽略$this->pdo->exec(" INSERT IGNORE INTO consumed_messages (msg_id, created_at) VALUES ('$msgId', NOW()) ");if($this->pdo->rowCount()===0){$this->pdo->rollBack();return;// 重复，跳过}$this->processOrder($message);// 业务逻辑$this->pdo->commit();}catch(\Exception$e){$this->pdo->rollBack();// 失败回滚，消息可重试throw$e;}}关键：INSERTIGNORE+事务，业务处理和去重记录原子完成---3.业务层幂等-状态机兜底// 即使去重失败，业务状态机也能拦截publicfunctionprocessOrder(array$msg):void{$order=Order::find($msg['order_id']);// 状态检查：不是待支付 → 已处理过，直接跳过if($order->status!=='pending'){return;}// UPDATE 加状态条件，天然幂等$affected=$this->pdo->exec(" UPDATE orders SET status = 'paid', paid_at = NOW() WHERE id ={$msg['order_id']}AND status = 'pending' ");if($affected===0)return;// 并发下已被处理，安全跳过$this->deductBalance($msg);// 扣款}---4.消息ID生成（没有唯一ID时）// 用业务字段组合生成幂等key，比随机UUID更可靠functionbuildMsgId(array$message):string{returnmatch($message['type']){'pay'=>"pay:{$message['order_id']}:{$message['amount']}",'notify'=>"notify:{$message['user_id']}:{$message['event']}",default=>md5(json_encode($message)),};}---三层防御组合 第一层：RedisNX→ 快速拦截99%重复（性能好） 第二层：DB唯一键 → 兜底，防Redis故障 第三层：状态机条件 → 业务语义保障，最终防线 消息到来 → Redis检查 →DB插入 → 业务状态检查 → 执行 ↓重复 ↓重复 ↓已处理 跳过 跳过 跳过---常见坑 坑1:先标记再处理 → 处理失败消息丢失 ✗ 坑2:只用Redis去重 → Redis重启丢数据 ✗ 坑3:事务外做去重检查 → 并发竞争失效 ✗ 坑4:用消息内容md5做ID→ 相同内容≠相同业务 ✗ 正确:DB唯一键+事务+业务状态机三层 ✓---一句话 幂等=Redis 快速拦截+数据库唯一键兜底+状态机条件更新，缺一不可。
