快捷導(dǎo)航

PHP swoole的process模塊創(chuàng)建和使用子進(jìn)程操作示例

更新時(shí)間：2020年03月11日 12:48:01 作者：懷素真

這篇文章主要介紹了PHP swoole的process模塊創(chuàng)建和使用子進(jìn)程操作,結(jié)合實(shí)例形式分析了swoole的進(jìn)程管理process模塊實(shí)現(xiàn)進(jìn)程間通信相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了PHP swoole的process模塊創(chuàng)建和使用子進(jìn)程操作。分享給大家供大家參考，具體如下：

swoole中為我們提供了一個(gè)進(jìn)程管理模塊 Process，替換PHP的 pcntl 擴(kuò)展，方便我們創(chuàng)建進(jìn)程，管理進(jìn)程，和進(jìn)程間的通信。

swoole提供了2種進(jìn)程間的通信：

1、基于 unix socket 的管道 pipe。

2、基于 sysvmsg 的消息隊(duì)列。

我們可以通過(guò) new swoole_process() 快速的創(chuàng)建一個(gè)進(jìn)程，默認(rèn)會(huì)創(chuàng)建一個(gè) SOCK_DGRAM 類(lèi)型的管道，用于進(jìn)程間的通信，當(dāng)然可以設(shè)置成其他類(lèi)型，也可以不創(chuàng)建。

一、通過(guò)同步阻塞管道進(jìn)行進(jìn)程間通信

<?php
$worker_process_nums = 5;
$worker_process = [];
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  //創(chuàng)建子進(jìn)程
  //默認(rèn)為每個(gè)子進(jìn)程創(chuàng)建一個(gè)管道，如果不想創(chuàng)建設(shè)置$pipe_type參數(shù)為false
  //注意管道默認(rèn)是同步阻塞，半雙工，如果讀取不到數(shù)據(jù)就會(huì)阻塞
  $worker = new swoole_process(function (swoole_process $worker) {
    //注意，如果主進(jìn)程中不寫(xiě)數(shù)據(jù)write()，那么子進(jìn)程這里read()就會(huì)阻塞
    $task = json_decode($worker->read(), true);
 
    //進(jìn)行計(jì)算任務(wù)
    $tmp = 0;
    for ($i = $task['start']; $i < $task['end']; $i++) {
      $tmp += $i;
    }
 
    echo '子進(jìn)程 PID : ', $worker->pid, ' 計(jì)算 ', $task['start'], ' - ', $task['end'], ' 結(jié)果 : ', $tmp, PHP_EOL;
    //往管道中寫(xiě)入計(jì)算的結(jié)果
    $worker->write($tmp);
    //子進(jìn)程退出
    $worker->exit();
  });
 
  //保存子進(jìn)程
  $worker_process[$i] = $worker;
 
  //啟動(dòng)子進(jìn)程
  $worker->start();
}
 
//往每個(gè)子進(jìn)程管道中投遞任務(wù)
for ($i = 0; $i < $worker_process_nums; $i++) {
  $worker_process[$i]->write(json_encode([
    'start' => mt_rand(1, 10),
    'end' => mt_rand(50, 100),
  ]));
}
 
//父進(jìn)程監(jiān)聽(tīng)子進(jìn)程退出信號(hào)，回收子進(jìn)程，防止出現(xiàn)僵尸進(jìn)程
swoole_process::signal(SIGCHLD, function ($sig) {
  //必須為false，非阻塞模式
  while ($ret = swoole_process::wait(false)) {
    echo "子進(jìn)程 PID : {$ret['pid']} 退出\n";
  }
});

二、通過(guò) swoole_event_add 將管道設(shè)為異步，來(lái)進(jìn)行通信

<?php
$worker_process_nums = 5;
$worker_process = [];
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  $worker = new swoole_process(function ($worker) {
    //在子進(jìn)程中給管道添加事件監(jiān)聽(tīng)
    //底層會(huì)自動(dòng)將該管道設(shè)置為非阻塞模式
    //參數(shù)二，是可讀事件回調(diào)函數(shù)，表示管道可以讀了
    swoole_event_add($worker->pipe, function ($pipe) use ($worker) {
      $task = json_decode($worker->read(), true);
 
      $tmp = 0;
      for ($i = $task['start']; $i < $task['end']; $i++) {
        $tmp += $i;
      }
      echo "子進(jìn)程 : {$worker->pid} 計(jì)算 {$task['start']} - {$task['end']} \n";
      //子進(jìn)程把計(jì)算的結(jié)果，寫(xiě)入管道
      $worker->write($tmp);
      //注意，swoole_event_add與swoole_event_del要成對(duì)使用
      swoole_event_del($worker->pipe);
      //退出子進(jìn)程
      $worker->exit();
    });
  });
 
  $worker_process[$i] = $worker;
 
  //啟動(dòng)子進(jìn)程
  $worker->start();
}
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  $worker = $worker_process[$i];
 
  $worker->write(json_encode([
    'start' => mt_rand(1, 10),
    'end' => mt_rand(50, 100),
  ]));
 
  //主進(jìn)程中，監(jiān)聽(tīng)子進(jìn)程管道事件
  swoole_event_add($worker->pipe, function ($pipe) use ($worker) {
    $result = $worker->read();
    echo "子進(jìn)程 : {$worker->pid} 計(jì)算結(jié)果 {$result} \n";
    swoole_event_del($worker->pipe);
  });
}
 
