289 lines
8.5 KiB
PHP
289 lines
8.5 KiB
PHP
<?php
|
|
class HTTP{
|
|
var $Socket, $Server, $Port, $Timeout, $HttpVersion = "1.0", $Url, $Length, $ResponseTime, $ErrNum, $ErrMsg;
|
|
var $headers = array();
|
|
var $Response = array();
|
|
var $Err = false;
|
|
var $_chunkedLength =0;
|
|
|
|
function HTTP($Server, $Port = 80, $Timeout = 30){
|
|
$this->Server = $Server;
|
|
$this->Port = $Port;
|
|
$this->Timeout = $Timeout;
|
|
|
|
$this->Socket = @fsockopen ($this->Server, $this->Port, $errno, $errstr, $this->Timeout);
|
|
if(!$this->Socket){
|
|
$this->Error(0, "Socket Connection Fail");
|
|
}
|
|
}
|
|
|
|
function setTimeout($Timeout){
|
|
$this->Timeout = $Timeout;
|
|
}
|
|
|
|
function setHttpVersion($HttpVersion){
|
|
$this->HttpVersion = $HttpVersion;
|
|
}
|
|
|
|
function Head($Url = "/") {
|
|
$this->Url = $Url;
|
|
$msg = sprintf("HEAD %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
|
|
return $this->Read();
|
|
}
|
|
|
|
function isHead($Url = "/"){
|
|
$this->Url = $Url;
|
|
$msg = sprintf("HEAD %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
if($Cookie != ""){
|
|
$msg .= $this->PutCookie($Cookie);
|
|
}
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
|
|
return $this->isOK();
|
|
}
|
|
|
|
function GetHead($Url = "/") {
|
|
$this->Url = $Url;
|
|
$msg = sprintf("GET %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
$out = $this->ReadHeader();
|
|
return $out;
|
|
}
|
|
|
|
function Get($Url = "/", $Cookie="") {
|
|
$this->Url = $Url;
|
|
$msg = sprintf("GET %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
if($Cookie != ""){
|
|
$msg .= $this->PutCookie($Cookie);
|
|
}
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
return $this->Read();
|
|
}
|
|
|
|
function isGet($Url = "/", $Cookie=""){
|
|
$this->Url = $Url;
|
|
$msg = sprintf("GET %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
if($Cookie != ""){
|
|
$msg .= $this->PutCookie($Cookie);
|
|
}
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
return $this->isOK();
|
|
}
|
|
|
|
function isGetAll($Url = "/", $Cookie=""){
|
|
$this->Url = $Url;
|
|
$msg = sprintf("GET %s HTTP/%s\r\n", $this->Url, $this->HttpVersion);
|
|
if($Cookie != ""){
|
|
$msg .= $this->PutCookie($Cookie);
|
|
}
|
|
$msg .= $this->PutHead();
|
|
$msg .= "\r\n\r\n";
|
|
fputs($this->Socket, $msg);
|
|
|
|
$data = $this->Read();
|
|
$this->Length = strlen($data);
|
|
return $this->isOK($data);
|
|
}
|
|
|
|
function Post($Url, $Data, $Cookie = ""){
|
|
$this->Url = $Url;
|
|
fputs($this->Socket,sprintf("POST %s HTTP/%s\r\n", $this->Url, $this->HttpVersion));
|
|
if($Cookie != ""){
|
|
$this->PutCookie($Cookie);
|
|
}
|
|
$this->PutHead();
|
|
fputs($this->Socket, "Content-type: application/x-www-form-urlencoded\r\n");
|
|
$out = "";
|
|
while (list ($k, $v) = each ($Data)) {
|
|
if(strlen($out) != 0) $out .= "&";
|
|
$out .= rawurlencode($k). "=" .rawurlencode($v);
|
|
}
|
|
fputs($this->Socket, "Content-length: ".strlen($out)."\r\n");
|
|
fputs($this->Socket, "$out");
|
|
fputs($this->Socket, "\r\n");
|
|
return $this->Read();
|
|
}
|
|
|
|
function IsPost($Url, $Data, $Cookie = ""){
|
|
$this->Url = $Url;
|
|
fputs($this->Socket,sprintf("POST %s HTTP/%s\r\n", $this->Url, $this->HttpVersion));
|
|
if($Cookie != ""){
|
|
$this->PutCookie($Cookie);
|
|
}
|
|
$this->PutHead();
|
|
fputs($this->Socket, "Content-type: application/x-www-form-urlencoded\r\n");
|
|
$out = "";
|
|
while (list ($k, $v) = each ($Data)) {
|
|
if(strlen($out) != 0) $out .= "&";
|
|
$out .= rawurlencode($k). "=" .rawurlencode($v);
|
|
}
|
|
fputs($this->Socket, "Content-length: ".strlen($out)."\r\n\r\n");
|
|
fputs($this->Socket, "$out");
|
|
fputs($this->Socket, "\r\n");
|
|
return $this->isOk();
|
|
}
|
|
|
|
function PutHead(){
|
|
$msg = "";
|
|
$msg .= "Accept: */*\r\n";
|
|
$msg .= "Accept-Language: ko\r\n";
|
|
$msg .= "Accept-Encoding: gzip, deflate\r\n";
|
|
$msg .= "User-Agent: Mozilla/4.0 (compatible; 62che)\r\n";
|
|
while (list($name, $value) = each ($this->headers)) {
|
|
$msg .= "$name: $value\r\n";
|
|
}
|
|
$msg .= "Host: ".$this->Server.":".$this->Port."\r\n";
|
|
$msg .= "Connection: close\r\n";
|
|
return $msg;
|
|
}
|
|
|
|
function AddHeader($name, $value){
|
|
$this->headers[$name] = $value;
|
|
}
|
|
|
|
function PutCookie($cookie){
|
|
$msg = "";
|
|
if(is_array($cookie)){
|
|
$out = "";
|
|
while (list ($k, $v) = each ($cookie)) {
|
|
if(strlen($out) != 0) $out .= ";";
|
|
$out .= rawurlencode($k). "=" .rawurlencode($v);
|
|
}
|
|
$msg = "Cookie: $out\n";
|
|
} else {
|
|
$msg = "Cookie: $cookie\n";
|
|
}
|
|
return $msg;
|
|
}
|
|
|
|
function Read(){
|
|
$out = $this->ReadHeader();
|
|
$chunked = isset($this->Response['transfer-encoding']) && ('chunked' == $this->Response['transfer-encoding']);
|
|
$gzipped = isset($this->Response['content-encoding']) && ('gzip' == $this->Response['content-encoding']);
|
|
$body = '';
|
|
$this->_chunkLength = 0;
|
|
while(!feof($this->Socket)){
|
|
if ($chunked) {
|
|
$buf = $this->_readChunked();
|
|
} else {
|
|
$buf = fread($this->Socket, 4096);
|
|
}
|
|
$body .= $buf;
|
|
}
|
|
if($gzipped){
|
|
$body = gzinflate(substr($body, 10));
|
|
}
|
|
$this->Response['body'] = $body;
|
|
$out .= $body;
|
|
return $out;
|
|
}
|
|
|
|
function ReadHeader(){
|
|
$out = '';
|
|
$buf = $this->_readLine();
|
|
if (sscanf($buf, 'HTTP/%s %s', $http_version, $returncode) != 2) {
|
|
$this->Error(0,"Malformed response");
|
|
return false;
|
|
} else {
|
|
$this->Response["protocol"] = 'HTTP/' . $http_version;
|
|
$this->Response["code"] = intval($returncode);
|
|
}
|
|
$out .= $buf;
|
|
while(!feof($this->Socket)){
|
|
$buf = $this->_readLine();
|
|
$out .= $buf;
|
|
|
|
if($buf == "\n" || $buf == "\r\n"){
|
|
break;
|
|
}
|
|
|
|
list($name,$value) = split(":",rtrim($buf,"\r\n"),2);
|
|
$this->Response[strtolower($name)] = trim($value);
|
|
}
|
|
$this->Response["header"] = $out;
|
|
return $out;
|
|
}
|
|
|
|
function isOk($buffer = ""){
|
|
if($buffer == "") $buffer .= fgets($this->Socket, 128);
|
|
if(preg_match('/^HTTP\/.* (2\d{2}|3\d{2}).*/', $buffer)){
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function _readLine(){
|
|
$line = '';
|
|
while(!feof($this->Socket)){
|
|
$line .= fgets($this->Socket, 4096);
|
|
if (substr($line, -2) == "\r\n" || substr($line, -1) == "\n") {
|
|
return $line;
|
|
}
|
|
}
|
|
return $line;
|
|
}
|
|
|
|
function _readAll(){
|
|
$data = '';
|
|
while(!feof($this->Socket)){
|
|
$data .= fread($this->Socket, 4096);
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
function _readChunked(){
|
|
// at start of the next chunk?
|
|
if (0 == $this->_chunkLength) {
|
|
$line = $this->_readLine();
|
|
if (preg_match('/^([0-9a-f]+)/i', $line, $matches)) {
|
|
$this->_chunkLength = hexdec($matches[1]);
|
|
// Chunk with zero length indicates the end
|
|
if (0 == $this->_chunkLength) {
|
|
$this->_readAll(); // make this an eof()
|
|
return '';
|
|
}
|
|
}
|
|
}
|
|
$data = fread($this->Socket, $this->_chunkLength);
|
|
$this->_chunkLength -= strlen($data);
|
|
if (0 == $this->_chunkLength) {
|
|
$this->_readLine(); // Trailing CRLF
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
function Close(){
|
|
fclose($this->Socket);
|
|
}
|
|
|
|
function Error($errnum, $errmsg){
|
|
$this->Err = true;
|
|
$this->ErrNum = $errnum;
|
|
$this->ErrMsg = $errmsg;
|
|
}
|
|
|
|
function GetErr() {
|
|
return $this->Err;
|
|
}
|
|
|
|
function GetError() {
|
|
if($this->Err == true) {
|
|
return "{$this->ErrNum}, {$this->ErrMsg}";
|
|
} else {
|
|
return "No Err";
|
|
}
|
|
}
|
|
}
|