浅谈Laravel队列实现原理解决问题记录_网络技术

浅谈Laravel队列实现原理解决问题记录

发布时间 - 2026-01-11 02:52:25 点击率：次

问题

公司项目使用Laravel的开发的两个项目在同一个测试服务器部署，公用同一个redis。在使用laravel中的队列时，产生冲突干扰。

查找问题原因

在laravel 队列的操作类Illuminate\Queue\RedisQueue.php中可以看到pushRaw()方法：

// 将一任务推入队列中
public function pushRaw($payload, $queue = null, array $options = [])
  {
    $this->getConnection()->rpush($this->getQueue($queue), $payload);

    return Arr::get(json_decode($payload, true), 'id');
  }

从该方法中可以看出Lrarvel队列的redis实现是通过list结构实现的，rpush(key, value)是将value推入键值为key的redis队列，key的值则是通过$this->getQueue($queue) 获取到的

protected function getQueue($queue)
  {
    return 'queues:'.($queue ?: $this->default);
  }

所以的redis中list中的key是 'queues:'.($queue ?: $this->default);拼接的，$this->default 的值是 RedisQueue 实例化的时候从config\queue.php配置中加载的 'queue' => 'default'，$queue 是添加队列时$this->dispatch( new jobClass()->onQueue($queue) )传入的。

// config\queue.php 文件中的redis配置部分
'redis' => [
      'driver'   => 'redis',
      'connection' => 'default',
      'queue'   => 'default',
      'expire'   => 60,
    ],

至此，两个项目的队列冲突原因就找到了。因为redis队列配置中 'queue' => 'default' 都使用的默认的default，所以当共用redis时，默认的队列list 都是'queue:default',所以导致了冲突。

因为队列监听监听的队列名称是由 --queue参数决定的，如果不传就是我们上面设置的默认值，若传了就会根据传入的队列名从前往后优先依次处理，具体见代码Illuminate\Queue\Worker.php中：

protected function getNextJob($connection, $queue)
  {
    if (is_null($queue)) {
      return $connection->pop();
    }

    foreach (explode(',', $queue) as $queue) {
      if (! is_null($job = $connection->pop($queue))) {
        return $job;
      }
    }
  }

$queue就是--queue=传入的参数，当 $queue不存在是直接调用$connection->pop()当参数存在时会将参数解析，优先处理排在前面的队列名称，将队列名称传入pop($queue), pop()会尝试从指定队列或默认队列中获取队列任务

// Illuminate\Queue\RedisQueue.php
public function pop($queue = null)
  {
    $original = $queue ?: $this->default;

    $queue = $this->getQueue($queue);

    if (! is_null($this->expire)) {
      $this->migrateAllExpiredJobs($queue);
    }

    $job = $this->getConnection()->lpop($queue);

    if (! is_null($job)) {
      $this->getConnection()->zadd($queue.':reserved', $this->getTime() + $this->expire, $job);

      return new RedisJob($this->container, $this, $job, $original);
    }
  }

至此搞清了队列执行的原理。

解决方法

将queue的配置文件中默认队列修改为不同的名称，比如： 'queue' => laravel1','queue' => laravel2'。

队列监听 php artisan queue:listen redis --queue=laravel1,syncExpress

最后

遇到问题，莫要病急乱投医。从代码入手，分析理解实现原理，找对点，解决方法也许很简单，希望对大家的学习有所帮助，也希望大家多多支持。

# Laravel队列实现 # Laravel # 队列 # laravel5.6 框架邮件队列database驱动简单demo示例 # Laravel使用Queue队列的技巧汇总 # Docker部署Laravel应用实现队列&任务调度 # Laravel 6 将新增为指定队列任务设置中间件的功能 # Laravel 队列使用的实现 # Laravel框架队列原理与用法分析 # Laravel中为什么不使用blpop取队列详析 # 关于 Laravel Redis 多个进程同时取队列问题详解 # 源码分析 Laravel 重复执行同一个队列任务的原因 # Laravel使用消息队列需要注意的一些问题 # Laravel中利用队列发送邮件的方法示例 # 浅析Laravel5中队列的配置及使用 # PHP的Laravel框架中使用消息队列queue及异步队列的方法 # Laravel 4.2 中队列服务（queue）使用感受 # Laravel框架中队列和工作(Queues、Jobs)操作实例详解 # 解决方法 # 都是 # 病急乱投医 # 就会 # 是由 # 则是 # 很简单 # 不存在 # 可以看到 # 可以看出 # 排在 # 传了 # 配置文件 # 大家多多 # 就找 # 键值 # 清了 # 默认值 # 莫要 # 不传

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：如何使用Linux进行文件系统管理和优化

下一篇：交管12123交通违章缴费操作全攻略违章罚款在线缴纳全攻略

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：如何使用Linux进行文件系统管理和优化

下一篇：交管12123交通违章缴费操作全攻略违章罚款在线缴纳全攻略