swoole使用异步进程通信

Posted zonehoo

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了swoole使用异步进程通信相关的知识,希望对你有一定的参考价值。

$process = new swoole_process(function($pro){

  $pro->exec(‘//linux中的php命令所在绝对路径‘, [‘//执行文件绝对路径‘]);

}, false);

$process->start();//开启进程

swoole_process::wait();//通过  #pstree -p Pid 进行查看线程间的关系

 

#####################################分隔符#################################################

用多进程执行多请求

//模拟请求多网站的数据
echo ‘start time : ‘ . date(‘H:i:s‘) . PHP_EOL;
$workers = [];
$urls = [
‘https://baidu.com‘,
‘https://sina.com.cn‘,
‘https://bilibili.com‘,
‘https://pipigui.cc‘,
‘https://www.swoole.com‘,
‘https://wiki.swoole.com‘,
];
$url_counts = count($urls);
for($i = 0; $i < $url_counts; $i++ ){
//创建线程请求
//当创建线程的第二个参数为true时,数据存储在线程间的管道中,不打印出来,为非阻塞模式
//为false为阻塞,为同步执行
$process = new swoole_process(function($pro) use($i , $urls){
        $content = curlData($urls[$i]);
// echo $content . PHP_EOL;
$pro->write($content . PHP_EOL);
    },true);
$process->start();
$workers[] = $process;
}
//打印出存在管道的数据
foreach($workers as $process){
echo $process->read();
}
//模拟curl请求
function curlData($url){
sleep(1);
return $url . ‘: request success‘ ;
}
echo ‘end time : ‘ . date(‘H:i:s‘) . PHP_EOL;

以上是关于swoole使用异步进程通信的主要内容,如果未能解决你的问题,请参考以下文章

swoole管道通信

异步任务推送的实践

PHP Swoole 异步并行编程(韩天峰)

Swoole系列3.2Swoole 异步进程服务系统

如何在CEF JS与browser进程间异步通信

swoole的http服务