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

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