登录  /  注册
首页 > php教程 > php手册 > 正文

Websocket协议之php实现

php中文网
发布： 2016-06-06 19:40:55
原创
1947人浏览过

前面学习了HTML5中websocket的握手 协议 、打开和关闭连接等基础内容，最近用php 实现 了与浏览器websocket的双向通信。在学习概念的时候觉得看懂了的内容，真正在实践过程中还是会遇到各种问题，网上也有一些关于php的websocket的 实现 ，但是只有自己亲手

前面学习了html5中websocket的握手协议、打开和关闭连接等基础内容，最近用php实现了与浏览器websocket的双向通信。在学习概念的时候觉得看懂了的内容，真正在实践过程中还是会遇到各种问题，网上也有一些关于php的websocket的实现，但是只有自己亲手写过之后才知道其中的感受。其中，google有一个开源的phpwebsocket类（https://code.google.com/p/phpwebsocket/），但是从其握手过程中可以明显看出，这还是最初的websocket协议，请求头中使用了两个key，并非version 13（现行版本）。下面是本人实践过程，同时封装好了一个现行版本的php实现的实用的websocket类。

一、握手

1、客户端发送请求

websocket协议提供给javascript的API就是特别简洁易用。

Websocket协议之php实现View Code

 

先看效果，客户端和服务器端握手的结果如下：

Websocket协议之php实现

Websocket协议之php实现

2、服务器端

封装的类为WebSocket，address和port为类的属性。

（1）建立socket并监听

<span> 1</span>     <span>function</span><span> createSocket()
</span><span> 2</span> <span>    {
</span><span> 3</span>         $<span>this</span>-&gt;master=<span>socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
</span><span> 4</span>             or die("socket_create() failed:"<span>.socket_strerror(socket_last_error()));
</span><span> 5</span>             
<span> 6</span>         socket_set_option($<span>this</span>-&gt;master, SOL_SOCKET, SO_REUSEADDR, 1<span>)
</span><span> 7</span>             or die("socket_option() failed"<span>.socket_strerror(socket_last_error()));
</span><span> 8</span>             
<span> 9</span>         socket_bind($<span>this</span>-&gt;master, $<span>this</span>-&gt;address, $<span>this</span>-&gt;<span>port)
</span><span>10</span>             or die("socket_bind() failed"<span>.socket_strerror(socket_last_error()));
</span><span>11</span>             
<span>12</span>         socket_listen($<span>this</span>-&gt;master,20<span>)
</span><span>13</span>             or die("socket_listen() failed"<span>.socket_strerror(socket_last_error()));
</span><span>14</span>         
<span>15</span>         $<span>this</span>-&gt;say("Server Started : ".date('Y-m-d H:i:s'<span>));
</span><span>16</span>         $<span>this</span>-&gt;say("Master socket  : ".$<span>this</span>-&gt;<span>master);
</span><span>17</span>         $<span>this</span>-&gt;say("Listening on   : ".$<span>this</span>-&gt;address." port ".$<span>this</span>-&gt;port."\n"<span>);
</span><span>18</span>         
<span>19</span>     }
登录后复制

 

然后启动监听，同时要维护连接到服务器的用户的一个数组（连接池），每连接一个用户，就要push进一个，同时关闭连接后要删除相应的用户的连接。

<span> 1</span>     public <span>function</span><span> __construct($a, $p)
</span><span> 2</span> <span>    {
</span><span> 3</span>         <span>if</span> ($a == 'localhost'<span>)
</span><span> 4</span>             $<span>this</span>-&gt;address =<span> $a;
</span><span> 5</span>         <span>else</span> <span>if</span> (preg_match('/^[\d\.]*$/is'<span>, $a))
</span><span> 6</span>             $<span>this</span>-&gt;address =<span> long2ip(ip2long($a));
</span><span> 7</span>         <span>else</span>
<span> 8</span>             $<span>this</span>-&gt;address =<span> $p;
</span><span> 9</span>         
<span>10</span>         <span>if</span> (is_numeric($p) &amp;&amp; intval($p) &gt; 1024 &amp;&amp; intval($p) )
<span>11</span>             $<span>this</span>-&gt;port =<span> $p;
</span><span>12</span>         <span>else</span>
<span>13</span>             die ("Not valid port:"<span> . $p);
</span><span>14</span>         
<span>15</span>         $<span>this</span>-&gt;<span>createSocket();
</span><span>16</span>         array_push($<span>this</span>-&gt;sockets, $<span>this</span>-&gt;<span>master);
</span><span>17</span>     }
登录后复制

（2）建立连接

维护用户的连接池

