php socket客戶端及服務器端應用實例

經常有朋友會對php的socket應用充滿疑惑，本文就以實例代碼作一講解，希望能對初學php的朋友起到一點幫助作用

具體代碼如下：

1.服務器端代碼:

<?php
class SocketServer{
  private $_port='9000';
  private $_address='127.0.0.1';
  private $_client_socket_list=array();
  public function __set($name,$val){
    $this--->$name=$val;
  }
  private function _showError($error){
    exit($error);
  }
  /**
   * 開始進行socket服務器端監聽端口
   */
  public function start(){
    // 創建端口
    if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) {
      $this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () ));
    }
    // 綁定
    if (socket_bind ( $sock, $this->_address, $this->_port ) === false) {
      $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ));
    }
    // 監聽
    if (socket_listen ( $sock, 5 ) === false) {
      $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) );
    }
    do {
      //當有一個客戶端連接的時候
      if ($client_socket=socket_accept ( $sock )) {
        $count = count ( $this->_client_socket_list ) + 1;
        //把新來的用戶加入 客戶端數組裡
        $this->_client_socket_list[]=$client_socket;
        echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量
        echo "current connection:{$count}\r\n";
        //接受客戶端傳過來的字符串
        $msg=$this->read($client_socket);
        echo "client:{$msg}\r\n";
        //服務器向客戶端傳值
        $my_msg="I am fine,think you\r\n";
        $this->send($client_socket,$my_msg);
      }
      /**
       * 這段代碼給你參考,用來判斷是否有客戶端主動失去連接
      else{
        foreach ( $this->_client_socket_list as $socket ) {
          $len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接
          if ($len < 7) {
            //這裡寫是去連接的客戶端業務
          }
        }
      }
       */
    }while(true);  
  }
  /**
   * 發送數據給客戶端
   */
  public function send($client_socket,$str){ 
    return socket_write ( $client_socket,$str, strlen ( $str ) );
  }
  /**
   * 從客戶端接受數據
   */
  public function read($client_socket){
    return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別
  }
}
$socket_server =new SocketServer();
$socket_server->start();//開始監聽

2.客戶端代碼:

<?php
class SocketServer{
  private $_port='9000';
  private $_address='127.0.0.1';
  private $_client_socket_list=array();
  public function __set($name,$val){
    $this--->$name=$val;
  }
  private function _showError($error){
    exit($error);
  }
  /**
   * 開始進行socket服務器端監聽端口
   */
  public function start(){
    // 創建端口
    if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) {
      $this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () ));
    }
    // 綁定
    if (socket_bind ( $sock, $this->_address, $this->_port ) === false) {
      $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ));
    }
    // 監聽
    if (socket_listen ( $sock, 5 ) === false) {
      $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) );
    }
    do {
      //當有一個客戶端連接的時候
      if ($client_socket=socket_accept ( $sock )) {
        $count = count ( $this->_client_socket_list ) + 1;
        //把新來的用戶加入 客戶端數組裡
        $this->_client_socket_list[]=$client_socket;
        echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量
        echo "current connection:{$count}\r\n";
        //接受客戶端傳過來的字符串
        $msg=$this->read($client_socket);
        echo "client:{$msg}\r\n";
        //服務器向客戶端傳值
        $my_msg="I am fine,think you\r\n";
        $this->send($client_socket,$my_msg);
      }
      /**
       * 這段代碼給你參考,用來判斷是否有客戶端主動失去連接
      else{
        foreach ( $this->_client_socket_list as $socket ) {
          $len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接
          if ($len < 7) {
            //這裡寫是去連接的客戶端業務
          }
        }
      }
       */
    }while(true);  
  }
  /**
   * 發送數據給客戶端
   */
  public function send($client_socket,$str){ 
    return socket_write ( $client_socket,$str, strlen ( $str ) );
  }
  /**
   * 從客戶端接受數據
   */
  public function read($client_socket){
    return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別
  }
}
$socket_server =new SocketServer();
$socket_server->start();//開始監聽

注意事項:服務器端請用CLI模式運行,cgi模式會超時,這是新手常喜歡犯的錯誤。那麼什麼是CLI模式呢？簡單的說就是用命令行去執行,而不要用游覽器打開,否則會超時的！