php基于websocket搭建简易聊天室实践

发布时间：2020-12-12 21:48:29 所属栏目：PHP教程来源：网络整理

导读：本篇章节讲解php基于websocket搭建简易聊天室实践。供大家参考研究。具体如下： 1、前言公司游戏里面有个简单的聊天室，了解了之后才知道是node+websocket做的，想想php也来做个简单的聊天室。于是搜集各种资料看文档、找实例自己也写了个简单的聊

本篇章节讲解php基于websocket搭建简易聊天室实践。分享给大家供大家参考。具体如下：

1、前言

公司游戏里面有个简单的聊天室，了解了之后才知道是node+websocket做的，想想php也来做个简单的聊天室。于是搜集各种资料看文档、找实例自己也写了个简单的聊天室。

http连接分为短连接和长连接。短连接一般可以用ajax实现，长连接就是websocket。短连接实现起来比较简单，但是太过于消耗资源。websocket高效不过兼容存在点问题。websocket是html5的资源

2、前端

前端实现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的难点主要在后台

3.1websocket连接过程 websocket 通信图解这是一个简易的客户端和服务端的通信图解，php主要就做的就是接受加密key 并返回其中完成套接字的创建和握手操作

下图是一张详细的服务端处理websocket的流程图

3.2 代码实践

服务端做的流程大致是：

挂起一个socket套接字进程等待连接
有socket连接之后遍历套接字数组
没有握手的进行握手操作，如果已经握手则接收数据解析并写入缓冲区进行输出

下面是示例代码（我写的是一个类所以代码是根据函数分段的），文底给出github地址以及自己遇到的一些坑 1、首先是创建套接字

2、将套接字放入数组

soc=$this->createSocket($address,$port); $this->socs=array($this->soc);

3、挂起进程遍历套接字数组，主要操作都是在这里面完成的

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,$v); }else{ //处理数据操作 $mess=$this->decodeData($buff); //发送数据 $this->send($mess,$v); } } } } }

4、进行握手流程是接收websocket内容从Sec-WebSocket-Key:中获取key并通过加密算法写入缓冲区客户端会进行验证（自动验证不需要我们处理）

hand[(int)$client]=true; }

5、解析客户端的数据（我这里没有进行加密，如果有需要也可以自己加密）

$block[0],); return $mess; }

6、将套接字写入缓冲区

socs as $keys => $values) { //用系统分配的套接字资源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)); } }

7、运行方法

github地址

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

转到server.php脚本目录(可以先php -v 看下有没有配置php如果没有Linux配置下bash windows 配置下path)

php -f server.php