如何實現隊列消費/自定義進程
可能我們會經常遇見需要不斷消費隊列內內容的場景,我們以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));
}
}