搜尋
首頁php教程PHP开发php基於websocket搭建簡易聊天室實踐

本文實例講述了php基於websocket搭建簡易聊天室實作。分享給大家供大家參考。具體如下:
1、前言

公司遊戲裡面有個簡單的聊天室,了解了之後才知道是node+websocket做的,想想php也來做個簡單的聊天室。於是蒐集各種資料看文件、找實例自己也寫了個簡單的聊天室。

http連接分為短連接和長連接。短連線一般可以用ajax實現,長連線就是websocket。短連線實作起來比較簡單,但太過於消耗資源。 websocket高效不過相容存在點問題。 websocket是html5的資源

2、前端

前端實作websocket很簡單直接

//连接websocket
 
var ws = new WebSocket("ws://127.0.0.1:8000");
 
//成功连接websoc的时候
 
ws.onopen = function(){}
 
//成功获取服务端输出的消息
 
ws.onmessage = function(e){}
 
//连接错误的时候
ws.onerror = function(){}
 
//向服务端发送数据
 
ws.send();

3、後台

websocket的難點主要在後台


websocket的難點主要在後台

php基於websocket搭建簡易聊天室實踐圖.端和服務端的通訊圖解,php主要就做的就是接受加密key  並回傳其中完成套接字的創建和握手操作


下圖是一張詳細的服務端處理websocket的流程圖

php基於websocket搭建簡易聊天室實踐


3.2 程式碼實作

服務端所做的流程大致是:

掛起一個socket套接字進程等待連線


有socket連線之後才有一個socket套接字行程等待連線

有socket連線之後才有一個沒有握手的動作組。 ,如果已經握手則接收資料解析並寫入緩衝區進行輸出

下面是範例程式碼(我寫的是一個類別所以程式碼是根據函數分段的),文底給出github位址以及自己遇到的有些坑

 1、先建立套接字

//建立套接字
    public function createSocket($address,$port)
    {
      //创建一个套接字
      $socket= socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
      //设置套接字选项
      socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
      //绑定IP地址和端口
      socket_bind($socket,$address,$port);
      //监听套接字
      socket_listen($socket);
      return $socket;
    }

   

2、將套接字放入陣列

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

 在這裡完成的

public function run(){
      //挂起进程
      while(true){
        $arr=$this->socs;
        $write=$except=NULL;
        //接收套接字数字 监听他们的状态
        socket_select($arr,$write,$except, NULL);
        //遍历套接字数组
        foreach($arr as $k=>$v){
          //如果是新建立的套接字返回一个有效的 套接字资源
          if($this->soc == $v){
            $client=socket_accept($this->soc);
            if($client <0){
              echo "socket_accept() failed";
            }else{
              // array_push($this->socs,$client);
              // unset($this[]);
              //将有效的套接字资源放到套接字数组
              $this->socs[]=$client;
            }
          }else{
            //从已连接的socket接收数据 返回的是从socket中接收的字节数
            $byte=socket_recv($v, $buff,20480, 0);
            //如果接收的字节是0
            if($byte<7)
              continue;
            //判断有没有握手没有握手则进行握手,如果握手了 则进行处理
            if(!$this->hand[(int)$client]){
              //进行握手操作
              $this->hands($client,$buff,$v);
            }else{
              //处理数据操作
              $mess=$this->decodeData($buff);
                //发送数据
              $this->send($mess,$v);
            }
          }
        }
      }
    }

   

4、進行握手流程是接收websocket內容從Sec-WebSocket-Key:中獲取key並透過加密演算法寫入緩衝區客戶端會進行驗證(自動驗證我們不需要我們處理)

public function hands($client,$buff,$v)
    {
      //提取websocket传的key并进行加密 (这是固定的握手机制获取Sec-WebSocket-Key:里面的key)
      $buf = substr($buff,strpos($buff,&#39;Sec-WebSocket-Key:&#39;)+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";
      //将套接字写入缓冲区
      socket_write($v,$new_message,strlen($new_message));
      // socket_write(socket,$upgrade.chr(0), strlen($upgrade.chr(0)));
      //标记此套接字握手成功
      $this->hand[(int)$client]=true;
    }

   

5、解析客戶端的資料(我這裡沒有加密,如果有需要也可以自己加密)

//解析数据
    public function decodeData($buff)
    {
      //$buff 解析数据帧
      $mask = array();
      $data = &#39;&#39;;
      $msg = unpack(&#39;H*&#39;,$buff); //用unpack函数从二进制将数据解码
      $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));
          //遇到的问题 刚连接的时候就发送数据 显示 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++;
        }
        //发送数据到客户端
          //如果长度大于125 将数据分块
          $block=str_split($data,125);
          $mess=array(
            &#39;mess&#39;=>$block[0],
            );
        return $mess;         
      }

   

7、運行方法

github位址git@github.com:rsaLive/websocket.git

①最好在控制台運行server.php

server.php腳本目錄(可以先轉到phpv看下有沒有設定php如果沒有Linux設定下bash windows 設定下path)

php -f server.php

如果有錯誤會提示

php基於websocket搭建簡易聊天室實踐

php基於websocket搭建簡易聊天室實踐8、踩過的坑,打開調試工作方便查看錯誤

①server.php 掛起的進程中可以打印輸出的,如果出現問題可以在代碼中加入打印來調試

可以在各個判斷裡面做標記在控制台查看程式碼運行在哪個區間php基於websocket搭建簡易聊天室實踐

不過每次修改完程式碼之後需要重新運行腳本php server.php

php基於websocket搭建簡易聊天室實踐②如果出現這種錯誤可能是

1、在與伺服器初始套接字的時候發送資料(在第一次與伺服器驗證握手的時候不能發送內容)

2、如果已經驗證過了但是客戶端沒有發送或發送的訊息為空也會出現這樣的情況

所以要檢驗已連接的套接字的資料

php基於websocket搭建簡易聊天室實踐

③可能浏览器不支持或者服务端没有开启socket开始之前最好验证下

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

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持PHP中文网。

更多php基於websocket搭建簡易聊天室實踐相关文章请关注PHP中文网!

陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您聽不到任何人,如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解鎖Myrise中的所有內容
3 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

EditPlus 中文破解版

EditPlus 中文破解版

體積小,語法高亮,不支援程式碼提示功能

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SecLists

SecLists

SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

這個專案正在遷移到osdn.net/projects/mingw的過程中,你可以繼續在那裡關注我們。 MinGW:GNU編譯器集合(GCC)的本機Windows移植版本,可自由分發的導入函式庫和用於建置本機Windows應用程式的頭檔;包括對MSVC執行時間的擴展,以支援C99功能。 MinGW的所有軟體都可以在64位元Windows平台上運作。

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強大的PHP整合開發環境