进程

用途

处理耗时任务，比如循环处理队列消息，清除多余redis中的token数据等等。

例子

定义一个进程类

  1. use EasySwoole\Component\Process\AbstractProcess;
  3. class Process extends AbstractProcess
  4. {
  6.     protected function run($arg)
  7.     {
  8.         //当进程启动后，会执行的回调
  9.         var_dump($this->getProcessName()." run");
  10.         var_dump($arg);
  11.     }
  13.     protected function onPipeReadable(\Swoole\Process $process)
  14.     {
  15.         /*
  16.          * 该回调可选
  17.          * 当有主进程对子进程发送消息的时候，会触发的回调，触发后，务必使用
  18.          * $process->read()来读取消息
  19.          */
  20.     }
  22.     protected function onShutDown()
  23.     {
  24.         /*
  25.          * 该回调可选
  26.          * 当该进程退出的时候，会执行该回调
  27.          */
  28.     }
  30.     protected function onException(\Throwable $throwable, ...$args)
  31.     {
  32.         /*
  33.          * 该回调可选
  34.          * 当该进程出现异常的时候，会执行该回调
  35.          */
  36.     }
  37. }

注册进程

我们在EasySwoole全局的 mainServerCreate 事件中进行进程注册

  1. use App\Process;
  2. use EasySwoole\Component\Process\Config;
  5. $processConfig = new Config();
  6. $processConfig->setProcessName('testProcess');
  7. /*
  8.  * 传递给进程的参数
  9. */
  10. $processConfig->setArg([
  11.     'arg1'=>time()
  12. ]);
  13. ServerManager::getInstance()->getSwooleServer()->addProcess((new Process($processConfig))->getProcess());

::: warning 注意，一个进程模型可以被注册N次，也就是创建N个相同类型的进程 :::

自定义进程热重启

在Swoole 文档中，明确提及自定义进程无法像worker一样reload 。但想实现，终归有办法的，我们只要知道某个进程的pid，给他发送SIGTERM命令， 这个进程自己就会推出。而再利用Swoole Manager会重新拉起进程的这个特性，绕一圈实现进程的热重启。

实例代码

  1. namespace App\HttpController;
  4. use EasySwoole\Http\AbstractInterface\Controller;
  6. class Index extends Controller
  7. {
  9.     function index()
  10.     {
  11.         $pid = $this->request()->getRequestParam('pid');
  12.         \Swoole\Process::kill($pid,SIGTERM);
  13.         $this->writeJson(200,null,'send reboot signal');
  14.     }
  15. }

定义一个控制器，用来发送信号，当然，这个逻辑可有其他方式

  1. namespace App\ProcessReload;
  4. use EasySwoole\Component\Timer;
  5. use EasySwoole\EasySwoole\Logger;
  7. class Work
  8. {
  9.     static function run()
  10.     {
  11.         Timer::getInstance()->loop(3000,function (){
  12.             $pid = getmypid();
  13.             Logger::getInstance()->info("asassdaasd");
  14.         });
  15.     }
  16. }

定义一个任务类，注意，run方法为静态

  1. namespace App\ProcessReload;
  4. use EasySwoole\Component\Process\AbstractProcess;
  5. use EasySwoole\EasySwoole\Logger;
  7. class Process extends AbstractProcess
  8. {
  10.     protected function run($arg)
  11.     {
  12.         $pid = getmypid();
  13.         Logger::getInstance()->info("process for pid {$pid} start");
  14.         Work::run();
  15.     }
  17.     function onShutDown()
  18.     {
  19.         $pid = getmypid();
  20.         Logger::getInstance()->info("process for pid {$pid} shutdown");
  21.         parent::onShutDown();
  22.     }
  23. }

定义一个进程类，进程类的run方法静态调用任务类的静态方法即可。

原理讲解

这里面主要的问题，在于自定义进程类还需要再去调用一个任务类。很多人可能不解。实际上的原理是因为， 我要注册一个进程的时候，我需要new一个自定义进程类，因此，自定义进程的代码就在主进程中被require进去，因此以后续无论如何再怎么修改， manager进程重新克隆出来的进程还是之前的代码。而这里面就巧妙的利用了、当我new这个类的时候，因为php是解释性语言，run方法并未立即被执行。 只有当我真的发生进程克隆的时候，也就是process start后，才会真正的去执行run()这个方法， 而我进程类run方法里面的内容，当执行到Work::run（）的时候，才会真正的去加载worker类的代码，因此我每次杀掉这个自定义进程的时候，进程 重新被主进程克隆出来的时候，都会重新去加载Work类的代码。

Pid管理

很多方式，可以自己用swoole table或者是redis,文件等多种方式实现。