fsocketのサンプルコード
サンプル1:
<?php
class ZSocket {
/*
* Init
*/
private function _fsockopen($host, $port, &$errno, &$errstr, $timeout){
$ip = @gethostbyname($host);
$s = @socket_create(AF_INET, SOCK_STREAM, 0);
if(socket_set_nonblock($s)){
$r = @socket_connect($s, $ip, $port);
if ($r || socket_last_error() == EINPROGRESS) {
$errno = EINPROGRESS;
return $s;
}
}
$errno = socket_last_error($s);
$errstr = socket_strerror($errno);
socket_close($s);
return false;
}
/*
* Cookieの設置
*/
private function _setCookie($cookie){
$_cookies = explode(“; “,$cookie);
$_tmp = explode(“=",$_cookies[0]);
setcookie($_tmp[0], $_tmp[1]);
return $_cookies;
}
/*
* header内容を取得してデータに戻る
*/
private function _getDataHeader(&$fp,&$reHeader,&$cookies){
$maxlen = 0;
while(!feof($fp)){
$line = fgets($fp,1024);
if(substr($line, 0, 12) == 'Set-Cookie: '){ $cookies[] = $this->_setCookie(substr($line, 12)); }
$reHeader .= $line;
if(substr($line, 0, 16) == 'Content-Length: '){
$maxlen = intval(substr($line, 16, -2));
}
if($line == “\r\n" || $line == “") break;
}
return $maxlen;
}
/*
* 本文の内容に戻る
*/
private function _getDataBody(&$fp,$maxlen){
$reData = “";
while(!feof($fp)){
$line = fgets($fp,$maxlen+1);
$reData .= $line;
if(strlen($line) < $maxlen) $maxlen = $maxlen – strlen($line);
else break;
}
return $reData;
}
/*
* 设置并返回要发送的header内容 header内容を設けてそして発送する
*/
public function get_HeaderInfo($host,$type=’GET’,$file=’/’,$params=array(),$head=array(),$cookies=array()){
$_params = $_cookies = ";
if(is_array($params)){
foreach($params as $key=>$value){
$_params .= “&".$key."=".urlencode($value);
}
$_params = (strlen($_params) > 1) ? substr($_params,1) : ";
}else if(is_string($params)){
$_params = urlencode($params);
}
foreach($cookies as $key=>$value){
$_cookies .= “; “.$key."=".urlencode($value);
}
$_cookies = (strlen($_cookies) > 2) ? substr($_cookies,2) : ";
$file .= ($type == 'GET’) ? ($_params == " ? " : '?’.$_params) : ";
$header = $type." “.$file." HTTP/1.1\r\n";
$header .= “Host: “.$host."\r\n";
//$header .= “Referer: “.get_ip()."\r\n";
//$header .= “X-Forwarded-For: “.get_ip()."\r\n";
$header .= ($type == 'GET’) ? " : “Content-Type: application/x-www-form-urlencoded\r\n";
if(is_array($head) && $head != array()){
foreach($head as $k=>$v){
$header .= $k.": “.$v."\r\n";
}
}
$header .= “Content-Length: “.strlen($_params)."\r\n";
if($_cookies != ") $header .= “Cookie: “.$_cookies."\r\n";
/*
foreach($_SERVER as $name => $value){
if(substr($name, 0, 5) == 'HTTP_’ && $name != 'HTTP_HOST’){
$header .= str_replace(' ', '-', ucwords(strtolower(str_replace('_’, ' ', substr($name, 5))))).":".$value."\r\n";
}
}
*/
$header .= “Connection: Close\r\n\r\n";
$header .= $_params."\r\n";
return $header;
}
/*
* 发送,并返回结果 Array 発送して結果はArrayに戻る
*/
public function get_SendData($host,$port=80,$header="){
if(function_exists('fsockopen’)){
$fp = fsockopen($host,$port,$errno,$errstr,10);
}else if(function_exists('pfsockopen’)){
$fp = pfsockopen($host,$port,$errno,$errstr,10);
}else if(function_exists('stream_socket_client’)){
$fp = stream_socket_client($host.’:’.$port,$errno,$errstr,10);
}else{
$fp = $this->_fsockopen($host,$port,$errno,$errstr,10);
}
$fp = fsockopen($host,$port,$errno,$errstr,10);
if(!$fp) return array('header’=>",’data’=>$errstr."—>".$errno,’cookie’=>");
$reHeader = $reData = “";
$cookies = array();
fputs($fp,$header);
$maxlen = $this->_getDataHeader($fp,$reHeader,$cookies);
$reData = $this->_getDataBody($fp,$maxlen);
fclose($fp);
return array('header’=>$reHeader,’data’=>$reData,’cookie’=>$cookies);
}
}
サンプル2:
/* demo */
$host = 'www.arkgame.com’;
$port = ’80’;
$type = 'POST’;
$file = '/’;
$params = ";
//include_once('include/zsocket.class.php’); //include
$zsk = new ZSocket();
$header = $zsk->get_HeaderInfo($host,$type,$file,$params);
$data = $zsk->get_SendData($host,$port,$header);
/*
echo “<!–\r\n";
print_r($header);
print_r($data);
echo “–>\r\n";
*/
var_dump($header);
var_dump($data);