经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » PHP » 查看文章
WebSocket 长连接 及超时问题解决
来源：cnblogs　　作者：Sorr　　时间：2019/1/14 10:00:23　　对本文有异议 
  1. <?php
    set_time_limit(0);
  2. class SocketService
  3. {
  4.     private $address  = 'localhost';
  5.     private $port = 80;
  6.     private $_sockets;
  7.     public function __construct($address = '', $port='')
  8.     {
  9.         if(!empty($address)){
  10.             $this->address = $address;
  11.         }
  12.         if(!empty($port)) {
  13.             $this->port = $port;
  14.         }
  15.     }
  17.     public function service(){
  18.         //获取tcp协议号码。
  19.         $tcp = getprotobyname("SOL_TCP");           # 获取与协议名称关联的协议号
  20.         $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);  # 创建一个套接字（通讯节点）
  21.         socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);  # 设置套接字选项
  22.         if($sock < 0)
  23.         {
  24.             throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
  25.         }
  26.         socket_bind($sock, $this->address, $this->port);    # 绑定
  27.         socket_listen($sock, $this->port);      # 监听套接字上的连接
  28.         $this->_sockets = $sock;   
  29.     }
  31.     public function run(){
  32.         $this->service();
  33.         $clients[] = $this->_sockets;   # 数组存储 每个socket
  34.         # 让服务器无限获取客户端传过来的信息
  35.         while (true){
  36.             $changes = $clients;
  37.             $write = NULL;
  38.             $except = NULL;
  39.             socket_select($changes,  $write,  $except, NULL);
  40.             foreach ($changes as $key => $_sock){
  41.                 if($this->_sockets == $_sock){  # 判断是不是新接入的socket
  42.                     if(($newClient = socket_accept($_sock))  === false){    # 接受新的套接字上的连接   socket_accept的作用就是接受socket_bind()所绑定的主机发过来的套接流
  43.                         die('failed to accept socket: '.socket_strerror($_sock)."\n");  # 返回描述套接字错误的字符串
  44.                     }
  45.                     $line = trim(socket_read($newClient, 1024));  # 读取客户端传过来的资源，并转化为字符串     socket_read的作用就是读出socket_accept()的资源并把它转化为字符串
  46.                     $this->handshaking($newClient, $line);
  47.                     //获取client ip
  48.                     socket_getpeername ($newClient, $ip);                                   # 查询给定套接字的远程端，这可能导致主机/端口或UNIX文件系统路径，具体取决于其类型。
  49.                     $clients[$ip] = $newClient;
  50.                 } else {
  51.                     # 读取该socket的信息，注意：第二个参数是引用传参即接收数据，第三个参数是接收数据的长度
  52.                     $lenght = socket_recv($_sock, $buffer,  2048, 0);               # 从已连接的socket接收数据   $lenght 接收到字符串长度
  53.                     $msg = $this->message($buffer);          # 接收到的信息
  54.                     //在这里业务代码
  55.                     fwrite(STDOUT, 'Please input a argument:');
  56.                     $response = trim(fgets(STDIN));
  57. //                    $this->send($_sock, $response);                                                       # 第二个参数是获取数据    要发送的信息
  58.                     $this->send($_sock, '在线');
  59.                 }
  60.             }
  61.         }
  62.     }
  64.     /**
  65.      * 握手处理
  66.      * @param $newClient socket
  67.      * @return int  接收到的信息
  68.      */
  69.     public function handshaking($newClient, $line){
  70.         $headers = array();
  71.         $lines = preg_split("/\r\n/", $line);   # 通过一个正则表达式分隔字符串。
  72.         foreach($lines as $line)
  73.         {
  74.             $line = chop($line);    # 移除字符串右端的空白字符或其他预定义字符
  75.             if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
  76.             {
  77.                 $headers[$matches[1]] = $matches[2];
  78.             }
  79.         }
  80.         $secKey = $headers['Sec-WebSocket-Key'];
  81.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
  82.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
  83.             "Upgrade: websocket\r\n" .
  84.             "Connection: Upgrade\r\n" .
  85.             "WebSocket-Origin: $this->address\r\n" .
  86.             "WebSocket-Location: ws://$this->address:$this->port/服务器地址\r\n".
  87.             "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
  88.         return socket_write($newClient, $upgrade, strlen($upgrade));    # socket_write的作用是向socket_create的套接流写入信息，或者向socket_accept的套接流写入信息
  89.     }
  91.     /**
  92.      * 解析接收数据
  93.      * @param $buffer
  94.      * @return null|string
  95.      */
  96.     public function message($buffer){
  97.         $len = $masks = $data = $decoded = null;
  98.         $len = ord($buffer[1]) & 127;
  99.         if ($len === 126)  {
  100.             $masks = substr($buffer, 4, 4);
  101.             $data = substr($buffer, 8);
  102.         } else if ($len === 127)  {
  103.             $masks = substr($buffer, 10, 4);
  104.             $data = substr($buffer, 14);
  105.         } else  {
  106.             $masks = substr($buffer, 2, 4);
  107.             $data = substr($buffer, 6);
  108.         }
  109.         for ($index = 0; $index < strlen($data); $index++) {
  110.             $decoded .= $data[$index] ^ $masks[$index % 4];
  111.         }
  112.         return $decoded;
  113.     }
  115.     /**
  116.      * 发送数据
  117.      * @param $newClinet 新接入的socket
  118.      * @param $msg   要发送的数据
  119.      * @return int|string
  120.      */
  121.     public function send($newClinet, $msg){
  122.         $msg = $this->frame($msg);
  123.         socket_write($newClinet, $msg, strlen($msg));   # 写入套接字
  124.     }
  126.     public function frame($s) {
  127.         $a = str_split($s, 125);    # 把字符串分割到数组中 第二个长度参数
  128.         if (count($a) == 1) {
  129.             return "\x81" . chr(strlen($a[0])) . $a[0];
  130.         }
  131.         $ns = "";
  132.         foreach ($a as $o) {
  133.             $ns .= "\x81" . chr(strlen($o)) . $o;
  134.         }
  135.         return $ns;
  136.     }
  138.     /**
  139.      * 关闭socket
  140.      */
  141.     public function close(){
  142.         # socket_close的作用是关闭socket_create()或者socket_accept()所建立的套接流
  143.         return socket_close($this->_sockets);
  144.     }
  145. }
  147. $sock = new SocketService();
  148. $sock->run();

 

