1、前言

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

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

　　如果想要详细了解websocket长连接的原理请看https://www.zhihu.com/question/20215561。

　　本文主要介绍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_mes