<span>1</span>     public <span>function</span><span> connect($clientSocket)
</span><span>2</span> <span>    {
</span><span>3</span>         $user = <span>new</span><span> User();
</span><span>4</span>         $user-&gt;id =<span> uniqid();
</span><span>5</span>         $user-&gt;socket =<span> $clientSocket;
</span><span>6</span>         array_push($<span>this</span>-&gt;<span>users,$user);
</span><span>7</span>         array_push($<span>this</span>-&gt;<span>sockets,$clientSocket);
</span><span>8</span>         $<span>this</span>-&gt;log($user-&gt;socket . " CONNECTED!" . date("Y-m-d H-i-s"<span>));
</span><span>9</span>     }
登录后复制

（3）回复响应头

首先要获取请求头，从中取出Sec-Websocket-Key，同时还应该取出Host、请求方式、Origin等，可以进行安全检查，防止未知的连接。

<span> 1</span>     public <span>function</span><span> getHeaders($req)
</span><span> 2</span> <span>    {
</span><span> 3</span>         $r = $h = $o = <span>null</span><span>;
</span><span> 4</span>         <span>if</span>(preg_match("/GET (.*) HTTP/"<span>   , $req, $match))
</span><span> 5</span>             $r = $match[1<span>];
</span><span> 6</span>         <span>if</span>(preg_match("/Host: (.*)\r\n/"<span>  , $req, $match))
</span><span> 7</span>             $h = $match[1<span>];
</span><span> 8</span>         <span>if</span>(preg_match("/Origin: (.*)\r\n/"<span>, $req, $match))
</span><span> 9</span>             $o = $match[1<span>];
</span><span>10</span>         <span>if</span>(preg_match("/Sec-WebSocket-Key: (.*)\r\n/"<span>, $req, $match))
</span><span>11</span>             $key = $match[1<span>];
</span><span>12</span>             
<span>13</span>         <span>return</span><span> array($r, $h, $o, $key);
</span><span>14</span>     }
登录后复制

之后是得到key然后进行websocket协议规定的加密算法进行计算，返回响应头，这样浏览器验证正确后就握手成功了。这里涉及的详细解析信息过程参见另一篇博文http://blog.csdn.net/u010487568/article/details/20569027

<span> 1</span>     protected <span>function</span> wrap($msg="", $opcode = 0x1<span>)
</span><span> 2</span> <span>    {
</span><span> 3</span>         <span>//</span><span>默认控制帧为0x1（文本数据）</span>
<span> 4</span>         $firstByte = 0x80 |<span> $opcode;
</span><span> 5</span>         $encodedata = <span>null</span><span>;
</span><span> 6</span>         $len =<span> strlen($msg);
</span><span> 7</span>         
<span> 8</span>         <span>if</span> (0 )
<span> 9</span>             $encodedata = chr(0x81<span>) . chr($len) . $msg;
</span><span>10</span>         <span>else</span> <span>if</span> (126 )
<span>11</span> <span>        {
</span><span>12</span>             $low = $len &amp; 0x00FF<span>;
</span><span>13</span>             $high = ($len &amp; 0xFF00) &gt;&gt; 8<span>;
</span><span>14</span>             $encodedata = chr($firstByte) . chr(0x7E<span>) . chr($high) . chr($low) . $msg;
</span><span>15</span> <span>        }
</span><span>16</span>         
<span>17</span>         <span>return</span><span> $encodedata;            
</span><span>18</span>     }
登录后复制

其中我只实现了发送数据长度在2的16次方以下个字符的情况，至于长度为8个字节的超大数据暂未考虑。

<span> 1</span>      private <span>function</span><span> doHandShake($user, $buffer)
</span><span> 2</span> <span>     {
</span><span> 3</span>         $<span>this</span>-&gt;log("\nRequesting handshake..."<span>);
</span><span> 4</span>         $<span>this</span>-&gt;<span>log($buffer);
</span><span> 5</span>         list($resource, $host, $origin, $key) = $<span>this</span>-&gt;<span>getHeaders($buffer);
</span><span> 6</span>         
<span> 7</span>         <span>//</span><span>websocket version 13</span>
<span> 8</span>         $acceptKey = base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', <span>true</span><span>));
</span><span> 9</span>         
<span>10</span>         $<span>this</span>-&gt;log("Handshaking..."<span>);
</span><span>11</span>         $upgrade  = "HTTP/1.1 101 Switching Protocol\r\n"<span> .
</span><span>12</span>                     "Upgrade: websocket\r\n"<span> .
</span><span>13</span>                     "Connection: Upgrade\r\n"<span> .
</span><span>14</span>                     "Sec-WebSocket-Accept: " . $acceptKey . "\r\n\r\n";  <span>//</span><span>必须以两个回车结尾</span>
<span>15</span>         $<span>this</span>-&gt;<span>log($upgrade);
</span><span>16</span>         $sent = socket_write($user-&gt;<span>socket, $upgrade, strlen($upgrade));
</span><span>17</span>         $user-&gt;handshake=<span>true</span><span>;
</span><span>18</span>         $<span>this</span>-&gt;log("Done handshaking..."<span>);
</span><span>19</span>         <span>return</span> <span>true</span><span>;
</span><span>20</span>     }
登录后复制