网上看到很多说会断开链接,设置心跳包也没有用

我这里直接配置了下 set_time_limit(0);　　 改变 php.ini中的 max_execution_time设置时间 然后就没有断线的问题了! 也保证了持久连接!

 

HTML部分

  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4.     <title>Socket 测试</title>
  5.     <meta charset="utf-8">
  6.     <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
  7.     <link href="https://cdn.bootcss.com/bootstrap/3.3.2/css/bootstrap.min.css" rel="stylesheet">

     <style type="text/css">
            html, body {
                min-height: 100%; }

            body {
                margin: 0;
                padding: 0;
                width: 100%;
                font-family: "Microsoft Yahei",sans-serif, Arial; }

            .container {
                text-align: center; }

            .title {
                font-size: 16px;
                color: rgba(0, 0, 0, 0.3);
                position: fixed;
                line-height: 30px;
                height: 30px;
                left: 0px;
                right: 0px;
                background-color: white; }

            .content {
                background-color: #f1f1f1;
                border-top-left-radius: 6px;
                border-top-right-radius: 6px;
                margin-top: 30px; }
            .content .show-area {
                text-align: left;
                padding-top: 8px;
                padding-bottom: 168px; }
            .content .show-area .message {
                width: 70%;
                padding: 5px;
                word-wrap: break-word;
                word-break: normal; }
            .content .write-area {
                position: fixed;
                bottom: 0px;
                right: 0px;
                left: 0px;
                background-color: #f1f1f1;
                z-index: 10;
                width: 100%;
                height: 160px;
                border-top: 1px solid #d8d8d8; }
            .content .write-area .send {
                position: relative;
                top: -28px;
                height: 28px;
                border-top-left-radius: 55px;
                border-top-right-radius: 55px; }
            .content .write-area #name{
                position: relative;
                top: -20px;
                line-height: 28px;
                font-size: 13px; }
        </style>
  8. </head>
  9. <body>
  10. <div class="container">
  11.     <div class="title">Socket 测试长连接</div>
  12.     <div class="content">
  13.         <div class="show-area"></div>
  14.         <div class="write-area">
  15.             <div><button class="btn btn-default send" >发送</button></div>
  16.             <div><input name="name" id="name" type="text" placeholder="input your name"></div>
  17.             <div>
  18.                 <textarea name="message" id="message" cols="38" rows="4" placeholder="input your message..."></textarea>
  19.             </div>
  20.         </div>
  21.     </div>
  22. </div>
  23.  
  24. <script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>
  25. <script src="https://cdn.bootcss.com/bootstrap/3.3.2/js/bootstrap.min.js"></script>
  26. <script>
  27.         var wsurl = 'ws://localhost:80/websocket/test2.php';
  28.         var websocket;
  29.         websocket = new WebSocket(wsurl);
  30.             //连接建立
  31.             websocket.onopen = function(evevt){
  32.                 console.log("Connected to WebSocket server.");
  33.                 $('.show-area').append('<p class="bg-info message"><i class="glyphicon glyphicon-info-sign"></i>Connected to WebSocket server!</p>');
  34.             }
  35.             //收到消息
  36.             websocket.onmessage = function(event) {
  37.                 console.log(event);
  38.                 $('.show-area').append('<p class="bg-info message"><i class="glyphicon glyphicon-info-sign"></i>'+event.data+'</p>');
  39.             }
  41.             //发生错误
  42.             websocket.onerror = function(event){
  43.                 console.log("Connected to WebSocket server error");
  44.                 $('.show-area').append('<p class="bg-danger message"><a name=""></a><i class="glyphicon glyphicon-info-sign"></i>Connect to WebSocket server error.</p>');
  45.             }
  47.             //连接关闭
  48.             websocket.onclose = function(event){
  49.                 console.log('websocket Connection Closed. ');
  50.                 $('.show-area').append('<p class="bg-warning message"><a name=""></a><i class="glyphicon glyphicon-info-sign"></i>websocket Connection Closed.</p>');
  51.             }
  53.     // 发送信息
  54.             function send(){
  55.                 var name = $('#name').val();
  56.                 var message = $('#message').val();
  57.                 if(!name){
  58.                     alert('请输入用户名!');
  59.                     return false;
  60.                 }
  61.                 if(!message){
  62.                     alert('发送消息不能为空!');
  63.                     return false;
  64.                 }
  65.                  var msg = {
  66.                      message: message,
  67.                      name: name
  68.                  };
  69.                 try{
  70.                      websocket.send(JSON.stringify(msg));
  71.                 } catch(ex) {
  72.                     console.log(ex);
  73.                 }
  74.             }
  75.             //点发送按钮发送消息
  76.             $('.send').bind('click',function(){
  77.                 send();
  78.             });
  80. </script>
  81. </body>
  82. </html>

 

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

PHP热门文章

  • 收藏了8年的PHP优秀资源，都给你整理好了
  • php对微信支付回调处理的方法（合集）
  • 聊聊TCP连接耗时的那些事儿
  • php如何比较两个浮点数是否相等详解
  • PHP实现PDO操作mysql存储过程示例
  • 富文本编辑器新增导入word功能，自动转为html，可直接显示图片
  • curl put方式上传文件
  • thinkphp3.2模块名如何不区分大小写?
  • php去掉字符串的最后一个字符
  • WebSocket 长连接 及超时问题解决

    • PHP推荐文章

  • 【workerman】uniapp+thinkPHP5使用GatewayWorker实现实时通讯
  • PHP转Go系列 | ThinkPHP与Gin框架之API接口签名设计实践
  • MagicArray:像php一样，让Go业务代码不再卷！
  • 2023年的PHP项目部署笔记。什么？还有人用PHP？
  • [CTF/Web] PHP 反序列化学习笔记
  • PHP的序列化和反序列化入门
  • 详解PHP实现HTTP服务器过程
  • 高效率开发Web安全扫描器之路（一）
  • PHP实现微信扫码登录功能的两种方式总结
  • PHP内存溢出的解决方法详解

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号