swoole进程详解

电玩女神 2023-10-06 18:57 53阅读 0赞

#### swoole进程详解 ####

*  进程详解
 *  开启进程
 *   *  Process.php
     *  http\_server.php
     *  跟踪查看父进程
     *  查看开启的子进程
     *  树形目录查看进程master，work进程分析
     *  exec执行服务端
 *  swoole进程使用场景

## 进程详解 ##

进程就是正在运行程序的一个实例

## 开启进程 ##

### Process.php ###

<?php
    
    $process = new Swoole\Process('callback_function', true);
    
    $pid = $process->start();
    
    function callback_function(Swoole\Process $worker)
    {
        
        $worker->exec('/www/server/php/71/bin/php', array(__DIR__.'/../http_server.php'));
    }
    echo $pid.PHP_EOL;
    Swoole\Process::wait();

![在这里插入图片描述][8d29b018e5e04610acda3d43c44ce799.png]

### http\_server.php ###

<?php
    
    $http=new swoole_http_server("0.0.0.0",8812);
    
    $http->set(
      [
        'enable_static_handler'=>true,
        'document_root'=>"/www/wwwroot/test.cc",
      ]
    );
    
    //绑定request请求
    $http->on('request',function($request,$response){
        
      //print_r($request->get);
      //$response->end("<h1>HTTPserver</h1>");
      $response->cookie("willem","chenweiguang",time()+1800);
      $response->end("sss".json_encode($request->get));
    });
    
    $http->start();

### 跟踪查看父进程 ###

![在这里插入图片描述][c6a034d1b988478bab2756afd4674998.png]

[root@bogon swoole]# ps aux | grep Process.php 
    root      4948  0.1  0.3 254648 15344 pts/1    S+   18:04   0:00 php Process.php
    root      4975  0.0  0.0 112812   984 pts/0    S+   18:04   0:00 grep --color=auto Process.php
    
    [root@bogon swoole]# pstree -p 4948
    php(4948)───php(4949)─┬─php(4950)─┬─php(4953)
                          │           └─php(4954)
                          ├─{php}(4951)
                          └─{php}(4952)

### 查看开启的子进程 ###

![在这里插入图片描述][f012a4eb89ff443b8275961e77af6292.png]  
linux网络状态，一般会用netstat -anp命令查看

### 树形目录查看进程master，work进程分析 ###

[root@bogon test.cc]# ps aft | grep http_server.php 
     4949 pts/1    Sl+    0:00      \_ /www/server/php/71/bin/php /www/wwwroot/test.cc/swoole/../http_server.php
     4950 pts/1    S+     0:00          \_ /www/server/php/71/bin/php /www/wwwroot/test.cc/swoole/../http_server.php
     4953 pts/1    S+     0:00              \_ /www/server/php/71/bin/php /www/wwwroot/test.cc/swoole/../http_server.php
     4954 pts/1    S+     0:00              \_ /www/server/php/71/bin/php /www/wwwroot/test.cc/swoole/../http_server.php
     5715 pts/0    S+     0:00  \_ grep --color=auto http_server.php
    [root@bogon test.cc]#

### exec执行服务端 ###

Process.php

<?php
    
    $process = new Swoole\Process('callback_function', true);
    
    $pid = $process->start();
    
    function callback_function(Swoole\Process $worker)
    {
        
        $worker->exec('/www/server/php/71/bin/php', array(__DIR__.'/redis.php'));
    }
    echo $pid.PHP_EOL;
    Swoole\Process::wait();

[root@bogon swoole]# php Process.php 
    4293

redis.php

<?php
    use Swoole\Coroutine\Redis;
    use function Swoole\Coroutine\run;
    
    run(function () {
        
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $redis->auth('123456');
        $val = $redis->set('name','process');
    
        print_r($val);
    });

![在这里插入图片描述][ad480ad7b06a4e93b35253d20eba30f1.png]

## swoole进程使用场景 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]

<?php
    /*
    //传统PHP复制子进程是这样的
    $urls=[
    	'http://baidu.com',
    	'http://sina.com',
    	'http://qq.com',
    	'http://51tx.cn',
    ];
    
    foreach($urls as $url){
    	$content[]=file_get_contents($url);
    }
    */
    
    # swoole方式
    echo "process-start-time：".date("Ymd H:i:s").PHP_EOL;//输出开始时间
    
    $urls=[
    	'http://baidu.com',
    	'http://sina.com',
    	'http://qq.com',
    	'http://51tx.cn',
    ];
    
    for($i=0;$i<4;$i++){
        
    	# 子进程
    	$process=new swoole_process(function(swoole_process $worker) use($i,$urls){
        
    		//每个子进程执行curl
    		$content=curlData($urls[$i]);
    		// echo $content.PHP_EOL;//内容输出到了管道里
    		
    		# 另一种写入管道方法
    		$worker->write($content.PHP_EOL);
    	},true);
    
    	$pid=$process->start();
    	$workers[$pid]=$process;
    }
    
    # 打印管道内容
    foreach ($workers as $value) {
        
    	//打印管道内容用read方法
    	echo $value->read();
    }
    
    /*获取数据的内容
      模拟请求URL的内容 ls
    */
    function curlData($url){
        
    	//正常cul 或 file_get_contents
    	sleep(1);//延迟一秒
    	return $url."success".PHP_EOL;
    }
    
    # 输出结束时间
    echo "process-end-time：".date("Ymd H:i:s").PHP_EOL;

[root@bogon swoole]# php Process.php 
    process-start-time：20210811 18:22:39
    http://baidu.comsuccess
    
    http://sina.comsuccess
    
    http://qq.comsuccess
    
    http://51tx.cnsuccess
    
    process-end-time：20210811 18:22:40
    [root@bogon swoole]#

[8d29b018e5e04610acda3d43c44ce799.png]: https://img-blog.csdnimg.cn/8d29b018e5e04610acda3d43c44ce799.png
[c6a034d1b988478bab2756afd4674998.png]: https://img-blog.csdnimg.cn/c6a034d1b988478bab2756afd4674998.png
[f012a4eb89ff443b8275961e77af6292.png]: https://img-blog.csdnimg.cn/f012a4eb89ff443b8275961e77af6292.png
[ad480ad7b06a4e93b35253d20eba30f1.png]: https://img-blog.csdnimg.cn/ad480ad7b06a4e93b35253d20eba30f1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/0fc7ac5be26749e689a94daa786d20d1.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70