五月天激情丁香,国产精品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精品久久 | 激情播播网 | 久久精品视频热 | 国产成人精品日本亚洲网址 | 婷婷色九月综合激情丁香 | 国产二区三区毛片 | 好色婷婷 | 久久国产精品亚洲综合 | 久久男人网 | 久热久操 | 四虎国产一区 | 免费国产综合视频在线看 | 国产欧美视频一区二区三区 | 国产精品无码久久av | 欧美尻逼视频 | 男人的天堂黄色 | 色综合久久综合欧美综合 | 青青草国产青春综合久久 | 色婷婷久久免费网站 | 国产亚洲精品视频中文字幕 | 久久99精品久久久久久久不卡 | 99精品久久久久久久 | 九七97影院理论片手机在线观看 | 精品午夜一区二区三区在线观看 | 黄污视频免费观看 |