Redis缓存故障时，如何重试调度队列任务？

问题背景 #

应用通过HereTheJob::dispatch($this)调度任务，此前运行正常，但数千个任务中有一个因Redis报错未成功调度，报错信息为RedisClusterException: Error processing response from Redis node!。配置：队列使用SQS，缓存使用Redis；任务实现ShouldBeUnique接口，唯一任务信息存储在Redis中。需解决Redis故障时如何重试调度该任务的问题。

手动重试方案 #

• 直接定位未成功调度的任务实例，在Redis恢复后重新执行HereTheJob::dispatch($instance)。
• 若无法直接获取任务实例，可根据业务唯一标识（如订单ID、用户ID）重新构建任务对象，再执行调度。

自动重试的代码优化 #

1. 捕获Redis异常触发自动重试
   在调度逻辑中加入异常捕获，针对RedisClusterException使用Laravel的重试机制：

   use Illuminate\Redis\Connections\RedisClusterException;
   use Illuminate\Support\Facades\Retry;
   
   Retry::times(3)->waitSeconds(5)->execute(function () {
       HereTheJob::dispatch($this);
   }, [RedisClusterException::class]);
   

   该代码会在捕获到Redis集群异常时，自动重试3次，每次间隔5秒，直至成功或重试次数耗尽。

2. 紧急降级：临时跳过唯一性校验
   若Redis故障持续，可临时绕过ShouldBeUnique校验（需注意重复任务风险，仅限紧急场景）：

   • 给任务添加临时属性，修改uniqueId()方法：

     public function uniqueId()
     {
         if (property_exists($this, 'skipUniqueCheck') && $this->skipUniqueCheck) {
             return uniqid(); // 生成临时唯一ID，绕过Redis存储的唯一性校验
         }
         return $this->business_id; // 原有业务唯一标识
     }
     

   • 调度时设置属性：

     $job = new HereTheJob($this);
     $job->skipUniqueCheck = true;
     dispatch($job);
     

   后续需通过业务逻辑排查是否出现重复执行的任务。

3. 监控与兜底
   配置Redis集群的监控告警，异常时及时通知运维恢复服务；同时记录调度失败的任务日志，便于后续回溯和批量重试。

内容的提问来源于stack exchange，提问作者aceraven777