进程

用户进程

Swoft 框架里面的进程分为Server 前置进程和自定义进程两种。

前置进程

Server 前置进程,Http Server 启动之前创建的守护进程(swoole_server->addProcess)

  • 通常放置于 app/Boot 目录
  • @Process 注解上要写明 boot=true 才会随着server启动,否则不会创建

自定义进程

用户在业务逻辑中创建自定义的进程, 通常放置于 app/Process 目录

  • 不会随server启动
  • 需要用户自己手动启动它(比如监听server启动事件时,或者在cli 环境下运行命令时)
ProcessBuilder::create('customProcess')->start();

更多关于进程的定义和使用,请看接下来的章节

进程配置

进程配置主要是配置定义的进程文件扫描目录,分为两种不同的情况。

Server 前置进程

配置Server 前置进程扫描目录,app/config/properties/app.php

return [
    // ....
    'bootScan'     => [
        // ....
        'App\Boot',
        // ....
    ],
    // ....
];

定义进程

定义进程主要是通过 @Process 注解完成定义。

注解

@Process

拥有属性:

  • name 进程唯一标识,默认类名
  • boot 是否为Server前置进程,默认false
  • inout 参数,参考 swoole $redirect_stdin_stdout,默认 false
  • pipe 参数,参考 swoole $create_pipe,默认 true
  • coroutine 是否启动一个协程来运行进程逻辑即开启协程模式,默认false
  • num 启动进程的个数,默认是 1

创建进程类

无论是Server前置进程或用户自定义进程,定义方式都是一样,实现 ProcessInterface 接口,需要实现run和check方法

  • run 方法里面实现进程的主要业务逻辑
  • check 方法用于验证进程启动的前置条件,返回true启动进程,返回false不启动进程。

Server 前置进程

  • 随着server启动,将会附加到 server, 并被其管理
  • 保证 boot=truecheck() 返回 true 才会启动
 /**
  * Boot process
  *
  * @Process(boot=true)
  */
 class MyProcess implements ProcessInterface
 {
     public function run(SwoftProcess $process)
     {
         $pname = App::$server->getPname();
         $processName = "$pname myProcess process";
         $process->name($processName);
 
         echo "Custom boot process \n";
 
         $result  = Task::deliverByProcess('sync', 'deliverCo', ['p', 'p2']);
         var_dump($result);
 
         // 在此自启动进程中,
         // 我们手动的创建了另一个自定义进程
         // 实际使用中是无需这样做的,在这个方法里我们已经可以写需要的逻辑了
         ProcessBuilder::create('customProcess')->start();
     }
 
     public function check(): bool
     {
         return true;
     }
 }

用户自定义进程

  • 不会随着server启动
  • 可以使用 ProcessBuilder::create('customProcess')->start() 来创建它
  • 如何启动使用
    • 如上面的,在一个自启动进程里来启动它。 :) 当然,这其实是没必要的
    • 监听server的相关事件,在里面启动它
    • 命令行里,执行某个命令时。启动使用它
    • … 在你需要的时候
  /**
   * Custom process
   *
   * @Process(name="customProcess", coroutine=true)
   */
  class MyProcess implements ProcessInterface
  {
      public function run(SwoftProcess $process)
      {
          $pname = App::$server->getPname();
          $processName = "$pname myProcess process";
          $process->name($processName);
  
          echo "Custom child process \n";
          var_dump(Coroutine::id());
      }
  
      public function check(): bool
      {
          return true;
      }
  }

运行进程

运行进程很简单,是通过进程唯一标识名称运行。

ProcessBuilder::create('customProcess')->start();

前置进程会被swoft主动调用并运行

投递任务

若进程里面需要投递任务功能,需要依赖 swoft/task 组件。 组件安装成功后,直接调用方法投递,具体如何投递任务Task里面有详细介绍。

$result  = Task::deliverByProcess('sync', 'deliverCo', ['p', 'p2']);
var_dump($result);
上一页
下一页