PHPソケットクラス


暇な時に自分でsocketクラスをカプセル化しました
機能は簡単でcurl機能と同じです
class socketClass{
    private $host;
    private $url;
    private $error_no = 0;
    public $error_str = '';
    private $port = 80;
    private $timeout = 5;
    private $method;
    private $param;
    private $fp;
    private $content = '';
    private $header = array();
    public function __construct($host, $port, $url, $param, $method='GET', $timeout=5) {
        $this->host = $host;
        $this->port = $port;
        $this->url = $url;
        $this->timeout = $timeout;
        $this->method = $method;
        if(is_array($param)){
            $this->param = http_build_query($param);
        }else{
            $this->param = $param;
        }
    }
    private function connect(){
        $this->fp = fsockopen($this->host, $this->port, $this->error_no, $this->error_str, $this->timeout);
        if(!$this->fp){
            $this->error_str = 'socket connect failed';
            return false;
        }
        return true;
    }
    private function send(){
        $this->fp = '';
        if(!$this->connect()){
            $this->error_str = 'connect socket failed';
            return false;
        }
        if($this->method == 'POST'){
            $header = "POST $this->url HTTP/1.1\r
"; }else{ if(!empty($this->param)){ $header = "GET $this->url?$this->param HTTP/1.1\r
"; }else{ $header = "GET $this->url HTTP/1.1\r
"; } } $header .= "Content-Length:" . strlen($this->param) . "\r
"; $header .= "Host:$this->host:$this->port\r
"; $header .= "Content-Type:application/x-www-form-urlencode\r
"; $header .= "Connection:close\r
\r
"; if($this->method == 'POST'){ $header .= "$this->param\r
\r
"; } if(!empty($this->header)){ foreach ($this->header as $key=>$val){ $tmep = urlencode($val);  $header .= "$key:$temp\r
"; } } fwrite($this->fp, $header); while(!feof($this->fp)){ $this->content .= fread($this->fp, 1024); } fclose($this->fp); return true; } public function getContent(){ if(!$this->send()){ return false; } $pos = strpos($this->content, "\r
\r
"); $this->content = substr($this->content, $pos); return $this->content; } public function setHeader($key, $val){ $this->header[$key] = $val; } public function getErrorStr(){ return $this->error_str; } } $host = 'localhost'; $port = 81; $url = 'http://localhost/phpdemo/php/socket_accept.php'; $param = array('username'=>'beggar', 'passwd'=>'20060400'); $method = 'GET'; $timeout = 10; $http = new socketClass($host, $port, $url, $param, $method, $timeout); $http->setHeader('referer', $url); $http->setHeader('Accept', '*/*'); $header = $http->getContent(); echo $header;