thinkphp 5.1 redis 队列重复消费是配置与设计不匹配的必然结果，需通过异常捕获、合理设置 retry_after（≥任务最长耗时）、手动记录失败日志及实现幂等控制（如分布式锁+业务唯一键校验）协同解决。
ThinkPHP 5.1 使用 Redis 驱动时，消费失败导致的重复消费不是偶然现象，而是配置与设计不匹配下的必然结果。核心问题在于：Redis 驱动本身不自动记录失败任务，也不保证单次执行的原子性或幂等性。必须从异常捕获、超时控制、幂等防护三方面协同处理。
Redis 驱动下 failed_jobs 表完全失效，必须手动记录失败
-
config/queue.php中配置'failed' => ['type' => 'database']对 Redis 驱动无效 -
php think queue:failed命令查不到任何 Redis 失败任务，日志也无堆栈输出 - 必须在
app/event.php或服务提供者中监听JobFailed事件
use think\queue\Event\JobFailed;
// 注册监听
event::listen(JobFailed::class, function (JobFailed $event) {
$jobName = $event->job->getName();
$exception = $event->exception;
$trace = $exception->getTraceAsString();
// 至少记录：任务名、错误信息、完整堆栈
\think\facade\Log::error("Queue Job Failed: {$jobName} | {$exception->getMessage()}");
// 生产环境建议同步写入数据库表（如 custom_failed_jobs），或上报 Sentry
db('custom_failed_jobs')->insert([
'job_name' => $jobName,
'exception' => $exception->getMessage(),
'trace' => $trace,
'created_time' => date('Y-m-d H:i:s'),
]);
});
retry_after 必须显式设为远大于任务真实耗时
- 该值不是重试间隔，而是 Redis 驱动判定“任务是否超时”的唯一依据
- 默认
60秒极易造成「任务还没执行完就被标记失败并重推」，表现为假失败 + 重复消费
以下配置更安全：
'redis' => [
'type' => 'redis',
'host' => '127.0.0.1',
'port' => 6379,
'password' => '',
'select' => 2, // 独立 DB，避免缓存干扰
'timeout' => 2,
'persistent' => true,
'expire' => 120, // 任务预期最长耗时（含网络、DB、第三方延迟）
'retry_after'=> 120, // 必须 ≥ expire，建议设为 120 或 180
],
✅ 示例：发短信任务平均耗时 45 秒，但第三方网关偶有 90 秒超时 →
retry_after至少设为120
消费端必须实现幂等控制，不能依赖 --tries 参数
-
--tries=3只是框架级兜底，每次重试都全量执行，无状态、无判断、无补偿 - 真正可靠的处理方式是在
handle()方法内主动控制：
public function handle(Job $job, $data)
{
$orderId = $data['order_id'] ?? null;
$taskId = md5("order_sync_{$orderId}_". $job->attempts());
// 1. 尝试加 Redis 分布式锁（防并发重复触发）
$lockKey = "lock:order_sync:{$orderId}";
if (!\think\facade\Cache::store('redis')->set($lockKey, 1, 30)) {
return; // 已有实例在处理，直接退出
}
try {
// 2. 查询数据库确认是否已处理（基于业务唯一键）
$exists = db('order_sync_log')->where('order_id', $orderId)->find();
if ($exists && $exists['status'] === 'success') {
$job->delete(); // 已成功，直接删任务
return;
}
// 3. 执行核心逻辑（如扣库存、发券）
$this->doSyncOrder($orderId);
// 4. 记录成功日志，确保可追溯
db('order_sync_log')->insert([
'order_id' => $orderId,
'status' => 'success',
'created_at' => date('Y-m-d H:i:s'),
]);
$job->delete();
} catch (\Exception $e) {
// 可恢复错误（如网络超时）：手动重试，限制次数
if (str_contains($e->getMessage(), 'timeout') && $job->attempts() release(10); // 10秒后重试
return;
}
// 不可恢复错误（如参数缺失、订单不存在）：记录后终止
\think\facade\Log::error("Fatal sync error for order {$orderId}: " . $e->getMessage());
throw $e; // 触发 JobFailed 事件
} finally {
\think\facade\Cache::store('redis')->delete($lockKey);
}
}
Supervisor 配置需保障优雅退出，避免任务中断丢失 ACK
- 若
stopwaitsecs缺失，supervisor 默认 10 秒后强杀进程 - ThinkPHP Redis 驱动需在退出前完成当前任务的 ACK（确认消费），否则该任务会重回队列
Supervisor 配置示例（关键项）：
[program:tp-queue-worker] command=php /www/wwwroot/your-site/think queue:work redis --daemon autostart=true autorestart=true stopwaitsecs=60 ; 给足时间让当前任务完成并 ACK user=www redirect_stderr=true stdout_logfile=/www/wwwroot/your-site/runtime/log/queue_worker.log
不复杂但容易忽略
php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
