//連接websocket

var ws = new WebSocket("ws://127.0.0.1:8000");

//成功連接websoc的時(shí)候

ws.onopen = function(){}

//成功獲取服務(wù)端輸出的消息

ws.onmessage = function(e){}

//連接錯(cuò)誤的時(shí)候
ws.onerror = function(){}

//向服務(wù)端發(fā)送數(shù)據(jù)

ws.send();

//建立套接字
    public function createSocket($address,$port)
    {
      //創(chuàng)建一個(gè)套接字
      $socket= socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
      //設(shè)置套接字選項(xiàng)
      socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
      //綁定IP地址和端口
      socket_bind($socket,$address,$port);
      //監(jiān)聽套接字
      socket_listen($socket);
      return $socket;
    }

public function __construct($address,$port)
    {
      //建立套接字
      $this->soc=$this->createSocket($address,$port);
      $this->socs=array($this->soc);

    }

public function run(){
      //掛起進(jìn)程
      while(true){
        $arr=$this->socs;
        $write=$except=NULL;
        //接收套接字?jǐn)?shù)字 監(jiān)聽他們的狀態(tài)
        socket_select($arr,$write,$except, NULL);
        //遍歷套接字?jǐn)?shù)組
        foreach($arr as $k=>$v){
          //如果是新建立的套接字返回一個(gè)有效的 套接字資源
          if($this->soc == $v){
            $client=socket_accept($this->soc);
            if($client <0){
              echo "socket_accept() failed";
            }else{
              // array_push($this->socs,$client);
              // unset($this[]);
              //將有效的套接字資源放到套接字?jǐn)?shù)組
              $this->socs[]=$client;
            }
          }else{
            //從已連接的socket接收數(shù)據(jù) 返回的是從socket中接收的字節(jié)數(shù)
            $byte=socket_recv($v, $buff,20480, 0);
            //如果接收的字節(jié)是0
            if($byte<7)
              continue;
            //判斷有沒有握手沒有握手則進(jìn)行握手,如果握手了 則進(jìn)行處理
            if(!$this->hand[(int)$client]){
              //進(jìn)行握手操作
              $this->hands($client,$buff,$v);
            }else{
              //處理數(shù)據(jù)操作
              $mess=$this->decodeData($buff);
                //發(fā)送數(shù)據(jù)
              $this->send($mess,$v);
            }
          }
        }
      }
    }

public function hands($client,$buff,$v)
    {
      //提取websocket傳的key并進(jìn)行加密 （這是固定的握手機(jī)制獲取Sec-WebSocket-Key:里面的key）
      $buf = substr($buff,strpos($buff,'Sec-WebSocket-Key:')+18);
      //去除換行空格字符
      $key = trim(substr($buf,0,strpos($buf,"\r\n")));
       //固定的加密算法
      $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
      $new_message = "HTTP/1.1 101 Switching Protocols\r\n";
      $new_message .= "Upgrade: websocket\r\n";
      $new_message .= "Sec-WebSocket-Version: 13\r\n";
      $new_message .= "Connection: Upgrade\r\n";
      $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
      //將套接字寫入緩沖區(qū)
      socket_write($v,$new_message,strlen($new_message));
      // socket_write(socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
      //標(biāo)記此套接字握手成功
      $this->hand[(int)$client]=true;
    }

//解析數(shù)據(jù)
    public function decodeData($buff)
    {
      //$buff 解析數(shù)據(jù)幀
      $mask = array(); 
      $data = ''; 
      $msg = unpack('H*',$buff); //用unpack函數(shù)從二進(jìn)制將數(shù)據(jù)解碼
      $head = substr($msg[1],0,2); 
      if (hexdec($head{1}) === 8) { 
        $data = false; 
      }else if (hexdec($head{1}) === 1){ 
        $mask[] = hexdec(substr($msg[1],4,2)); 
        $mask[] = hexdec(substr($msg[1],6,2)); 
        $mask[] = hexdec(substr($msg[1],8,2)); 
        $mask[] = hexdec(substr($msg[1],10,2)); 
          //遇到的問題 剛連接的時(shí)候就發(fā)送數(shù)據(jù) 顯示 state connecting
        $s = 12; 
        $e = strlen($msg[1])-2; 
        $n = 0; 
        for ($i=$s; $i<= $e; $i+= 2) { 
          $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2))); 
          $n++; 
        }
        //發(fā)送數(shù)據(jù)到客戶端
          //如果長(zhǎng)度大于125 將數(shù)據(jù)分塊
          $block=str_split($data,125);
          $mess=array(
            'mess'=>$block[0],
            );
        return $mess;          
      }

//發(fā)送數(shù)據(jù)
    public function send($mess,$v)
    {
      //遍歷套接字?jǐn)?shù)組 成功握手的 進(jìn)行數(shù)據(jù)群發(fā)
      foreach ($this->socs as $keys => $values) {
        //用系統(tǒng)分配的套接字資源id作為用戶昵稱
          $mess['name']="Tourist's socket:{$v}";
          $str=json_encode($mess);
          $writes ="\x81".chr(strlen($str)).$str;
          // ob_flush();
          // flush();
          // sleep(3);
          if($this->hand[(int)$values])
            socket_write($values,$writes,strlen($writes));
        }
    }

if (window.WebSocket){
  console.log("This browser supports WebSocket!");
} else {
  console.log("This browser does not support WebSocket.");
}