脚本宝典收集整理的这篇文章主要介绍了详解PHP swoole process的使用方法，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。

引入背景：假如我们每天有10000个订单生成，需要同步到仓储系统中去，以前做法是开启一个crontab去跑这些任务，但是发现总有感觉同步效率低，间隔时间都是分钟级别的。

解决方案测试：我们将同步订单的任务表添加一个hash作为key，作为分发条件，因为MysqL中select如果做mod函数是用不到索引的，所以我们自己做随机hash，但是务必不需要范围太大，以免服务器资源不够，方法是根据hashkey投放到不同的进程中进行同步，测试代码如下

<PRe class="brush:PHP;"> 1,'uname'=>'bot','hash'=>1,'handle'=>'test'],['uid'=>2,'uname'=>'bot1','hash'=>2,['uid'=>3,'uname'=>'bot2','hash'=>3,['uid'=>4,'uname'=>'bot3','hash'=>4,'uname'=>'bot4','uname'=>'bot5','uname'=>'bot6',]; public $works = []; public $swoole_table = NULL; //public $new_index=0; function test($index,$task){ print_r("[".date('Y-m-d H:i:s')."]".'work-index:'.$index.'处理'.$task['uname'].'完成'.PHP_EOL); }

public function __construct(){
try {
$this->swoole_table = new swoole_table(1024);
$this->swoole_table->column('index',swoole_table::TYPE_INT);//用于父子进程间数据交换
$this->swoole_table->create();

  swoole_set_process_name(sprintf('<a href="https://www.js-code.COM/tag/PHP/" target="_blank" class="keywords">PHP</a>-ps:<a href="https://www.js-code.com/tag/s/" target="_blank" class="keywords">%s</a>','master'));
  $this->;mpid = posix_getpid();
  $this->run();
  $this->processWait();
}catch (\Exception $e){
  die('ALL ERROR: '.$e->getMessage());
}

}

public function run(){
for ($i=0; $i < $this->max_precess; $i++) {
$this->CreateProcess();
}
}

private function getTask($index){
$_return = [];
foreach ($this->task as $v){
if($v['hash']==$index){
$_return[] = $v;
}
}
return $_return;
}

public function CreateProcess($index=null){
if(is_null($index)){//如果没有指定了索引，新建的子进程，开启计数
$index=$this->swoole_table->get('index');
if($index === false){
$index = 0;
}else{
$index = $index['index']+1;
}
print_r($index);
}
$this->swoole_table->set('index',array('index'=>$index));
$process = new swoole_process(function(swoole_process $worker)use($index){

  swoole_set_process_name(sprintf('<a href="https://www.js-code.com/tag/PHP/" target="_blank" class="keywords">PHP</a>-ps:<a href="https://www.js-code.com/tag/s/" target="_blank" class="keywords">%s</a>',$index));
  $task = $this->getTask($index);
  foreach ($task as $v){
    call_user_func_array(array($this,$v['handle']),array($index,$v));
  }
  sleep(20);
},false,false);
$pid=$process->start();

$this->works[$index]=$pid;
return $pid;

}

public function rebootProcess($ret){
$pid=$ret['pid'];
$index=array_seArch($pid,$this->works);
if($index!==false){
$index=intval($index);
$new_pid=$this->CreateProcess($index);
echo "rebootProcess: {$index}={$new_pid} Done\n";
return;
}
throw new \Exception('rebootProcess Error: no pid');
}

public function processWaIT(){
while(1) {
if(count($this->works)){
$ret = swoole_process::wait();
if ($ret) {
$this->rebootProcess($ret);
}
}else{
break;
}
}
}

}
$process = new Process();

脚本宝典总结

以上是脚本宝典为你收集整理的详解PHP swoole process的使用方法全部内容，希望文章能够帮你解决详解PHP swoole process的使用方法所遇到的问题。

如果觉得脚本宝典网站内容还不错，欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。