linuxsir首页 LinuxSir.Org | Linux、BSD、Solaris、Unix | 开源传万世,因有我参与欢迎您!
网站首页 | 设为首页 | 加入收藏
您所在的位置:主页 > Limux发行版SuSE >

PHP+WebSocket搭建简易聊天室实践

时间:2016-11-01  来源:未知  作者:linuxsir首页

1、前言

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

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

  本文主要介绍websocket简易聊天室的实现步骤具体部分知识点的深入会给出链接或者麻烦读者自己搜集资料。

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

  3.1websocket连接过程

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

  

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

  

     

3.2 代码实践

  服务端做的流程大致是:

    ①、挂起一个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);

        } 

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

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,'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";
            //将套接字写入缓冲区
            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 = '';  
            $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、将套接字写入缓冲区

复制代码
//发送数据
        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、运行方法

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

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

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

php -f server.php

如果有错误会提示

②通过服务器访问html文件

 

 8、踩过的坑,打开调试工作方便查看错误

server.php 挂起的进程中可以打印输出的,如果出现问题可以在代码中加入打印来调试 

可以在各个判断里面做标记在控制台查看代码运行在哪个区间

不过每次修改完代码之后需要重新运行脚本 php server.php

如果出现这种错误可能是

  1、在与服务器初始套接字的时候发送数据 (在第一次与服务器验证握手的时候不能发送内容)

  2、如果已经验证过了但是客户端没有发送或者发送的消息为空也会出现这样的情况

    所以要检验已连接的套接字的数据

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

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

如有不正欢迎指出

 

linux
友情链接
  • Mozilla发布Firefox 67.0.4,修复沙箱逃逸漏洞
  • 蚂蚁金服正式成为CNCF云原生计算基金会黄金会员
  • Firefox 68将采用Microsoft BITS安装更新
  • OpenSSH增加对存储在RAM中的私钥的保护
  • 谷歌想实现自己的curl,为什么?
  • Raspberry Pi 4发布:更快的CPU、更大的内存
  • Firefox的UA将移除CPU架构信息
  • Ubuntu放弃支持32位应用程序实属乌龙,Steam会否重回Ubuntu怀抱
  • Qt 5.13稳定版发布:引入glTF 2.0、改进Wayland以及支持Lottie动
  • 红帽企业Linux 7现已内置Redis 5最新版
  • Slack进入微软内部禁用服务清单,GitHub也在其列?
  • 安全的全新编程语言V发布首个可用版本
  • Windows Terminal已上架,快尝鲜
  • 阿里巴巴微服务开源生态报告No.1
  • 面世两年,Google地球将支持所有基于Chromium的浏览器
  • 推进企业容器化持续创新,Rancher ECIC千人盛典完美收官
  • CentOS 8.0最新构建状态公布,或于数周后发布
  • Debian移植RISC
  • 微软拆分操作系统的计划初现雏形
  • Oracle发布基于VS Code的开发者工具,轻松使用Oracle数据库
  • Ubuntu 19.10停止支持32位的x86架构
  • 微软为Windows Terminal推出全新logo
  • 联想ThinkPad P系列笔记本预装Ubuntu系统
  • 微软发布适用于Win7/8的Microsoft Edge预览版
  • 启智平台发布联邦学习开源数据协作项目OpenI纵横
  • 经过六个多月的延迟,微软终于推出Hyper
  • ZFS On Linux 0.8.1 发布,Python可移植性工作
  • DragonFly BSD 5.6.0 发布,HAMMER2状态良好
  • Linux Kernel 5.2
  • CentOS 8.0 看起来还需要几周的时间
  • 百度网盘Linux版正式发布
  • PCIe 6.0宣布:带宽翻倍 狂飙至256GB/s
  • PHP 7.4 Alpha 发布,FFI扩展,预加载Opcache以获得更好的性能
  • Canonical将在未来的Ubuntu版本中放弃对32位架构的支持
  • Scala 2.13 发布,改进的编译器性能
  • 微软的GitHub收购了Pull Panda,并且使所有订阅完全免费
  • Windows Subsystem for Linux 2 (WSL 2)现在适用于Windows 10用
  • Debian 10 “Buster”的RISC
  • MariaDB宣布发布MariaDB Enterprise Server 10.4
  • DXVK 1.2.2 发布,带来微小的CPU开销优化
  • DragonFlyBSD 5.6 RC1 发布,VM优化,默认为HAMMER2
  • PrimeNG 8.0.0 发布,支持Angular 8,FocusTrap等
  • GIMP 2.10.12 发布,一些有用的改进
  • 清华大学Anaconda 镜像服务即将恢复
  • Debian GNU/Linux 10 “Buster” 操作系统将于2019年7月6日发布
  • 时时彩论坛
  • 五星体育斯诺克
  • 北单比分直播
  • 河北11选5走势图
  • 福建体彩36选7开奖结果
  • 九龙图库下载