二、数据传输

1、客户端

客户端websocket的API非常容易，直接使用websocket对象的send方法即可。

<span>1</span> ws.send(message);
登录后复制

2、服务器端

客户端发送的数据是经过浏览器支持的websocket进行了mask处理的，而根据规定服务器端返回的数据不能进行掩码处理，但是需要按照协议的数据帧规定进行封装后发送。因此服务器需要接收数据必须将接收到的字节流进行解码。

<span> 1</span>     protected <span>function</span> unwrap($clientSocket, $msg=""<span>)
</span><span> 2</span> <span>    { 
</span><span> 3</span>         $opcode = ord(substr($msg, 0, 1)) &amp; 0x0F<span>;
</span><span> 4</span>         $payloadlen = ord(substr($msg, 1, 1)) &amp; 0x7F<span>;
</span><span> 5</span>         $ismask = (ord(substr($msg, 1, 1)) &amp; 0x80) &gt;&gt; 7<span>;
</span><span> 6</span>         $maskkey = <span>null</span><span>;
</span><span> 7</span>         $oridata = <span>null</span><span>;
</span><span> 8</span>         $decodedata = <span>null</span><span>;
</span><span> 9</span>         
<span>10</span>         <span>//</span><span>关闭连接</span>
<span>11</span>         <span>if</span> ($ismask != 1 || $opcode == 0x8<span>)
</span><span>12</span> <span>        {
</span><span>13</span>             $<span>this</span>-&gt;<span>disconnect($clientSocket);
</span><span>14</span>             <span>return</span> <span>null</span><span>;
</span><span>15</span> <span>        }
</span><span>16</span>         
<span>17</span>         <span>//</span><span>获取掩码密钥和原始数据</span>
<span>18</span>         <span>if</span> ($payloadlen = 0<span>)
</span><span>19</span> <span>        {
</span><span>20</span>             $maskkey = substr($msg, 2, 4<span>);
</span><span>21</span>             $oridata = substr($msg, 6<span>);
</span><span>22</span> <span>        }
</span><span>23</span>         <span>else</span> <span>if</span> ($payloadlen == 126<span>)
</span><span>24</span> <span>        {
</span><span>25</span>             $maskkey = substr($msg, 4, 4<span>);
</span><span>26</span>             $oridata = substr($msg, 8<span>);
</span><span>27</span> <span>        }
</span><span>28</span>         <span>else</span> <span>if</span> ($payloadlen == 127<span>)
</span><span>29</span> <span>        {
</span><span>30</span>             $maskkey = substr($msg, 10, 4<span>);
</span><span>31</span>             $oridata = substr($msg, 14<span>);
</span><span>32</span> <span>        }
</span><span>33</span>         $len =<span> strlen($oridata);
</span><span>34</span>         <span>for</span>($i = 0; $i )
<span>35</span> <span>        {
</span><span>36</span>             $decodedata .= $oridata[$i] ^ $maskkey[$i % 4<span>];
</span><span>37</span> <span>        }        
</span><span>38</span>         <span>return</span><span> $decodedata; 
</span><span>39</span>     }
登录后复制

其中得到掩码和控制帧后需要进行验证，如果掩码不为1直接关闭，如果控制帧为8也直接关闭。后面的原始数据和掩码获取是通过websocket协议的数据帧规范进行的。

效果如下

Websocket协议之php实现
Websocket协议之php实现
数据交互的过程非常的直接，其中“u”是服务器发送给客户端的，然后客户端发送一段随机字符串给服务器。

三、连接关闭

1、客户端

<span>1</span> ws.close();
登录后复制

2、服务器端

需要将维护的用户连接池移除相应的连接用户。

