Laravel集成RabbitMQ队列时SQL驱动缺失及失败任务处理求助

一、修复SQL驱动缺失错误 #

这个报错和RabbitMQ队列本身无关，是你的任务逻辑里执行了数据库查询（select * from text where is_parsed = 0 limit 1），但Laravel的数据库连接出了问题，按下面步骤排查：

• 检查.env数据库配置：确认DB_CONNECTION、DB_HOST、DB_PORT、DB_DATABASE、DB_USERNAME、DB_PASSWORD这些参数是否匹配你的数据库环境，比如用MySQL的话DB_CONNECTION要设为mysql，同时确保数据库服务已经启动。执行php artisan config:clear清缓存，让配置生效。
• 检查模型连接配置：如果任务里用到的Text模型指定了自定义数据库连接，看模型里的$connection属性是不是指向了config/database.php里正确的连接配置。比如：

  class Text extends Model
  {
      protected $connection = 'mysql'; // 确保这个连接存在且配置正确
  }
  

• 测试数据库连接：跑php artisan tinker，然后输入DB::connection()->getPdo()，如果报错，根据错误信息修复（比如数据库不存在、账号权限不够等）。

二、配置失败任务处理 #

Laravel默认把失败任务存在failed_jobs表，哪怕用RabbitMQ当队列驱动，默认还是依赖数据库。有两种处理方案：

方案1：用数据库存储失败任务 #

• 先把上面的数据库连接问题搞定，然后执行php artisan queue:failed-table生成failed_jobs的迁移文件，再跑php artisan migrate创建表。
• 启动Worker时可以指定重试次数，比如php artisan queue:work rabbitmq --tries=3，超过次数的任务会自动存入failed_jobs，之后用php artisan queue:failed查看，php artisan queue:retry 任务ID重试。

方案2：用RabbitMQ存储失败任务（扩展包支持） #

vladimir-yuldashev/laravel-queue-rabbitmq支持把失败任务扔到RabbitMQ的失败队列，配置步骤：

1. 在config/queue.php的connections.rabbitmq里加失败队列配置：

   'rabbitmq' => [
       'driver' => 'rabbitmq',
       // 保留你原来的其他配置
       'failed' => [
           'driver' => 'rabbitmq',
           'queue' => 'failed',
           'exchange' => 'failed',
           'exchange_type' => 'direct',
       ],
   ],
   

2. 在.env里加QUEUE_FAILED_CONNECTION=rabbitmq，指定失败任务用RabbitMQ驱动。
3. 失败的任务会被发到指定的RabbitMQ失败队列，之后可以用php artisan queue:work rabbitmq --queue=failed来处理这些任务。

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