php实现异步轮询_php轮询_铁柱同学的博客

二、工欲善其事

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

在不断的百度中，发现大家虽然有用 curl 进行异步请求的，但是不管是 curl 还是 curl_multi 都需要把整个请求池所有请求处理完毕，把所有响应报文拿到，才会继续往下走的。虽然看起来像异步，但是实际上是同步阻塞的。
参考： 关于 php 通过 curl 的伪异步方式抓取数据，下面这种 curl 方式和普通的 curl 同步请求有什么区别？
2、鸟哥推荐的方法中有curl

这里其实鸟哥给出了最佳的方式，不过这个 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" 
      OK，那这里咱们就选择用fsockopen的方式来实现异步轮询，具体请看下文。 
三、异步轮询（fsockopen）
 
1、模拟异步轮询的demo
 
想要模拟异步轮询，那肯定是要有两个请求方法的，这里我们使用test1.php和test2.php两个页面： 
test1页面代码： 
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().'<br/>';
解释：
       这段代码主要是打印了一些时间，然后调用咱们写好的函数来实现fsockopen的异步去请求。$data数组是为了模拟post请求，如果是get请求的话就不需要传这个数组了。 
（1） 拼接header头的话，需要注意用的是哪个版本的http，选择不同的http版本，拼接header部分是有差异的，博主这里拼接的是http1.1的头部，如果是其他版本的，参考：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、响应页面代码
 
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 .= "<br/>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<br/>sleep结束1575978774
开始时间：1575978775请求方式:POST<br/>sleep结束1575978780
开始时间：1575978780请求方式:POST<br/>sleep结束1575978785
开始时间：1575978785请求方式:POST<br/>sleep结束1575978790
开始时间：1575978790请求方式:POST<br/>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，酸，真酸
 

       这是博主最近写的python脚本，我滴妈啊，就引用了两个库，就实现了异步请求，还有多进程？？？酸，实在是酸，啥也不说了，必须赶紧学会swoole，我们php也不差，主要是博主菜，对，一定是这样的！ 
      建议大家是早点掌握workman或者swoole，高并发和多线程早就成了业界公认的高手标准，咱们得跟上潮流不是，加油啊各位！ 
                    一、前言&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如题所示，对于phper来说，异步轮询总是会觉得很麻烦，在不考虑workman和swoole的情况下，php总是被人诟病的就是多线程和异步IO问题了，刚好博主最近有这个需求，下面咱们来一起研究下怎么实现原生的异步轮询。二、工欲善其事&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;既然是要做...
public class RoundRobin {
    private int currentIndex = 0;
    private List<String> servers = new ArrayList<>();
    public RoundRobin(List<String> servers) {
        this.servers = servers;
    public String getServer() {
        String server = servers.get(currentIndex);
        currentIndex = (currentIndex + 1) % servers.size();
        return server;
该代码实现了一个简单的轮询算法，其中 `servers` 数组存储了所有的服务器地址，每次调用 `getServer` 方法就会返回下一个服务器地址。当到达最后一个服务器地址时，下一个服务器地址会回到第一个。
                laravel的composer require报错：Installation failed, reverting ./composer.json to its original content.
                    carryoo: 
                    我删除 composer.lock，然后 require 安装成功
                logstash导入数据到Elasticsearch踩过的坑详解
                    qq_53107249: 
                    已经有的es索引，为什么更新不上去呢
                mysql存储数据，varchar类型中的数据变成了科学计数法？
                    铁柱同学: 
                    x是你要取2的多少次方
                mysql存储数据，varchar类型中的数据变成了科学计数法？
                    seven大数据: 
                    这里的x是什么
                mysql优化sql相关（持续补充）
                    铁柱同学: 
                    mysql现在用的少了