php实现异步轮询

迈不过友情╰ 2023-06-20 15:56 161阅读 0赞

### 文章目录 ###

*   *  一、前言
     *  二、工欲善其事
     *   *  1、curl是伪异步请求
         *  2、鸟哥推荐的方法中有curl
     *  三、异步轮询（fsockopen）
     *   *  1、模拟异步轮询的demo
         *  2、响应页面代码
         *  3、测试结果
         *  4、fsockopen(): unable to connect to 错误
     *  四、问题以及反思
     *   *  1、无法调试返回
         *  2、占用进程
         *  3、最佳方式
         *  4、python，酸，真酸

## 一、前言 ##

如题所示，对于`phper`来说，异步轮询总是会觉得很麻烦，在不考虑`workman`和`swoole`的情况下，对了还有个`Guzzle`，`php`总是被人诟病的就是`多线程`和`异步IO`问题了，刚好博主最近有这个需求，下面咱们来一起研究下怎么实现原生的异步轮询。

## 二、工欲善其事 ##

既然是要做异步，博主的脑海里第一时间浮现的是`curl`的方式，我们平时对于一些外部请求，用的最多的就是`curl`方式，还可以避开`https`的证书验证，那么`curl`的方式符合需求吗？

### 1、curl是伪异步请求 ###

在不断的百度中，发现大家虽然有用`curl`进行异步请求的，但是不管是`curl`还是`curl_multi` 都需要把整个请求池所有请求处理完毕，把所有响应报文拿到，才会继续往下走的。虽然看起来像异步，但是实际上是同步阻塞的。

**参考 ：** [关于 php 通过 curl 的伪异步方式抓取数据，下面这种 curl 方式和普通的 curl 同步请求有什么区别？][php _ curl _ curl _ curl]

### 2、鸟哥推荐的方法中有curl ###

鸟哥博文：[PHP实现异步调用方法研究][PHP]

这里其实鸟哥给出了最佳的方式，不过这个`curl`鸟哥也提了一下，说是最小超时时间是`1s`，其实看到这里大家也都明白了，`curl`并不是比较好的方式，不过咱们还是研究下这个最小`1s`的问题，因为博主记得可以设置毫秒级的超时来着：

function _curl($url) { 
      $ch = curl_init();
      curl_setopt($ch,CURLOPT_URL,$url);
      curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
     curl_setopt($ch, CURLOPT_NOSIGNAL, true);    //注意，毫秒超时一定要设置这个
     curl_setopt($ch, CURLOPT_TIMEOUT_MS, 200); //超时时间200毫秒
      $result = curl_exec($ch);
      curl_close($ch);
      return $result;
    }

通过这种写法，是可以实现毫秒级的，不过想要得到什么，那就要失去什么，代价是这样一来, 就会有一个隐患, 那就是`DNS`解析将不受超时限制了。这样一来，最好是老老实实的设置`CURLOPT_TIMEOUT`为1。

参考：[Curl的毫秒超时的一个"Bug"][Curl_Bug]

OK，那这里咱们就选择用`fsockopen`的方式来实现异步轮询，具体请看下文。

## 三、异步轮询（fsockopen） ##

### 1、模拟异步轮询的demo ###

想要模拟异步轮询，那肯定是要有两个请求方法的，这里我们使用`test1.php`和`test2.php`两个页面：

test1页面代码：

<?php
 
 function request_by_fsockopen($url,$post_data=array()){ 
 $url_array = parse_url($url);
 $hostname = $url_array['host'];
 $port = isset($url_array['port']) ? $url_array['port'] : 80;
 $query = isset($url_array['query']) ? $url_array['query'] : '';
 $requestPath = isset($url_array['path']) ? $url_array['path'] . "?" . $query : $url;
 // http 协议的话是 $fp = fsockopen("ssl://localhost", 443, $errno, $errstr);
 $fp = fsockopen($hostname, $port, $errno, $errstr, 10);
 if (!$fp) { 
 echo "$errstr ($errno)";
 return false;
 }
 $method = "GET";
 if (!empty($post_data)) { 
 $method = "POST";
 }
 $header = "$method $requestPath " . "HTTP/1.1\r\n";
 $header .= "Host: $hostname\r\n"; // POST
 if (!empty($post_data)) { 
 $_post = [];
 foreach ($post_data as $k => $v) { 
 $_post[] = $k . "=" . urlencode($v);//必须做url转码以防模拟post提交的数据中有&符而导致post参数键值对紊乱
 }
 $_post = implode('&', $_post);
 // send request
 $header .= "Content-Type: application/x-www-form-urlencoded\r\n";//POST数据
 $header .= "Content-Length: " . strlen($_post) . "\r\n";//POST数据的长度
 $header .= "Connection: Close\r\n\r\n";//长连接关闭
 $header .= $_post; //传递POST数据
 } else { 
 $header .= "Connection: Close\r\n\r\n";//长连接关闭
 }
 stream_set_blocking($fp, 0); //非阻塞，true也就是1的时候，代表阻塞
 stream_set_timeout($fp, 1);//响应超时时间（S），读取流的超时时间
 fwrite($fp, $header);
 //-----------------调试代码区间-----------------
 //如果打开注释，则异步请求变成同步请求，效果还不如curl
 $html = '';
 // while (!feof($fp)) { 
 // $html .= fgets($fp, 1024);
 // }
 //-----------------调试代码区间-----------------
 usleep(20000); //fwrite之后马上执行fclose，nginx会直接返回499
 fclose($fp);
 //解析返回的内容，返回的并不是直接的json，所以需要正则匹配到json，然后处理
 /*preg_match('/\{(.*)\}/s', $html, $matches); $data = json_decode($matches[0], true); print_r($data);*/
 $status = time();
 return $status; //获取这个值，然后return
 }
 
 function test()
 { 
 // 这个$data是为了模拟post请求的参数，如果是get请求，就不需要$data参数了
 $data = array(
 'xxx' => 'xxxx',
 );
 
 $status = request_by_fsockopen('http://localhost/test22.php', $data); //模拟post
 echo $status;
 }
 
 test();
 echo '是否堵塞';
 echo "结束时间".time().' ';
 
 ?>

**解释：**  
      这段代码主要是打印了一些时间，然后调用咱们写好的函数来实现`fsockopen`的异步去请求。`$data`数组是为了模拟`post`请求，如果是`get`请求的话就不需要传这个数组了。

**注意：**

**（1）** 拼接`header`头的话，需要注意用的是哪个版本的`http`，选择不同的`http`版本，拼接`header`部分是有差异的，博主这里拼接的是`http1.1`的头部，如果是其他版本的，参考：[fsockopen与HTTP 1.1/HTTP 1.0][fsockopen_HTTP 1.1_HTTP 1.0]

**（2）** 需要设置 非阻塞访问模式

stream_set_blocking($fp, 0); //非阻塞，true也就是1的时候，代表阻塞
        stream_set_timeout($fp, 1);//响应超时时间（S），读取流的超时时间

**（3）** 注释有个代码调试区间，当我们打开注释的时候，相当于要获取该请求的返回值，那么此时就从异步变成同步了，需要注意下。  
**（4）** 如果要获取请求内容的话，`fsockopen`返回的响应需要用正则匹配`json`部分内容，参考代码上的注释即可。

### 2、响应页面代码 ###

<?php
 set_time_limit(0); //表示长时间链接运行，不限制运行时间
 ignore_user_abort(true);//设置与客户机断开是否会终止执行
 //开启该参数之后，该PHP脚本将一直处于执行的状态，代价就是占用进程
 //fastcgi_finish_request();//FastCGI模式独有，冲刷(flush)所有响应的数据给客户端。提高请求的处理速度
 
 
 //收到请求后，sleep，然后写入到日志
 function b()
 { 
 $i = 0;
 do { 
 $message = "开始时间：" . time();
 sleep(5);
 $request = $_SERVER['REQUEST_METHOD'];
 $message .= "请求方式:" . $request;
 $message .= " sleep结束" . time() . "\n";
 //FILE_APPEND参数是为了不覆盖前面的内容
 file_put_contents("E:\log.txt", $message, FILE_APPEND);
 $i+=1;
 }while($i<5);
 }
 // 调用b方法
 b()