<span> 1</span>     public <span>function</span><span> disconnect($clientSocket)
</span><span> 2</span> <span>    {
</span><span> 3</span>         $found = <span>null</span><span>;
</span><span> 4</span>         $n = count($<span>this</span>-&gt;<span>users);
</span><span> 5</span>         <span>for</span>($i = 0; $i)
<span> 6</span> <span>        {
</span><span> 7</span>             <span>if</span>($<span>this</span>-&gt;users[$i]-&gt;socket ==<span> $clientSocket)
</span><span> 8</span> <span>            { 
</span><span> 9</span>                 $found =<span> $i;
</span><span>10</span>                 <span>break</span><span>;
</span><span>11</span> <span>            }
</span><span>12</span> <span>        }
</span><span>13</span>         $index = array_search($clientSocket,$<span>this</span>-&gt;<span>sockets);
</span><span>14</span>         
<span>15</span>         <span>if</span>(!<span>is_null($found))
</span><span>16</span> <span>        { 
</span><span>17</span>             array_splice($<span>this</span>-&gt;users, $found, 1<span>);
</span><span>18</span>             array_splice($<span>this</span>-&gt;sockets, $index, 1<span>); 
</span><span>19</span>             
<span>20</span> <span>            socket_close($clientSocket);
</span><span>21</span>             $<span>this</span>-&gt;say($clientSocket." DISCONNECTED!"<span>);
</span><span>22</span> <span>        }
</span><span>23</span>     }
登录后复制

其中遇到的一个问题就是，如果将上述函数中的socket_close语句提出到if语句外面的时候，当浏览器连接到服务器后，F5刷新页面后会发现出错：

Websocket协议之php实现

后来发现是重复关闭socket了，这个是因为在unwrap函数中遇到了控制帧直接关闭的原因。因此需要注意浏览器已经连接后进行刷新的操作。最后提供整个封装好的类，https://github.com/OshynSong/web/blob/master/websocket.class.php

 

智能AI问答
PHP中文网智能助手能迅速回答你的编程问题，提供实时的代码和解决方案，帮助你解决各种难题。不仅如此，它还能提供编程资源和学习指导，帮助你快速提升编程技能。无论你是初学者还是专业人士，AI智能助手都能成为你的可靠助手，助力你在编程领域取得更大的成就。
我要提问
来源：php中文网
收藏 点赞
上一篇：php实现表单多按钮提交action的处理方法 下一篇：php连接数据库失败，数据源也加上了还是出错，求大神破解
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
子窗口操作父窗口，输出没反应 前两句可执行，最后一句没法应
P粉722478067来自于2024-04-19 15:37:47
0 0 28
父窗口没有输出 document.onclick = function(){ window.opener.document.write('我是子窗口的输出');  &nb...
P粉722478067来自于2024-04-18 23:52:34
0 0 51
关于CSS思维导图的课件在哪？ 课件
凡人来自于2024-04-16 10:10:18
0 0 139
PX自动转换为REM错误  <style>html {   font-size: calc(100vw / 3.75);      }...
凡人来自于2024-04-16 09:34:16
0 0 820
PHP数组从URL参数中获取的行为不如预期 我有一个包含类别ID的URL参数，我想将其视为一个数组，如下所示：http://example.com?cat[]=3,9,13在PHP中，我使用它从URL参数获取数组：$catI...
P粉785905797来自于2024-04-06 22:09:02
0 1 443
通过添加 Width 属性将内容向左移动 我已经为主体提供了边距。主要{左边缘：200px;右边距：200px；文本对齐：居中}由于我想以两行而不是一行显示文本，因此我在样式中添加了width属性。.p{字体大小：12px...
P粉738046172来自于2024-04-06 22:01:35
0 2 322
我应该在 apache 中哪里放置 CustomLog 指令 我正在使用php:7.2-apachedocker。我需要禁用运行状况检查url登录访问日志。基于此链接，他们提到了有关修改Customlog指令的信息。我不是关于需要更改Cust...
P粉573809727来自于2024-04-06 22:03:59
0 1 445
返回值中变量的格式是什么？ 我是php的新学习者。我发现有一段代码：if($x<time()){return[false,'error'];}逻辑或变量并不重要，但我不明白[false,'error']...
P粉757556355来自于2024-04-06 21:55:20
0 1 267
页面突然无法拉动 css 或 bootstrap 所以我正在开发一个页面，我昨天做了一部分，效果很好，今天我继续做剩下的部分，一切都很好。当我尝试将其作为普通html页面打开时，CSS或BOOTSTRAP不起作用，仅显示页面文本，...
P粉771233336来自于2024-04-06 21:58:04
0 1 358
如何在 React 中的排序方法上触发渲染（带有过滤器和分页）？ 这是我的Sort.js样式组件：<SortWrapper><SortText>SortBy</SortText><SortSelecton...
P粉970736384来自于2024-04-06 21:28:37
0 1 1864
相关专题
更多>
热门推荐
热门教程
更多>
相关推荐
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
app下载
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • 精品班

  • 技术支持

  • 技术咨询

  • 学习群

  • 会员优惠

  • 返回顶部