PHP异步：在PHP中使用 fsockopen curl 实现类似异步处理的功能

freewolf 发布于2019-06-27 11:21 / 2504人阅读

摘要：除了，其实也可以实现这样的效果，有些主机上并不支持，我们就可以使用来实现。

本文仅作为本人学习过程中的一点心得，欢迎大家拍砖。

PHP从主流来看，是一门面向过程的语言，它的最大缺点就是无法实现多线程管理，其程序的执行都是从头到尾，按照逻辑一路执行下来，不可能出现分支，这一点是限制php在主流程序语言中往更高级的语言发展的原因之一。

在PHP中我们有的时候其实希望在执行某项操作的时候，同时去执行另外一项操作，举一个场景：在用户抢票的时候，你并不希望用户排队去连接数据库进行查询、判断、插入，完成之后再返回用户结果。其实我们并不需要用户等那么久的时间，用户提交之后，直接告诉他已经抢票成功了就可以了，至于各种操作，交给后台去处理就好。当然，这种情况我们现在都用消息列表来处理，把每一个用户提交的请求存在一个消息列队中，告诉用户已经搞定了，用户愉快的关掉页面之后，实际上后台还在一个一个从消息列队中取出请求进行操作。我们这篇文章则是通过一种异类的手法，实现操作在后台运行，无需用户等待。

首先，我们要创建一个请求入口：



其次，我们需要一个后台处理程序，用户是否在线并不影响它的运行：



现在的问题是，在第一段代码中，如何“提交给后台”？我们通过一种非阻塞式的请求来实现这个功能。也就是创建一个可以被访问的url，在这个url运行第二段程序，通过一个请求来请求这个url，从而激活第二段程序自动运行。接下来我们直接看代码：

// 远程请求（不获取内容）函数
function _sock($url) {
  $host = parse_url($url,PHP_URL_HOST);
  $port = parse_url($url,PHP_URL_PORT);
  $port = $port ? $port : 80;
  $scheme = parse_url($url,PHP_URL_SCHEME);
  $path = parse_url($url,PHP_URL_PATH);
  $query = parse_url($url,PHP_URL_QUERY);
  if($query) $path .= "?".$query;
  if($scheme == "https") {
    $host = "ssl://".$host;
  }

  $fp = fsockopen($host,$port,$error_code,$error_msg,1);
  if(!$fp) {
    return array("error_code" => $error_code,"error_msg" => $error_msg);
  }
  else {
    stream_set_blocking($fp,true);//开启了手册上说的非阻塞模式
    stream_set_timeout($fp,1);//设置超时
    $header = "GET $path HTTP/1.1
";
    $header.="Host: $host
";
    $header.="Connection: close

";//长连接关闭
    fwrite($fp, $header);
    usleep(1000); // 这一句也是关键，如果没有这延时，可能在nginx服务器上就无法执行成功
    fclose($fp);
    return array("error_code" => 0);
  }
}


我们创建了一个基于fsockopen的函数，这个函数中利用fsockopen去访问url，但是在访问时，并不要求获取url显示的内容，而是仅仅发出访问请求，请求到达后马上关闭这个访问。这样做的好处就是无需再等待被访问的url是否返回了可靠的信息，节约了时间，这段代码的执行时间在0.1-0.2秒之间，对于普通访客而言，几乎察觉不到。因此，在使用时，仅需要调用这个函数和对应的url即可。不过，这里并没有提供数据传输的部分，如何传输数据，其实只需要在$header中增加post的内容即可。

除了fsockopen，curl其实也可以实现这样的效果，有些主机上并不支持fsockopen，我们就可以使用curl来实现。

function _curl($url) {
  $ch = curl_init();
  curl_setopt($ch,CURLOPT_URL,$url);
  curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
  curl_setopt($ch,CURLOPT_TIMEOUT,1);
  $result = curl_exec($ch);
  curl_close($ch);
  return $result;
}


这段代码的关键是提供了一个Timeout，仅1秒钟，也就是说curl发出请求，无论是否接收到返回的内容，1秒钟之后都会关闭该访问，因此这个函数的执行数据为1.0-1.1秒之间。但对于用户来说，如果是一个需要进行数据处理的应用，1秒中的等待几乎是被忽略的，如果你希望用一段更简单和容易被理解的代码，可以选择curl来实现。

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/21023.html

PHP cURL请求详解

摘要：不支持多进程，如果需要异步请求，非阻塞的方式，请选择。时会发送请求，类型为，是表单提交时最常见的一种。允许函数执行的最长秒数。设定请求中部分的内容。常规的使用来请求，功能强大，使用方便，按需配置。在PHP后端的开发过程中，除了获取数据库的数据和处理数据的内部逻辑，往往还需要请求其他服务器接口的数据，我们一般有3种方式来获取数据，分别是： file_get_contents fsoc...

paney129 2019-07-01 12:29 评论0 收藏0
PHP超时处理全面总结

摘要：的毫秒级超时也有问题。。中超时实现一初级最简单的超时实现秒级超时思路很简单链接一个后端，然后设置为非阻塞模式，如果没有连接上就一直循环，判断当前时间和超时时间之间的差异。实际处理这个调用的部件在完成后，通过状态通知和回调来通知调用者。概述在PHP开发中工作里非常多使用到超时处理到超时的场合，我说几个场景：异步获取数据如果某个后端数据源获取不成功则跳过，不影响整个页面展现为了保...

I_Am 2019-06-27 10:27 评论0 收藏0
利用客服消息和模板消息实现微信群发（突破群发接口的上限）

摘要：此接口主要用于客服等有人工消息处理环节的功能，方便开发者为用户提供更加优质的服务。不支持广告等营销类消息以及其它所有可能对用户造成骚扰的消息。 1、关于群发接口和消息接口关于群发接口1.订阅号每天可以群发消息一条，服务号每月（自然月）四条的群发权限。开发者模式下，可以通过高级群发接口，实现更灵活的群发能力。2.注意● 对于认证订阅号，群发接口每天可成功调用1次，此次群发可选择发送给全...

Gemini 2019-07-01 12:25 评论0 收藏0