//父進(jìn)程監(jiān)聽(tīng)子進(jìn)程退出信號(hào)，回收子進(jìn)程，防止出現(xiàn)僵尸進(jìn)程
swoole_process::signal(SIGCHLD, function ($sig) {
  //必須為false，非阻塞模式
  while ($ret = swoole_process::wait(false)) {
    echo "子進(jìn)程 PID : {$ret['pid']} 退出\n";
  }
});

三、使用消息隊(duì)列來(lái)完成進(jìn)程間通信

<?php
$worker_process_nums = 5;
$worker_process = [];
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  //注意，這里將參數(shù)$pipe_type設(shè)為false，表示不創(chuàng)建管道
  $worker = new swoole_process(function ($worker) {
    $task = json_decode($worker->pop(), true);
 
    $tmp = 0;
    for ($i = $task['start']; $i < $task['end']; $i++) {
      $tmp += $i;
    }
    echo "子進(jìn)程 : {$worker->pid} 計(jì)算 {$task['start']} - {$task['end']} \n";
    $worker->push($tmp);
    $worker->exit();
  }, false, false);
 
  //使用消息隊(duì)列，作為進(jìn)程間的通信
  //注意，消息隊(duì)列是共享的
  $worker->useQueue();
 
  $worker_process[$i] = $worker;
 
  //啟動(dòng)子進(jìn)程
  $worker->start();
}
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  //只需用一個(gè)子進(jìn)程發(fā)送消息即可，因?yàn)橄㈥?duì)列是共享的
  $worker_process[0]->push(json_encode([
    'start' => mt_rand(1, 10),
    'end' => mt_rand(50, 100),
  ]));
}
 
//注意，這里要暫停，防止加入隊(duì)列的任務(wù)，立刻被主進(jìn)程讀出來(lái)。
sleep(1);
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  $result = $worker_process[0]->pop();
  echo "計(jì)算結(jié)果 : {$result} \n";
}
 
//父進(jìn)程監(jiān)聽(tīng)子進(jìn)程退出信號(hào)，回收子進(jìn)程，防止出現(xiàn)僵尸進(jìn)程
swoole_process::signal(SIGCHLD, function ($sig) {
  //必須為false，非阻塞模式
  while ($ret = swoole_process::wait(false)) {
    echo "子進(jìn)程 PID : {$ret['pid']} 退出\n";
  }
});

四、進(jìn)程可以通過(guò) signal 監(jiān)聽(tīng)信號(hào)，和 alarm 設(shè)置定時(shí)器。

我們可以在父進(jìn)程上設(shè)置監(jiān)聽(tīng)信號(hào)，當(dāng)子進(jìn)程退出時(shí)，重新掛起子進(jìn)程。

也可以設(shè)置定時(shí)器，通過(guò) swoole_process::kill($pid, 0); 定時(shí)檢測(cè)進(jìn)程是否存活。

<?php
//每隔1秒觸發(fā)SIGALAM信號(hào)
//注意，alarm不能和Timer同時(shí)使用
swoole_process::alarm(1000 * 1000, 0);
 
swoole_process::signal(SIGALRM, function ($signo) {
  static $cnt = 0;
  $cnt++;
  echo "時(shí)鐘定時(shí)信號(hào)\n";
 
  if ($cnt > 10) {
    //清除定時(shí)器
    swoole_process::alarm(-1);
  }
});
 
swoole_process::signal(SIGINT, function ($signo) {
  echo "我被ctrl+c了\n";
 
  //退出主進(jìn)程，不然將一直無(wú)法正常退出
  exit(0);
});

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專(zhuān)題：《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《php socket用法總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門(mén)教程》、《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》及《php程序設(shè)計(jì)算法總結(jié)》

希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: