当前位置: 首页 > 工具软件 > QPM > 使用案例 >

QPM-PHP多进程开发-Supervisor配置参考

诸葛雅达
2023-12-01

QPM 是一个PHP 进程管理框架,可用于简化Daemon开发,项目地址在:https://github.com/Comos/qpm

截至0.2版本,QPM支持3种Supervison模式,OneForOne MultiGroupOneForOne 和 TaskFactoryMode。 不同的模式可以建立起不同的进程树组合,子进程的重启,并发控制的策略都各不相同,以适应不同的应用场景。 不同的模式对应着不同的工厂方法,例如OneForOne的创建方法是 qpm\supervisor\Supervisor::oneForOne($config);

OneForOne

方法

qpm\supervisor\Supervisor::oneForOne($config)

使用场景

所有的子进程都使用同一个回调函数或Runnable类。

配置字段

  • *runnableCallback 或 runnableClass. 类型 callable 或 qpm\process\Runnable runnableCallback是在子进程执行实际任务的回调。runnableClass在子进程种执行实际任务的类,和runnableCallback二选一。

  • quantity 类型 integer 默认1 并发数量。

  • maxRestartTimes 类型 integer 最大重启次数, 和withInSeconds配合使用。
  • withInSeconds 类型 integer 和maxRestartTimes,指示master进程在约定的时间内最大的重启次数。

例子1

<?php
//保持3个子进程并发,在子进程中执行justDoIt 函数
$config = ['runnableCallback' => 'justDoIt', 'quantity' => 3];
$sup = qpm\supervisor\Supervisor::oneForOne($config);
$sup->start();

例子2

<?php
//保持5个子进程并发,在子进程中执行 Foo::run()
//10秒内最多允许重启100次,否则主进程将异常退出
$config = ['runnableClass' => 'Foo', 'quantity' => 5, 'maxRestartTimes'=>100, 'withInSeconds'=>10];
$sup = qpm\supervisor\Supervisor::oneForOne($config);
$sup->start();

MultiGroupOneForOne

方法

qpm\supervisor\Supervisor::oneForOne($config)

使用场景

MultiGroupOneForOne是OneForOne的升级版,可管理多组OneForOne的进程。 MultiGroupOneForOne的配置是一个内嵌了若干OneForOne配置的数组。

TaskFactoryMode

任务工厂模式,任务由指定的工厂方法产生。

方法

qpm\supervisor\Supervisor::taskFactoryMode($config)

使用场景

每次子进程执行的任务各不相同,须要不同的参数、类或Run函数,因此每次的任务都由任务工厂生成。

配置字段

*factoryMethod callable 用于生成任务对象 或 callable的工厂方法。 factoryMethod 返回值可以是 qpm\process\Runnable 或 callable

  • quantity 类型 integer 默认1 并发数量。

截至0.2版本,QPM支持3种Supervison模式,OneForOne MultiGroupOneForOne 和 TaskFactoryMode。 不同的模式可以建立起不同的进程树组合,子进程的重启,并发控制的策略都各不相同,以适应不同的应用场景。 不同的模式对应着不同的工厂方法,例如OneForOne的创建方法是 qpm\supervisor\Supervisor::oneForOne($config);

OneForOne

方法

qpm\supervisor\Supervisor::oneForOne($config)

使用场景

所有的子进程都使用同一个回调函数或Runnable类。

配置字段

  • *runnableCallback 或 runnableClass. 类型 callable 或 qpm\process\Runnable runnableCallback是在子进程执行实际任务的回调。runnableClass在子进程种执行实际任务的类,和runnableCallback二选一。

  • quantity 类型 integer 默认1 并发数量。

  • maxRestartTimes 类型 integer 最大重启次数, 和withInSeconds配合使用。
  • withInSeconds 类型 integer 和maxRestartTimes,指示master进程在约定的时间内最大的重启次数。

例子1

<?php
//保持3个子进程并发,在子进程中执行justDoIt 函数
$config = ['runnableCallback' => 'justDoIt', 'quantity' => 3];
$sup = qpm\supervisor\Supervisor::oneForOne($config);
$sup->start();

例子2

<?php
//保持5个子进程并发,在子进程中执行 Foo::run()
//10秒内最多允许重启100次,否则主进程将异常退出
$config = ['runnableClass' => 'Foo', 'quantity' => 5, 'maxRestartTimes'=>100, 'withInSeconds'=>10];
$sup = qpm\supervisor\Supervisor::oneForOne($config);
$sup->start();

MultiGroupOneForOne

方法

qpm\supervisor\Supervisor::oneForOne($config)

使用场景

MultiGroupOneForOne是OneForOne的升级版,可管理多组OneForOne的进程。 MultiGroupOneForOne的配置是一个内嵌了若干OneForOne配置的数组。

TaskFactoryMode

任务工厂模式,任务由指定的工厂方法产生。

方法

qpm\supervisor\Supervisor::taskFactoryMode($config)

使用场景

每次子进程执行的任务各不相同,须要不同的参数、类或Run函数,因此每次的任务都由任务工厂生成。

配置字段

*factoryMethod callable 用于生成任务对象 或 callable的工厂方法。 factoryMethod 返回值可以是 qpm\process\Runnable 或 callable

  • quantity 类型 integer 默认1 并发数量。
 类似资料: