进程

用户进程

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=true 和 check() 返回 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);