README

$ composer require seankndy/daemon

使用概述

在主循环的每次迭代中，都会调用生产者，它们应提供要分叉/运行的任务。

生产者可以是可调用函数或实现了 SeanKndy\Daemon\Tasks\Producer 的对象。如果没有要执行的任务，则生产者应返回 null，否则返回 SeanKndy\Daemon\Tasks\Task 或 callable。 SeanKndy\Daemon\Tasks\Task 有 3 个方法

init() - 在父进程分叉子进程之前调用。

run() - 在分叉进程（子进程工作）内部调用

finish(int $status) - 在父进程收到进程退出时调用

因此，如果您需要在子进程生成/退出时执行任何初始化或清理操作，则应创建自己的任务类实现 SeanKndy\Daemon\Tasks\Task，而不是使用简单的闭包。

您可以监听各种事件（使用 SeanKndy\Daemon\Daemon::addListener()）

SeanKndy\Daemon\DaemonEvent::START - 当守护进程启动时

SeanKndy\Daemon\DaemonEvent::STOP - 当守护进程停止时

SeanKndy\Daemon\DaemonEvent::DAEMONIZED - 当守护进程化（后台运行）时

SeanKndy\Daemon\DaemonEvent::LOOP_ITERATION - 在每次循环迭代结束时调用

SeanKndy\Daemon\Processes\Event::START - 新进程启动

SeanKndy\Daemon\Processes\Event::EXIT - 新进程退出

SeanKndy\Daemon\Processes\Event::ITERATION - 在每次主循环迭代中，为每个运行的进程触发一次

<?php
use SeanKndy\Daemon\Daemon;
use SeanKndy\Daemon\Processes\Event as ProcessEvent;

$maxProcesses = 50;
$quietTime = 1000000;
$childTimeout = 30;

$daemon = new Daemon($maxProcesses, $quietTime, $childTimeout);

// $producer can be a callable or an object that implements SeanKndy\Daemon\Tasks\Producer
// it should produce work to do (which is also a callable or an object implementing SeanKndy\Daemon\Tasks\Task)
//
// if multiple producers are added, they will be round-robined
$number = 0;
$producer = function() use (&$number) {
    if ($number >= 10) return null;
    $number++;

    // this is the "task" or the code to run within the forked child
    return function() use ($number) {
        echo "hello from child $number, my pid is " . getmypid() . "\n";
        return 0; // child exit value
    };
};
$daemon->addProducer($producer);

// optional, signal catching
$daemon->addSignal(SIGTERM, function ($signo) {
    // SIGTERM caught, handle it here
});

// optional, example event listeners
$daemon->addListener(ProcessEvent::START, function ($event) {
    // process $event->getProcess() started
});
$daemon->addListener(ProcessEvent::EXIT, function ($event) {
    // process $event->getProcess() exited
});

$daemon->setDaemonize(false); // don't fork to background
$daemon->start();

进程间通信示例

您可以使用 \SeanKndy\Daemon\IPC\Socket 通过套接字对从子进程向父进程发送消息。以下是一个示例：

<?php
use SeanKndy\Daemon\Tasks\Task;

class MyTask implements Task
{
    private $ipc;

    /**
     * Initialize task (main thread)
     *
     * @return void
     */
    public function init() : void
    {
        $this->ipc = new \SeanKndy\Daemon\IPC\Socket();
    }

    /**
     * Do the work (child thread)
     *
     * @return int
     */
     public function run() : int
     {
         // do something useful in child and generate $interestingData

         $this->ipc->send($interestingData);
         $this->ipc->close();
     }

     /**
      * Cleanup (main thread)
      *
      * @var int $status Exit status of child thread
      * @return void
      */
     public function finish(int $status) : void
     {
         if ($this->ipc->hasMessage()) {
             $interestingData = $this->ipc->receive();
             // $interestingData now in parent process
         }
         $this->ipc->close();
     }
}