Laravel使用database队列驱动如何限流实现每分钟发1封邮件

Laravel 自带的 Redis::throttle 队列限流中间件仅适配 Redis 队列驱动，database 队列驱动默认没有内置同等的原子限流能力，但无需更换驱动、无需额外安装 Redis 组件，完全可以基于现有 file 缓存 + database 队列的配置，实现你需要的发信频率限制，满足共享主机每小时发信不超过200封的要求。

你当前在任务分发阶段统一调用 ->delay(now()->addSeconds(30)) 的写法，本质是给所有批量分发的任务设置了同一个相对执行时间——所有任务都会在「分发时刻+30秒」的时间点同时进入可执行状态，队列 worker 会一次性拉取所有到期任务无间隔执行，自然只会出现第一个任务有延迟、其余任务直接发送的问题，根本达不到逐封限流的目的。

直接使用 Laravel 原生提供的缓存原子锁能力实现限流，逻辑和 Redis::throttle 完全一致：任务执行前先抢占全局发信锁，抢到锁才执行发信逻辑，抢不到就将任务延迟后重新放回队列等待下次重试。

• 第一步：移除原有分发逻辑里的全局delay配置
  把sendEmailNotification方法里的延迟调用删掉，所有发信任务正常分发即可，限流逻辑统一收敛到任务内部处理：

  public function sendEmailNotification($email,$data)
  {
      $email_job = new ProcessEmailNotificationJob($email,$data);
      return $this->dispatch($email_job);
  }
  

• 第二步：修改队列任务的handle方法，加锁限流逻辑
  在ProcessEmailNotificationJob的handle方法中加入缓存锁判断，代码如下：

  public function handle()
  {
      // 所有发信任务共用同一个锁键，实现全局发信频率控制
      $lockKey = 'email_send_global_throttle';
      // 配置限流规则：锁持有30秒，即每30秒最多允许1个任务拿到锁发信
      $lock = cache()->lock($lockKey, 30);
  
      try {
          if ($lock->get()) {
              // 成功获取锁，执行发信逻辑
              Mail::to($this->email)->send(new NotificationEmail($this->data));
              Log::info('Emailed order ' . $this->email);
              // 发信完成后不主动释放锁，等锁30秒自动过期，保证间隔期内其他任务拿不到锁
          } else {
              // 获取锁失败，将任务延迟2秒后重新放回队列重试
              return $this->release(2);
          }
      } catch (\Throwable $e) {
          // 发信出现异常时主动释放锁，避免锁被占用到自然过期导致限流窗口异常
          $lock->release();
          throw $e;
      }
  }
  

• 该方案完全适配你当前的ENV配置：CACHE_DRIVER=file 支持原子锁能力，不需要额外安装扩展、不需要更换队列驱动，共享主机环境可直接运行
• 频率换算：当前配置的30秒1封等价于每小时发送120封邮件，远低于共享主机200封/小时的限制，不会触发发信封禁；如果需要调整频率，只需要修改锁的持有时间即可，比如设置为50秒1封约等于每小时72封，留足冗余量
• 可以根据服务器负载调整任务重试的延迟时间，比如将$this->release(2)改成$this->release(10)，不会影响限流效果，还能减少jobs表的查询压力

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