Loading Please wait...

socket.php

Go to the documentation of this file.

<?php
class zSocketClient extends zCore{
  var $host;
  var $port;
  var $timeout;
  var $sep;
  var $connected;
  var $map;
  var $protocol;
  var $handle;
  var $cnv;
  var $conversation;

  function zSocketClient($host=null, $port=null, $timeout=null){
    $this->__construct($host, $port, $timeout);
  }
  function __construct($host=null, $port=null, $timeout=null){
    $this->host = $host;
    $this->port = $port;
    $this->timeout = $timeout;
    $this->sep = "\r\n";
    $this->protocol = 'tcp';
    $this->conversation = new stdClass();
    $this->conversation->client = array();
    $this->conversation->server = array();
  }
  function setHost($hostName){
    $this->host = $hostName;
  }
  function getHost(){
    return $this->host;
  }
  function setPort($port){
    $this->port = $port;
  }
  function getPort(){
    return $this->port;
  }
  function setTimeOut($timeOut){
    $this->timeout = $timeOut;
  }
  function getTimeOut(){
    return $this->timeout;
  }
  function setSeparator($sep){
    $this->sep = $sep;
  }
  function useUDP($flag = true){
    $this->protocol = $flag ? 'udp' : 'tcp';
  }
  function isUDP(){
    return ($this->protocol == 'udp');
  }
  function useTCP($flag=true){
    $this->protocol = $flag ? 'tcp' : $this->protocol;
  }
  function isTCP(){
    return ($this->protocol == 'tcp');
  }
  function useSSL($flag = true){
    $this->protocol = $flag ? 'ssl' : '';
  }
  function isSSL(){
    return ($this->protocol == 'ssl');
  }
  function useTLS($flag=true){
    $this->protocol = $flag ? 'tls' : '';
  }
  function isTLS(){
    return ($this->protocol == 'tls');
  }
  function connect(){
    if(!$this->isConnectable()){
      perror("<code>zigmoyd.socket.connect</code><br />Sorry Server not Connectable");
      exit;
    }
    if(!$this->isConnected()){
      if(!$this->handle = @pfsockopen($this->host, $this->port, $errNo, $errStr, $this->timeout)){
        perror("<code>zigmoyd.socket.connect</code><br />Failed to Connect with $this->host on Port $this->port<br />Error No: $errNo<br />Error Text: $errStr");
        if(class_exists('zLogger'))zLogger::error("Failed to Connect with Host $this->host on Port $this->port Error: ($errNo) $errStr", 'socket.connect');
        $this->connected = false;
      }else{
        if(class_exists('zLogger'))zLogger::debug("Successfully Connected to Host $this->host on Port $this->port<br />Error No: $errNo<br />Error Text: $errStr", 'socket.connect');
        $this->connected = true;
      }
    }
    return $this->connected;
  }
  function isConnected(){
    return $this->connected;
  }
  function isConnectable(){
    if(strlen($this->protocol) <= 1){
      perror('<code>zigmoyd.socket.isConnectable</code><br />Invalid Protocol');
      if(class_exists('zLogger'))zLogger::error('Invalid Protocol', 'zigmoyd.socket');
      return false;
    }
    if(strlen($this->host) <= 1){
      perror('<code>zigmoyd.socket.isConnectable</code><br />Invalid Host');
      if(class_exists('zLogger'))zLogger::error('Invalid Host', 'zigmoyd.socket');
      return false;
    }
    if(strlen($this->port) <= 1){
      perror('<code>zigmoyd.socket.isConnectable</code><br />Invalid Port');
      if(class_exists('zLogger'))zLogger::error('Invalid Port', 'zigmoyd.socket');
      return false;
    }
    if(!$this->timeout){
      $this->timeout = 30;
    }
    return true;
  }
  function send($data){
    $this->conversation->client[] = $data;
    fflush($this->handle);
    $ret = fwrite($this->handle, $data.$this->sep);
    if(!$ret)perror('<code>zigmoyd.socket.send</code><br />Failed to Write on Sicket');
    return $ret;
  }
  function receive($maxLen=0){
    $return = '';
    while(is_string(($ch = fgetc($this->handle)))){
      if($maxLen != 1){
        $return .= $ch;
        --$maxLen;
      }
    }
    $this->conversation->server[] = $return;
    return $return;
  }
  function disconnect(){
    if(is_resource($this->handle)){
      if(class_exists('zLogger'))zLogger::debug("Closing Socket Connection as not yet Closed", "socket.disconnect");
      fclose($this->handle);
    }else{
      if(class_exists('zLogger'))zLogger::debug("NOT Closing Socket Connection as already Closed", "socket.disconnect");
    }
  }
  function __destruct(){
    $this->disconnect();
  }
}
?>
<?php
//$tst = new zSocketClient('google.co.in', 80, 30);
//$tst->connect();
//$tst->send("GET /");
//echo $tst->receive();
?>

---