课程咨询 :18300268127 QQ:2720475033

保险

  • php多进程处理

    发布:青岛达内php培训教学部      来源:青岛达内php培训教学部      时间:2016-10-09

  • 青岛达内php培训小编讯 小编习惯使用多进程的方式,php中使用多进程的时候需要使用pcntl,pcntl的使用可以看这个PHP的pcntl多进程。

    但是这里有一个问题,一个主进程把任务分成n个部分,然后把任务分配给多个子进程,但是任务可能是有返回值的,所有的子进程处理完返回值以后需要把返回值返回给主进程。

    这个就涉及到了进程间通信了。进程间通信可以使用的方法当然很多了,比如用redis,用数据库,用文件等。

    php中最简单的要算shmop相关函数了。

    shmop_open

    shmop_read

    shmop_write

    shmop_size

    shmop_delete

    那怎么让一个类很容易有多进程处理的能力呢?青岛达内php培训小编使用php的trait,创建一个PcntlTrait,所有需要有多进程处理功能的类就use 这个trait就行。

    PcntlTrait代码如下:

    trait PcntlTrait

    {

    private $workers = 1;

    public function worker($count)

    {

    $this->workers = $count;

    }

    public function pcntl_call($all, \Closure $callback)

    {

    $perNum = ceil(count($all) / $this->workers);

    $pids = [];

    for($i = 0; $i < $this->workers; $i++){

    $pids[$i] = pcntl_fork();

    switch ($pids[$i]) {

    case -1:

    echo "fork error : {$i} \r\n";

    exit;

    case 0:

    $data = [];

    try {

    $data = $callback(array_slice($all, $i * $perNum, $perNum));

    } catch(\Exception $e) {

    echo ($e->getMessage());

    }

    $shm_key = ftok(__FILE__, 't') . getmypid();

    $data = json_encode($data);

    $shm_id = shmop_open($shm_key, "c", 0777, strlen($data) + 10);

    shmop_write($shm_id, $data, 0);

    shmop_close($shm_id);

    exit;

    default:

    break;

    }

    }

    // only master process will go into here

    $ret = [];

    foreach ($pids as $i => $pid) {

    if($pid) {

    pcntl_waitpid($pid, $status);

    $shm_key = ftok(__FILE__, 't') . $pid;

    $shm_id = shmop_open($shm_key, "w", 0, 0);

    $data = trim(shmop_read($shm_id, 0, shmop_size($shm_id)));

    $data = json_decode($data, true);

    $ret = array_merge($ret, $data);

    @shmop_close($shm_id);

    @shmop_delete($shm_id);

    }

    }

    return $ret;

    }

    }

    它有两个参数,第一个参数为传入数组,第二个参数为数组处理函数。

    它的具体使用通过下面这个测试用例可以看出:

    use App\Console\Commands\PcntlTrait;

    class PcntlImp

    {

    use PcntlTrait;

    }

    class TestPcntlTrait extends \TestCase

    {

    public function setup()

    {

    $this->createApplication();

    }

    public function testPcntlCall()

    {

    $arr = [1,2,3,4,5,6,7,8,9,10];

    $imp = new \PcntlImp();

    $imp->worker(2);

    $data = $imp->pcntl_call($arr, function($info){

    if (empty($info)){

    return [];

    }

    $ret = [];

    foreach ($info as $item) {

    $ret[] = $item * $item;

    }

    return $ret;

    });

    $this->assertEquals(10, count($data));

    $this->assertEquals(25, $data[4]);

    }

    }

上一篇:Web开发者需要关注哪些技术细节

下一篇:关于php权限管理的思考

最新开班日期  |  更多

PHP高级开发工程师优选班

PHP高级开发工程师优选班

开班日期:11月30日

PHP高级开发工程师定制班

PHP高级开发工程师定制班

开班日期:11月30日

PHP高级开发工程师就业班

PHP高级开发工程师就业班

开班日期:11月30日

PHP高级开发工程师周末班

PHP高级开发工程师周末班

开班日期:11月30日

 扫一扫,关注一下! 青岛:市南区金坛路17号 济南:历下区趵突泉北路三联商社
济南:历下区山大路47号数码港大厦 潍坊:奎文区东风东街299号建行大厦
烟台:海港路25号阳光100城市广场 临沂:兰山区红旗路1号苏宁易购
淄博:张店区金晶大道68号华润大厦 济宁:市中区太白路10号苏宁生活广场
课程培训电话:18300268127 全国服务监督电话:400-111-8989    服务邮箱 tousu@tedu.cn

2001-2017 达内时代科技集团有限公司 版权所有 京ICP证8000853号-56

达内教育

有位老师想和您聊一聊