本页文章导读:

    ▪php 多进程实现守护进程的实例代码      php 多进程（守护进程）的代码，如下：   代码示例: <?php /** * 入口函数 * 将此文件保存为 ProcessOpera.php * 在terminal中运行 /usr/local/php/bin/php ProcessOpera.php & * 查看进程 ps aux|grep php * mo.........

    ▪php 多进程编程的实例代码      php 多进程的例子。   代码示例: <?php /**  * Project: Signfork: php多线程库  * File: Signfork.class.php  * modify by www.  */ class Signfork{     /**      * 设置子进程通信文件所在目录      * @va.........

    ▪php 多进程解决代码常驻内存的问题      PHP不适合做常驻的SHELl进程，因为它没有专门的gc例程，也没有有效的内存管理途径。 如果用PHP做常驻SHELL，会经常被内存耗尽导致abort而unhappy。 而且，如果输入数据非法，而脚本没有检测.........

代码示例:

<?php
/**
* 入口函数
* 将此文件保存为 ProcessOpera.php
* 在terminal中运行 /usr/local/php/bin/php ProcessOpera.php &
* 查看进程 ps aux|grep php
* modify by www.
*/
ProcessOpera("runCode", array(), 8);

/**
* run Code
*/
function runCode($opt = array()) {
//在守护进程中运行的代码
}

/**
* $func为子进程执行具体事物的函数名称
* $opt为$func的参数 数组形式
* $pNum 为fork的子进程数量
*/
function ProcessOpera($func, $opts = array(), $pNum = 1) {
while(true) {
$pid = pcntl_fork();
if($pid == -1) {
exit("pid fork error");
}
if($pid) {
static $execute = 0;
$execute++;
if($execute >= $pNum) {
pcntl_wait($status);
$execute--;
}
} else {
while(true) {
//somecode
$func($opts);
sleep(1);
}
exit(0);
}
}
}
?>

代码示例:

<?php
/**
 * Project: Signfork: php多线程库
 * File: Signfork.class.php
 * modify by www.
 */
class Signfork{
    /**
     * 设置子进程通信文件所在目录
     * @var string
     */
    private $tmp_path='/tmp/';

    /**
     * Signfork引擎主启动方法
     * 1、判断$arg类型,类型为数组时将值传递给每个子进程;类型为数值型时,代表要创建的进程数.
     * @param object $obj 执行对象
     * @param string|array $arg 用于对象中的__fork方法所执行的参数
     * 如:$arg,自动分解为:$obj->__fork($arg[0])、$obj->__fork($arg[1])…
     * @return array 返回 array(子进程序列=>子进程执行结果);
     */
    public function run($obj,$arg=1){
        if(!method_exists($obj,'__fork')){
            exit('Method "__fork" not found!');
        }

        if(is_array($arg)){
            $i=0;
            foreach($arg as $key=>$val){
                $spawns[$i]=$key;
                $i++;
                $this->spawn($obj,$key,$val);
            }
            $spawns['total']=$i;
        }elseif($spawns=intval($arg)){
            for($i = 0; $i < $spawns; $i++){
                $this->spawn($obj,$i);
            }
        }else{
            exit('Bad argument!');
        }

        if($i>1000) exit('Too many spawns!');
        return $this->request($spawns);
    }

    /**
     * Signfork主进程控制方法
     * 1、$tmpfile 判断子进程文件是否存在，存在则子进程执行完毕，并读取内容
     * 2、$data收集子进程运行结果及数据，并用于最终返回
     * 3、删除子进程文件
     * 4、轮询一次0.03秒，直到所有子进程执行完毕，清理子进程资源
     * @param string|array $arg 用于对应每个子进程的ID
     * @return array 返回 array([子进程序列]=>[子进程执行结果]);
     */
    private function request($spawns){
        $data=array();
        $i=is_array($spawns)?$spawns['total']:$spawns;
        for($ids = 0; $ids<$i; $ids++){
            while(!($cid=pcntl_waitpid(-1, $status, WNOHANG)))usleep(30000);
            $tmpfile=$this->tmp_path.'sfpid_'.$cid;
            $data[$spawns['total']?$spawns[$ids]:$ids]=file_get_contents($tmpfile);
            unlink($tmpfile);
        }
        return $data;
    }

    /**
     * Signfork子进程执行方法
     * 1、pcntl_fork 生成子进程
     * 2、file_put_contents 将'$obj->__fork($val)'的执行结果存入特定序列命名的文本
     * 3、posix_kill杀死当前进程
     * @param object $obj 待执行的对象
     * @param object $i 子进程的序列ID，以便于返回对应每个子进程数据
     * @param object $param 用于输入对象$obj方法'__fork'执行参数
     */
    private function spawn($obj,$i,$param=null){
        if(pcntl_fork()===0){
            $cid=getmypid();
            file_put_contents($this->tmp_path.'sfpid_'.$cid,$obj->__fork($param));
            posix_kill($cid, SIGTERM);
            exit;
        }
    }
}
?>

代码示例:

<?php
require_once(dirname(__FILE__) . '/Signfork.class.php');
class ExecObj{
    public function __fork($param){
        return getmypid();
    }
   
}
echo getmypid()."\n";
$signfork = new Signfork();
$result = $signfork->run(new ExecObj(),5);
foreach ($result as $key=>$val)
{
    echo $key." ".$val."\n";
}
?>

代码示例:

#!/bin/env php
<?php
/** A example denoted muti-process application in php
* @filename fork.php
* @edit www.
* @version 1.0.0
*/
/** 确保这个函数只能运行在SHELL中 */
if
(substr(php_sapi_name(), 0, 3) !== 'cli')
{
die("This Programe can only be run in CLI mode");
}
/** 关闭最大执行事件限制, 在CLI模式下, 这个语句其实不必要 */
set_time_limit(0);
$pid = posix_getpid(); //取得主进程ID
$user = posix_getlogin(); //取得用户名
echo
<<<EOD
USAGE: [command | expression]
input php code to execute by fork a new process
input quit to exit
Shell Executor version 1.0.0 by laruence
EOD;
while
(true)
{
$prompt = "\n{$user}$ ";
$input = readline($prompt);
readline_add_history($input);
if
($input == 'quit')
{
break;
}
process_execute($input . ';');
}
exit(0);
function
process_execute($input)
{
$pid = pcntl_fork(); //创建子进程
if
($pid == 0)
{//子进程
$pid = posix_getpid();
echo
"* Process {$pid} was created, and Executed:\n\n";
eval($input); //解析命令
exit;
}
else
{//主进程
$pid = pcntl_wait($status, WUNTRACED); //取得子进程结束状态
if
(pcntl_wifexited($status))
{
echo
"\n\n* Sub process: {$return['pid']} exited with {$status}";
}
}
}
?>