本篇文章為大家展示了Laravel隊(duì)列的實(shí)現(xiàn)原理是什么，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

成都創(chuàng)新互聯(lián)致力于互聯(lián)網(wǎng)網(wǎng)站建設(shè)與網(wǎng)站營(yíng)銷，提供成都做網(wǎng)站、網(wǎng)站建設(shè)、網(wǎng)站開(kāi)發(fā)、seo優(yōu)化、網(wǎng)站排名、互聯(lián)網(wǎng)營(yíng)銷、小程序制作、公眾號(hào)商城、等建站開(kāi)發(fā)，成都創(chuàng)新互聯(lián)網(wǎng)站建設(shè)策劃專家，為不同類型的客戶提供良好的互聯(lián)網(wǎng)應(yīng)用定制解決方案，幫助客戶在新的全球化互聯(lián)網(wǎng)環(huán)境中保持優(yōu)勢(shì)。

查找問(wèn)題原因

在laravel 隊(duì)列的操作類Illuminate\Queue\RedisQueue.php中可以看到pushRaw()方法：

// 將一任務(wù)推入隊(duì)列中
public function pushRaw($payload, $queue = null, array $options = [])
  {
    $this->getConnection()->rpush($this->getQueue($queue), $payload);

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

從該方法中可以看出Lrarvel隊(duì)列的redis實(shí)現(xiàn)是通過(guò)list結(jié)構(gòu)實(shí)現(xiàn)的，rpush(key, value)是將value推入鍵值為key的redis隊(duì)列，key的值則是通過(guò)$this->getQueue($queue)獲取到的

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

所以的redis中l(wèi)ist中的key是 'queues:'.($queue ?: $this->default);拼接的，$this->default的值是RedisQueue實(shí)例化的時(shí)候從config\queue.php配置中加載的 'queue' => 'default'，$queue 是添加隊(duì)列時(shí)$this->dispatch( new jobClass()->onQueue($queue) )傳入的。

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

至此，兩個(gè)項(xiàng)目的隊(duì)列沖突原因就找到了。因?yàn)閞edis隊(duì)列配置中'queue' => 'default'都使用的默認(rèn)的default，所以當(dāng)共用redis時(shí)，默認(rèn)的隊(duì)列l(wèi)ist 都是'queue:default',所以導(dǎo)致了沖突。

因?yàn)殛?duì)列監(jiān)聽(tīng) 監(jiān)聽(tīng)的隊(duì)列名稱是由 --queue參數(shù)決定的，如果不傳就是我們上面設(shè)置的默認(rèn)值，若傳了就會(huì)根據(jù)傳入的隊(duì)列名從前往后優(yōu)先依次處理，具體見(jiàn)代碼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=傳入的參數(shù)，當(dāng) $queue不存在是直接調(diào)用$connection->pop()當(dāng)參數(shù)存在時(shí)會(huì)將參數(shù)解析，優(yōu)先處理排在前面的隊(duì)列名稱，將隊(duì)列名稱傳入pop($queue), pop()會(huì)嘗試從指定隊(duì)列或默認(rèn)隊(duì)列中獲取隊(duì)列任務(wù)

// 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);
    }
  }

至此搞清了隊(duì)列執(zhí)行的原理。

解決方法

將queue的配置文件中默認(rèn)隊(duì)列修改為不同的名稱，比如： 'queue' => laravel1','queue' => laravel2'。

隊(duì)列監(jiān)聽(tīng) php artisan queue:listen redis --queue=laravel1,syncExpress

上述內(nèi)容就是Laravel隊(duì)列的實(shí)現(xiàn)原理是什么，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

本文名稱：Laravel隊(duì)列的實(shí)現(xiàn)原理是什么-創(chuàng)新互聯(lián)
網(wǎng)站網(wǎng)址：http://weahome.cn/article/isegh.html