Supervisor配置参考

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

##公有配置项

worker

• 类型 callable 或 Comos\Qpm\Process\Runnable
• 传入回调时，是在子进程执行实际任务的回调。传入类时，在子进程中实例化并执行此类的run方法。

quantity

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

timeout

• 类型 float
• 子进程运行的最大时间，单位为秒。
• 默认为 －1.0，表示无超时处理。

termTimeout

• 类型 float
• 子进程超时时发送term信号后的最大等待时间，单位为秒。
• 默认为 －1.0，表示无超时处理。

OneForOne 模式下

调用方法

Comos\Qpm\Supervision\Supervisor::oneForOne($config);

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

##配置字段

maxRestartTimes

• 类型 integer
• 最大重启次数, 和withInSeconds配合使用。

withInSeconds

• 类型 integer
• 和maxRestartTimes，指示master进程在约定的时间内最大的重启次数。

例子1

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

例子2

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

MultiGroupOneForOne 模式下

##方法 qpm\supervisor\Supervisor::oneForOne($config) ##使用场景 MultiGroupOneForOne是OneForOne的升级版，可管理多组OneForOne的进程。 MultiGroupOneForOne的配置是一个内嵌了若干OneForOne配置的数组。

TaskFactoryMode 模式下

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

##调用方法 Comos\Qpm\Supervision\Supervisor::taskFactoryMode($config)

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

##配置字段

factory callable 用于生成任务对象 或 callable的工厂方法。

factory 返回值可以是 Comos\Qpm\Process\Runnable 或 callable