**解释：** 这个页面是请求页面，我们这里用`sleep`模拟阻塞，用`do{}while()`方式来模拟轮询，将每次的时间写入到日志，方便对比查看。

**注意：**  
**（1）** 页面顶部设置`set_time_limit(0);`参数，异步请求的场景就是比较耗时的场景，因此我们这里要防止超时问题。  
**（2）** 设置`ignore_user_abort(true);`防止客户端断开之后，页面就停止运行了

### 3、测试结果 ###

**（1）** 页面上访问`test1.php`，返回：

开始时间：1575978768
    1575978768是否堵塞结束时间1575978768

此时可以看到请求是很顺畅的就下来了，没有阻塞。

**（2）** 打印log.text文件：

$ tail -f log.txt
 
 
 开始时间：1575978769请求方式:POST sleep结束1575978774
 开始时间：1575978775请求方式:POST sleep结束1575978780
 开始时间：1575978780请求方式:POST sleep结束1575978785
 开始时间：1575978785请求方式:POST sleep结束1575978790
 开始时间：1575978790请求方式:POST sleep结束1575978795

这里我们看到，确实是轮询了`5`次，每次都`sleep`了5s，但是并没有影响到咱们主程序的运行，`yes`，就是它了。

### 4、fsockopen(): unable to connect to 错误 ###

如果在测试的时候，出现这个提示，解决方案是：

把对应的url地址：
    
    http://xxx.xxx.com
    改为
    xxx.xxx.com

然后再去调用`fsockopen`，记得`port`设置为`80`（默认是`-1`），就可以正常访问了

## 四、问题以及反思 ##

虽然我们这里已经完成了自己的需求，但是这样的代码是不美观而且局限性很大的，而且总觉得代码过于冗余。。

### 1、无法调试返回 ###

我们在代码里也注释过了，当我们需要调试的时候，这个异步就变成了同步，那就毫无意义了，总有一些场景是需要返回值的，很明显`fsockopen`还是不够完美

### 2、占用进程 ###

这个是博主自己的想法，因为要使用这种方式，那就代表它必须要占用一个进程来不停的执行这些逻辑，页面设置了不会超时和防止客户端断开停止运行，不知道这样会不会对性能有什么大的影响。。

### 3、最佳方式 ###

如果大家有时间的话，强烈推荐使用`workerman`,如果使用了`fsockopen`,这个只是讲异步发出去了，但是并没有返回回来!如果你要异步处理，就用`workerman`.当然`swoole`也可以的，但是呢，这个有`C`语言的，一些报错信息是`C`的。你会`C`你也可以用这个（**PS：不会C也可以的！**）。`workerman`入门比较简单，推荐的话就是：

**熟悉TP框架就用workman，TP5已经集成了workman。熟悉laravel就用swoole，因为扩展安装十分方便。**

### 4、python，酸，真酸 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xKRlBIUA_size_16_color_FFFFFF_t_70]  
      这是博主最近写的`python`脚本，我滴妈啊，就引用了两个库，就实现了异步请求，还有多进程？？？酸，实在是酸，啥也不说了，必须赶紧学会`swoole`，**我们php也不差，主要是博主菜，对，一定是这样的！**

建议大家是早点掌握`workman`或者`swoole`，高并发和多线程早就成了业界公认的高手标准，咱们得跟上潮流不是，加油啊各位！

**end**

[php _ curl _ curl _ curl]: https://www.v2ex.com/t/305577
[PHP]: http://www.laruence.com/2008/04/14/318.html
[Curl_Bug]: http://www.laruence.com/2014/01/21/2939.html
[fsockopen_HTTP 1.1_HTTP 1.0]: http://www.nowamagic.net/academy/detail/12220227
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xKRlBIUA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191210210935323.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xKRlBIUA==,size_16,color_FFFFFF,t_70