LeCMS
ClassCMS
Fastadmin
iCMS
PbootCMS
PHPCMS
易优CMS
YzmCMS
讯睿CMS
极致CMS
Wordpress
HkCMS
YznCMS
WellCMS
ThinkCMF
帝国CMS
SIYUCMS《PHP学习：php基于websocket搭建简易聊天室实践》要点：
本文介绍了PHP学习：php基于websocket搭建简易聊天室实践，希望对您有用。如果有疑问，可以联系我们。
本文实例讲述了php基于websocket搭建简易聊天室实践.分享给大家供大家参考.具体如下：
1、前言PHP学习
公司游戏里面有个简单的聊天室,了解了之后才知道是node+websocket做的,想想php也来做个简单的聊天室.于是搜集各种资料看文档、找实例自己也写了个简单的聊天室.PHP学习
http连接分为短连接和长连接.短连接一般可以用ajax实现,长连接就是websocket.短连接实现起来比较简单,但是太过于消耗资源.websocket高效不过兼容存在点问题.websocket是html5的资源PHP学习
2、前端PHP学习
前端实现websocket很简单直接PHP学习
//连接websocketvar ws = new WebSocket("ws://127.0.0.1:8000");//成功连接websoc的时候ws.onopen = function(){}//成功获取服务端输出的消息ws.onmessage = function(e){}//连接错误的时候ws.onerror = function(){}//向服务端发送数据ws.send();3、后台
PHP学习
websocket的难点主要在后台
PHP学习
3.1websocket连接过程
websocket 通信图解 这是一个简易的客户端和服务端的通信图解,php主要就做的就是接受加密key 并返回 其中完成套接字的创建和握手操作
PHP学习
PHP学习
下图是一张详细的服务端处理websocket的流程图
PHP学习
PHP学习
3.2 代码实践
PHP学习
服务端做的流程大致是：PHP学习
挂起一个socket套接字进程等待连接
有socket连接之后遍历套接字数组
没有握手的进行握手操作,如果已经握手则接收数据解析并写入缓冲区进行输出
下面是示例代码(我写的是一个类所以代码是根据函数分段的),文底给出github地址以及自己遇到的一些坑
1、首先是创建套接字
PHP学习
//建立套接字 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、将套接字放入数组
PHP学习
public function __construct($address,$port) { //建立套接字 $this->soc=$this->createSocket($address,$port); $this->socs=array($this->soc); }3、挂起进程遍历套接字数组,主要操作都是在这里面完成的
PHP学习
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并通过加密算法写入缓冲区客户端会进行验证(自动验证不需要我们处理)
PHP学习
public function hands($client,$buff,$v) { //提取websocket传的key并进行加密 (这是固定的握手机制获取Sec-WebSocket-Key:里面的key) $buf = substr($buff,strpos($buff,'Sec-WebSocket-Key:')+18); //去除换行空格字符 $key = trim(substr($buf,0,strpos($buf,"rn"))); //固定的加密算法 $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true)); $new_message = "HTTP/1.1 101 Switching Protocolsrn"; $new_message .= "Upgrade: websocketrn"; $new_message .= "Sec-WebSocket-Version: 13rn"; $new_message .= "Connection: Upgradern"; $new_message .= "Sec-WebSocket-Accept: " . $new_key . "rnrn"; //将套接字写入缓冲区 socket_write($v,$new_message,strlen($new_message)); // socket_write(socket,$upgrade.chr(0), strlen($upgrade.chr(0))); //标记此套接字握手成功 $this->hand[(int)$client]=true; }5、解析客户端的数据(我这里没有进行加密,如果有需要也可以自己加密 )
PHP学习
//解析数据 public function decodeData($buff) { //$buff 解析数据帧 $mask = array(); $data = ''; $msg = unpack('H*',$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( 'mess'=>$block[0], ); return $mess; }6、将套接字写入缓冲区
PHP学习
//发送数据 public function send($mess,$v) { //遍历套接字数组 成功握手的 进行数据群发 foreach ($this->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、运行方法PHP学习
github地址git@github.com:rsaLive/websocket.gitPHP学习
①最好在控制台运行server.phpPHP学习
转到server.php脚本目录(可以先php -v 看下有没有配置php如果没有Linux配置下bash windows 配置下path)PHP学习
php -f server.phpPHP学习
PHP学习
如果有错误会提示PHP学习
PHP学习
②通过服务器访问html文件PHP学习
PHP学习
PHP学习
8、踩过的坑,打开调试工作方便查看错误PHP学习
①server.php 挂起的进程中可以打印输出的,如果出现问题可以在代码中加入打印来调试PHP学习
可以在各个判断里面做标记在控制台查看代码运行在哪个区间PHP学习
不过每次修改完代码之后需要重新运行脚本 php server.phpPHP学习
②如果出现这种错误可能是PHP学习
PHP学习
1、在与服务器初始套接字的时候发送数据 (在第一次与服务器验证握手的时候不能发送内容)PHP学习
2、如果已经验证过了但是客户端没有发送或者发送的消息为空也会出现这样的情况PHP学习
所以要检验已连接的套接字的数据PHP学习
PHP学习
③可能浏览器不支持或者服务端没有开启socket开始之前最好验证下PHP学习
if (window.WebSocket){ console.log("This browser supports WebSocket!");} else { console.log("This browser does not support WebSocket.");}以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持维易PHP.PHP学习
转载请注明本页网址：
/jiaocheng/2957.html
希望以上内容对你有所帮助！如果还有其他问题，请随时提问。 各类知识收集 拥有多年CMS企业建站经验，对 iCMS， LeCMS， ClassCMS， Fastadmin， PbootCMS， PHPCMS， 易优CMS， YzmCMS， 讯睿CMS， 极致CMS， Wordpress， HkCMS， YznCMS， WellCMS， ThinkCMF， 等各类cms的相互转化，程序开发，网站制作，bug修复，程序杀毒，插件定制都可以提供最佳解决方案。
