请php达人举个fsockopen post表单的例子

发布网友发布时间：2022-04-29 09:28

我来回答

共2个回答

懂视网时间：2022-04-29 13:49

php执行一段程序，有可能几毫秒就执行完毕，也有可能耗时较长。

例如，用户下单这个事件，如果调用了些第三方服务进行发邮件、短信、推送等通知，可能导致前端一直在等待。

而有的时候，我们并不关心这些耗时脚本的返回结果，只要执行就行了。这时候就需要采用异步的方式执行。

众所周知，PHP没有直接支持多线程这种东西。我们可以采用折衷的方式实现。这里主要说的就是fsockopen。

通过fsockopen发送请求并忽略返回结果，程序可以马上返回。

示例代码：

$fp = fsockopen("www.example.com", 80, $errno, $errstr, 30);
if (!$fp) {
 echo "$errstr ($errno)<br />
";
} else {
 $out = "GET /backend.php HTTP/1.1
";
 $out .= "Host: www.example.com
";
 $out .= "Connection: Close

";
 
 fwrite($fp, $out);
 /*忽略执行结果
 while (!feof($fp)) {
 echo fgets($fp, 128);
 }*/
 fclose($fp);
}

需要注意的是我们需要手动拼出header头信息。通过打开注释部分，可以查看请求返回结果，但这时候又变成同步的了，因为程序会等待返回结果才结束。

实际测试的时候发现，不忽略执行结果，调试的时候每次都会成功发送sock请求；但忽略执行结果，经常看到没有成功发送sock请求。查看nginx日志，发现很多状态码为499的请求。

后来找到了原因：

fwrite之后马上执行fclose，nginx会直接返回499，不会把请求转发给php处理。

客户端主动端口请求连接时，NGINX 不会将该请求代理给上游服务（FastCGI PHP 进程），这个时候 access log 中会以 499 记录这个请求。

解决方案：

1)nginx.conf增加配置

# 忽略客户端中断
fastcgi_ignore_client_abort on;

2)fwrite之后使用usleep函数休眠20毫秒：

usleep(20000);

后来测试就没有发现失败的情况了。

附上完整代码：

<?php
/**
 * 工具类
 * */
class FsockService {
 
 public static function post($url, $param){
 $host = parse_url($url, PHP_URL_HOST);
 $port = 80;
 $errno = '';
 $errstr = '';
 $timeout = 30;
 $data = http_build_query($param);
 // create connect
 $fp = fsockopen($host, $port, $errno, $errstr, $timeout);
 if(!$fp){
  return false;
 }
 // send request
 $out = "POST ${url} HTTP/1.1
";
 $out .= "Host:${host}
";
 $out .= "Content-type:application/x-www-form-urlencoded
";
 $out .= "Content-length:".strlen($data)."
";
 $out .= "Connection:close

";
 $out .= "${data}";
 fwrite($fp, $out);
 //忽略执行结果；否则等待返回结果
// if(APP_DEBUG === true){
 if(false){
  $ret = '';
  while (!feof($fp)) {
  $ret .= fgets($fp, 128);
  }
 }
 usleep(20000); //fwrite之后马上执行fclose，nginx会直接返回499
 fclose($fp);
 }
 public static function get($url, $param){
 $host = parse_url($url, PHP_URL_HOST);
 $port = 80;
 $errno = '';
 $errstr = '';
 $timeout = 30;
 $url = $url.'?'.http_build_query($param);
 // create connect
 $fp = fsockopen($host, $port, $errno, $errstr, $timeout);
 if(!$fp){
  return false;
 }
 // send request
 $out = "GET ${url} HTTP/1.1
";
 $out .= "Host:${host}
";
 $out .= "Connection:close

";
 fwrite($fp, $out);
 //忽略执行结果；否则等待返回结果
// if(APP_DEBUG === true){
 if(false){
  $ret = '';
  while (!feof($fp)) {
  $ret .= fgets($fp, 128);
  }
 }
 usleep(20000); //fwrite之后马上执行fclose，nginx会直接返回499
 fclose($fp);
 }
 
}
?>

更多相关php知识，请访问php教程！

热心网友时间：2022-04-29 10:57

例子代码如下，里面的函数是从我的程序里面粘贴的，保证没有问题，我空间有用PHP写的开心农场、超级大富翁的自动挂机程序可以供你参考：

<?php
list($body,$header)=http_request('POST',
'http://www2.ctt.pt/feapl/jsp/pesqobjectos/public/pesqobjectosform.jsf',
'pesqObjectoForm%3Aidioma=PT&pesqObjectoForm%3Aempresa=CTT&pesqObjectoForm%3AobjectoId=RT039328389HK&pesqObjectoForm%3Asend=Pesquisar&pesqObjectoForm_SUBMIT=1&pesqObjectoForm%3A_link_hidden_=&pesqObjectoForm%3A_idcl=
');

//执行HTTP请求
function http_request($url,$method='GET',$data='',$cookie='',$refer=''){
$header='';
$body='';
$newcookie='';
if (preg_match('/^http:\/\/(.*?)(\/.*)$/',$url,$reg)){$host=$reg[1]; $path=$reg[2];}
else {outs("URL($url)格式非法!"); return;}
$http_host=$host;
if (preg_match('/^(.*):(\d+)$/', $host, $reg)) {$host=$reg[1]; $port=$reg[2];}
else $port=80;
$fp = fsockopen($host, $port, $errno, $errstr, 30);
if (!$fp) {
outs("$errstr ($errno)\n");
} else {
fputs($fp, "$method $path HTTP/1.1\r\n");
fputs($fp, "Host: $http_host\r\n");
if ($refer!='') fputs($fp, "Referer: $refer\r\n");
if ($cookie!='') fputs($fp, "Cookie: $cookie\r\n");
fputs($fp, "Content-type: application/x-www-form-urlencoded\r\n");
fputs($fp, "Content-length: ".strlen($data)."\r\n");
fputs($fp, "Connection: close\r\n\r\n");
fputs($fp, $data . "\r\n\r\n");
$header_body=0;
while (!feof($fp)) {
$str=fgets($fp);
if ($header_body==1) $body.=$str;
else if ($str=="\r\n") $header_body=1;
else {
$header.=$str;
if (preg_match('|Set-Cookie: (\S+)=(\S+);|',$str,$reg)) $newcookie.=($newcookie==''?'':'; ').$reg[1].'='.$reg[2];
}
}
fclose($fp);
}
$GLOBALS['TRAFFIC']+=414+strlen($url)+strlen($data)+strlen($header)+strlen($body);
if (preg_match('/^Location: (\S+)\r\n/m',$header,$reg)) {
if (substr($reg[1],0,1)!='/'){
$path=substr($path,0,strrpos($path,'/')+1);
$path.=$reg[1];
} else $path=$reg[1];
if ($newcookie) $cookie=$newcookie;
return http_request('http://'.$http_host.$path,'GET','',$cookie,$url);
}
return array($body, $header, $newcookie);
}
?>