五月天激情丁香,国产精品2019,国产成人精品亚洲2020,国产精品免费视频一区二区三区,开心久久婷婷综合中文字幕,天堂视频在线观看免费完整版

如何實現隊列消費/自定義進程

可能我們會經常遇見需要不斷消費隊列內內容的場景,我們以EasySwoole中自定義進程的方式,來實現這一功能。

實現代碼

定義消費進程邏輯

<?php
/**
 * Created by PhpStorm.
 * User: Tioncico
 * Date: 2018/10/18 0018
 * Time: 9:43
 */

namespace App\Process;

use EasySwoole\Component\Process\AbstractProcess;
use Swoole\Process;

class Consumer extends AbstractProcess
{
    private $isRun = false;
    public function run($arg)
    {
        // TODO: Implement run() method.
        /*
         * 舉例,消費redis中的隊列數據
         * 定時500ms檢測有沒有任務,有的話就while死循環執行
         */
        $this->addTick(500,function (){
            if(!$this->isRun){
                $this->isRun = true;
                $redis = new \redis();//此處為偽代碼,請自己建立連接或者維護redis連接
                while (true){
                    try{
                        $task = $redis->lPop('task_list');
                        if($task){
                            // do you task
                        }else{
                            break;
                        }
                    }catch (\Throwable $throwable){
                        break;
                    }
                }
                $this->isRun = false;
            }
            var_dump($this->getProcessName().' task run check');
        });
    }

    public function onShutDown()
    {
        // TODO: Implement onShutDown() method.
    }

    public function onReceive(string $str, ...$args)
    {
        // TODO: Implement onReceive() method.
    }
}

注冊消費進程

在EasySwoole的全局事件中,注冊消費進程。

<?php
use App\Process\TestProcess;
use EasySwoole\Component\Process\Manager;
use EasySwoole\EasySwoole\Swoole\EventRegister;

public static function mainServerCreate(EventRegister $register)
{

    $allNum = 3;
    for ($i = 0 ;$i < $allNum;$i++){
        $processConfig= new \EasySwoole\Component\Process\Config();
        $processConfig->setProcessName('testProcess'.$i);//設置進程名稱
        Manager::getInstance()->addProcess(new TestProcess($processConfig));
    }
}
主站蜘蛛池模板: 九月丁香激情综合婷婷玉立 | 国产精品久久久久久久久免费 | 国产福利不卡一区二区三区 | 色婷婷久久综合中文网站 | 国产一区二区三区在线观看精品 | 欧美中文字幕 | 久久久久久久国产免费看 | 婷婷六月色 | 高清成人综合 | 久久国产免费观看精品 | 天堂视频在线观看免费完整版 | 日本免费中文字幕 | 99久久免费观看 | 国产视频自拍一区 | 福利国产精品 | 国产成人久久精品二区三区 | 美女在线免费视频 | 四虎影在永久地址在线观看 | 亚洲一区二区精品视频 | 色男人的天堂久久综合 | 99精品影院 | 日本久久久久中文字幕 | 国产一级在线现免费观看 | 久久香蕉网站 | 国产欧美日韩综合精品一区二区三区 | 国产真实自拍 | 日本亚洲最大的色成网站www | 久视频免费精品6 | 99国产情在线视频 | 成人在线黄色 | 欧妇女乱妇女乱视频 | 日本四虎影院 | 四虎家庭影院 | 国产一区二区三区毛片 | 免费人成年激情视频在线观看 | 久久精品亚洲牛牛影视 | 欧美亚洲激情视频 | 青草国产精品久久久久久 | 精品久久免费视频 | 青青草国产97免久久费观看 | 一级一级一级毛片免费毛片 |