成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

分析Laravel隊(duì)列實(shí)現(xiàn)原理解決問題記錄

Corwien / 2670人閱讀

摘要：在使用中的隊(duì)列時(shí)，產(chǎn)生沖突干擾。文件中的配置部分至此，兩個(gè)項(xiàng)目的隊(duì)列沖突原因就找到了。隊(duì)列監(jiān)聽最后遇到問題，莫要病急亂投醫(yī)。從代碼入手，分析理解實(shí)現(xiàn)原理，找對(duì)點(diǎn)，解決方法也許很簡(jiǎn)單，。

問題

公司項(xiàng)目使用Laravel的開發(fā)的兩個(gè)項(xiàng)目在同一個(gè)測(cè)試服務(wù)器部署，公用同一個(gè)redis。在使用laravel中的隊(duì)列時(shí)，產(chǎn)生沖突干擾。

查找問題原因

在laravel 隊(duì)列的操作類 IlluminateQueueRedisQueue.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)是通過list結(jié)構(gòu)實(shí)現(xiàn)的， rpush(key, value) 是將value推入鍵值為key的redis隊(duì)列，key的值則是通過 $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í)候從 configqueue.php 配置中加載的 "queue" => "default"， $queue 是添加隊(duì)列時(shí)$this->dispatch( new jobClass()->onQueue($queue) )傳入的。

// configqueue.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)聽 監(jiān)聽的隊(duì)列名稱是由 --queue參數(shù)決定的，如果不傳就是我們上面設(shè)置的默認(rèn)值，若傳了就會(huì)根據(jù)傳入的隊(duì)列名從前往后優(yōu)先依次處理，具體見代碼IlluminateQueueWorker.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ù)

// IlluminateQueueRedisQueue.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)聽 php artisan queue:listen redis --queue=laravel1,syncExpress

最后

遇到問題，莫要病急亂投醫(yī)。從代碼入手，分析理解實(shí)現(xiàn)原理，找對(duì)點(diǎn)，解決方法也許很簡(jiǎn)單，^_^。

歡迎關(guān)注我的博客

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/25700.html

相關(guān)文章

  • 個(gè)人整理, 閱讀過的好文章 (每天隨時(shí)更新)

    摘要：大家有好的文章可以在評(píng)論下面分享出來(lái)共同進(jìn)步本文鏈接數(shù)組使用之道程序員進(jìn)階學(xué)習(xí)書籍參考指南教你在不使用框架的情況下也能寫出現(xiàn)代化代碼巧用數(shù)組函數(shù)框架中間件實(shí)現(xiàn)沒錯(cuò)，這就是面向?qū)ο缶幊淘O(shè)計(jì)模式需要遵循的個(gè)基本原則令人困惑的在中使用協(xié)程實(shí)現(xiàn)多任 大家有好的文章,可以在評(píng)論下面分享出來(lái), 共同進(jìn)步! 本文github鏈接 php PHP 數(shù)組使用之道 PHP程序員進(jìn)階學(xué)習(xí)書籍參考指南 教你...

    Chiclaim 評(píng)論0 收藏0

  • Laravel核心解讀 -- 事件系統(tǒng)

    摘要：對(duì)于包含通配符的事件名，會(huì)被統(tǒng)一放入數(shù)組中，是用來(lái)創(chuàng)建事件對(duì)應(yīng)的的如果是監(jiān)聽器是類，去創(chuàng)建監(jiān)聽類創(chuàng)建的時(shí)候，會(huì)判斷監(jiān)聽對(duì)象是監(jiān)聽類還是閉包函數(shù)。對(duì)于閉包監(jiān)聽來(lái)說，會(huì)再包裝一層返回一個(gè)閉包函數(shù)作為事件的監(jiān)聽者。 事件系統(tǒng) Laravel 的事件提供了一個(gè)簡(jiǎn)單的觀察者實(shí)現(xiàn)，能夠訂閱和監(jiān)聽?wèi)?yīng)用中發(fā)生的各種事件。事件機(jī)制是一種很好的應(yīng)用解耦方式，因?yàn)橐粋€(gè)事件可以擁有多個(gè)互不依賴的監(jiān)聽器。lar...

    chengjianhua 評(píng)論0 收藏0

  • 獻(xiàn)給虛擬主機(jī) Laravel 4 用戶: 全功能 MySQL 隊(duì)列驅(qū)動(dòng)器 L4mysqlqueue

    摘要：幾小時(shí)前剛剛發(fā)布的為隊(duì)列功能提供了官方原生的驅(qū)動(dòng)器，完全取代了本軟件包的功能。不過這也并不意味著就是虛擬主機(jī)沒戲，必須云主機(jī)起跳的小網(wǎng)站殺手。性能確實(shí)低下受制于，絕對(duì)禁止用于大數(shù)量高密度任務(wù)的場(chǎng)合。虛擬主機(jī)肯定不會(huì)提供。 幾小時(shí)前剛剛發(fā)布的 Larevel 5.0 為隊(duì)列功能提供了官方原生的database驅(qū)動(dòng)器，完全取代了本軟件包的功能。 對(duì)于Laravel 5及以上版本，本文的內(nèi)...

    missonce 評(píng)論0 收藏0

  • Laravel5.2隊(duì)列驅(qū)動(dòng)expire參數(shù)設(shè)置帶來(lái)的重復(fù)執(zhí)行問題 數(shù)據(jù)庫(kù)驅(qū)動(dòng)

    摘要：已經(jīng)取消了參數(shù)，都用來(lái)執(zhí)行。取數(shù)據(jù)的過程事物處理已經(jīng)打開。取得符合條件的隊(duì)列后程序會(huì)更新該條數(shù)據(jù)，并且更新完后即。 connections => [ .... database => [ driver => database, table => jobs, queue => defaul...

    ysl_unh 評(píng)論0 收藏0

  • 一個(gè) 16年畢業(yè)生所經(jīng)歷的 PHP 面試

    摘要：正確做法是給加索引，還有聯(lián)合索引，并不能避免全表掃描。 前言：有收獲的話請(qǐng)加顆小星星，沒有收獲的話可以 反對(duì) 沒有幫助 舉報(bào)三連 有心的同學(xué)應(yīng)該會(huì)看到我這個(gè)noteBook下面的其它知識(shí)，希望對(duì)你們有些許幫助。 本文地址 時(shí)間點(diǎn)：2017-11 一個(gè)16年畢業(yè)生所經(jīng)歷的php面試 一、什么是面試 二、面試準(zhǔn)備 1. 問：什么時(shí)候開始準(zhǔn)備？ 2. 問：怎么準(zhǔn)備？ 三、面試...

    dabai 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<