创建进程

fastd 内部进程依赖 swoole，因此在使用该功能前，请确保当前 swoole 环境是否已经成功安装。

创建进程，仅需两步:

  • 创建进程类: 进程所执行的逻辑
  • 注册到配置文件: config/process.php值得注意的是，进程中如果需要保持在后台运行，需要在进程中设置"死循环"，让其一直执行，否则会在逻辑代码执行完成后，进程退出。
  1. <?php
  3. namespace Process;
  5. use FastD\Process\AbstractProcess;
  6. use swoole_process;
  8. class HelloProcess extends AbstractProcess
  9. {
  10.     public function handle(swoole_process $swoole_process)
  11.     {
  12.         timer_tick(1000, function ($id) {
  13.             static $index = 0;
  14.             ++$index;
  15.             echo $index.PHP_EOL;
  16.             if ($index === 3) {
  17.                 timer_clear($id);
  18.             }
  19.         });
  20.     }
  21. }

以上程序每秒输出 $index，直到 $index == 3 时，进程退出，父进程进行回收。

注册到配置文件中(config/process.php):

  1. <?php
  3. return [
  4.     'demo' => [
  5.         'process' => \Process\HelloProcess::class,
  6.         'options' => [
  8.         ],
  9.     ],
  10. ];
  1. $ php bin/console process demo

输出:

  1. process demo pid: 15894
  2. pid: fastd-demo/runtime/process/demo.pid
  3. 1
  4. 2
  5. 3
  6. process: demo. pid: 15894 exit. code: 0. signal: 0

process 命令包含几个命令，可以通过 -h 进行查看:

  1. $ php bin/process -h
  1. Usage:
  2.   process [options] [--] [<process>] [<action>]
  4. Arguments:
  5.   process               process name
  6.   action                process action, status|start|stop [default: "status"]
  8. Options:
  9.   -p, --pid[=PID]       set process pid path.
  10.       --name[=NAME]     set process name.
  11.   -d, --daemon          set process daemonize.
  12.   -h, --help            Display this help message
  13.   -q, --quiet           Do not output any message
  14.   -V, --version         Display this application version
  15.       --ansi            Force ANSI output
  16.       --no-ansi         Disable ANSI output
  17.   -n, --no-interaction  Do not ask any interactive question
  18.   -v|vv|vvv, --verbose  Increase the verbosity of messages: 1 for normal output, 2 for more verbose output and 3 for debug
  20. Help:
  21.   Create new processor.

除了可以单独运行外，还能直接注入到 swoole server 中执行。😎