pagon/childprocess

PHP child process manager

0.0.5 2013-09-08 11:45 UTC

Requires

• php: >=5.3.0
• ext-pcntl: *
• ext-posix: *
• pagon/eventemitter: *

Requires (Dev)

• ext-sysvmsg: *

MIT

• Corrie Zhao

• process
• pcntl
• childprocess

README

其它语言：English

PHP-ChildProcess

一个CLI下易用简单的管理进程的库

安装

添加 "pagon/childprocess": "*" 到 composer.json:

composer.phar install

目录

• 使用管理器
• 创建子进程
  • 自动运行
  • 手动运行
  • 手动运行等待
  • 运行PHP文件
  • 运行命令
• 其它
  • 发送消息
  • 高级用法
• 事件
  • ChildProcess
  • Process

使用

使用管理器

控制当前进程

declare(ticks = 1) ;

$manager = new ChildProcess();

$manager->on('exit', function () use ($process) {
    error_log('exit');
    exit;
});

// 做其他事情或等待

创建子进程

简单运行

在子平行空间运行闭包函数

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->parallel(function () {
    sleep(10);
    // 做其他事情
});

为了保证主进程不退出来handle事件，可以使用join或者while(1)来保证运行

手动运行

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->parallel(function () {
    // to do something
    sleep(10);
    error_log('child execute');
}, false);

$child->on('exit', function ($status) {
    error_log('child exit ' . $status);
});

// 只运行子进程不等待退出
$child->run()

while(1) { /*to do something */}

手动运行等待

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->parallel(function () {
    // to do something
    sleep(10);
    error_log('child execute');
}, false);

$child->on('exit', function ($status) {
    error_log('child exit ' . $status);
});

// 等待子进程退出
$child->join();

运行PHP文件

在子平行空间运行PHP文件

主进程：

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->fork(__DIR__ . '/worker.php', false);

$child->on('exit', function ($status) {
    error_log('child exit ' . $status);
});

$child->join();

PHP文件：

$process // The parent process
// 需要做的工作

运行命令

在子进程运行命令，并且捕获输出

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->spawn('/usr/sbin/netstat', false);

$child->on('stdout', function ($data) {
    error_log('receive stdout data: '  . $data);
    // to save data or process it
});

$child->on('stderr', function ($data) {
    error_log('receive stderr data: '  . $data);
    // to save data or process something
});

$child->join();

其它

发送消息

父子进程可以使用消息来通信

declare(ticks = 1) ;

$manager = new ChildProcess();

$manager->listen();

$child = $manager->parallel(function (Process $process) {
    $process->on('message', function ($msg) {
        error_log('child revive message: ' . $msg);
    });

    $process->listen();

    $process->send('hello master');

    error_log('child execute');
}, false);

$child->on('message', function ($msg) {
    error_log('parent receive message: ' . $msg);
});

$child->send('hi child');

$child->join();

高级用法

设置选项

当前支持的选项列表：

array(
    'cwd'      => false,        // Current working deirectory
    'user'     => false,        // Startup user
    'env'      => array(),      // Enviroments
    'timeout'  => 0,            // Timeout
    'init'     => false,        // Init callback
    'callback' => false         // Child startup callback
)

一些用法：

declare(ticks = 1) ;

$manager = new ChildProcess();

$child = $manager->spawn('/usr/sbin/netstat', array(
    'timeout' => 60 // Will wait 60 seconds
    'callback' => function(){ error_log('netstat start'); }
), false);

$child->on('stdout', function ($data) {
    echo $data;
    // to save data or process it
});

$child->join();

事件

ChildProcess事件

• tick 每个tick都会触发，主要用于监控一些行为来及时反馈到管理器
• listen 监听消息队列
• signal 收到任何的信号
• abort 中断时：SIGINT,SIGTERM
• finish 运行结束时（正常退出）
• exit 管理器进程退出，包含abort和finish

Process事件

• listen 当前进程实例开始监听队列时触发
• run 当前进程实例手动运行时
• init 当前进程实例子进程创建完成时
• fork 当前进程实例fork时
• abort 当前进程实例中断时：SIGINT,SIGTERM
• finish 当前进程实例结束时（正常退出）
• exit 当前进程实例退出时，包含abort和finish

授权

MIT