如何实现队列消费/自定义进程

可能我们会经常遇见需要不断消费队列内内容的场景，我们以EasySwoole中自定义进程的方式，来实现这一功能。

实现代码

定义消费进程逻辑

  1. namespace App;
  2. use EasySwoole\Core\Swoole\Process\AbstractProcess;
  3. use Swoole\Process;
  5. class Consumer extends AbstractProcess
  6. {
  7.     private $isRun = false;
  8.     public function run(Process $process)
  9.     {
  10.         // TODO: Implement run() method.
  11.         /*
  12.          * 举例，消费redis中的队列数据
  13.          * 定时500ms检测有没有任务，有的话就while死循环执行
  14.          */
  15.         $this->addTick(500,function (){
  16.             if(!$this->isRun){
  17.                 $this->isRun = true;
  18.                 $redis = new \redis();//此处为伪代码，请自己建立连接或者维护redis连接
  19.                 while (true){
  20.                     try{
  21.                         $task = $redis->lPop('task_list');
  22.                         if($task){
  23.                             // do you task
  24.                         }else{
  25.                             break;
  26.                         }
  27.                     }catch (\Throwable $throwable){
  28.                         break;
  29.                     }
  30.                 }
  31.                 $this->isRun = false;
  32.             }
  33.             var_dump($this->getProcessName().' task run check');
  34.         });
  35.     }
  37.     public function onShutDown()
  38.     {
  39.         // TODO: Implement onShutDown() method.
  40.     }
  42.     public function onReceive(string $str, ...$args)
  43.     {
  44.         // TODO: Implement onReceive() method.
  45.     }
  46. }

注册消费进程

在EasySwoole的全局事件中，注册消费进程。

  1. use App\Consumer;
  2. use EasySwoole\Core\Swoole\Process\ProcessManager;
  3. use \EasySwoole\Core\Swoole\ServerManager;
  5. public static function mainServerCreate(ServerManager $server,EventRegister $register): void
  6. {
  7.     // TODO: Implement mainServerCreate() method.
  8.     $allNum = 3;
  9.     for ($i = 0 ;$i < $allNum;$i++){
  10.         ProcessManager::getInstance()->addProcess("consumer_{$i}",Consumer::class);
  11.     }
  12. }

爬虫例子：https://github.com/easy-swoole/spider