WebSocket 長連接 及超時問題解決

<?php
set_time_limit(0);
class SocketService
{
    private $address  = 'localhost';
    private $port = 80;
    private $_sockets;
    public function __construct($address = '', $port='')
    {
        if(!empty($address)){
            $this->address = $address;
        }
        if(!empty($port)) {
            $this->port = $port;
        }
    }

    public function service(){
        //獲取tcp協議號碼。
        $tcp = getprotobyname("SOL_TCP");           # 獲取與協議名稱關聯的協議號
        $sock = socket_create(AF_INET, SOCK_STREAM, $tcp);  # 創建一個套接字（通訊節點）
        socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);  # 設置套接字選項
        if($sock < 0)
        {
            throw new Exception("failed to create socket: ".socket_strerror($sock)."\n");
        }
        socket_bind($sock, $this->address, $this->port);    # 綁定
        socket_listen($sock, $this->port);      # 監聽套接字上的連接
        $this->_sockets = $sock;   
    }

    public function run(){
        $this->service();
        $clients[] = $this->_sockets;   # 數組存儲 每個socket
        # 讓服務器無限獲取客戶端傳過來的信息
        while (true){
            $changes = $clients;
            $write = NULL;
            $except = NULL;
            socket_select($changes,  $write,  $except, NULL);
            foreach ($changes as $key => $_sock){
                if($this->_sockets == $_sock){  # 判斷是不是新接入的socket
                    if(($newClient = socket_accept($_sock))  === false){    # 接受新的套接字上的連接   socket_accept的作用就是接受socket_bind()所綁定的主機發過來的套接流
                        die('failed to accept socket: '.socket_strerror($_sock)."\n");  # 返回描述套接字錯誤的字符串
                    }
                    $line = trim(socket_read($newClient, 1024));  # 讀取客戶端傳過來的資源，並轉化為字符串     socket_read的作用就是讀出socket_accept()的資源並把它轉化為字符串
                    $this->handshaking($newClient, $line);
                    //獲取client ip
                    socket_getpeername ($newClient, $ip);                                   # 查詢給定套接字的遠程端，這可能導致主機/端口或UNIX文件系統路徑，具體取決於其類型。
                    $clients[$ip] = $newClient;
                } else {
                    # 讀取該socket的信息，注意：第二個參數是引用傳參即接收數據，第三個參數是接收數據的長度
                    $lenght = socket_recv($_sock, $buffer,  2048, 0);               # 從已連接的socket接收數據   $lenght 接收到字符串長度
                    $msg = $this->message($buffer);          # 接收到的信息
                    //在這里業務代碼
                    fwrite(STDOUT, 'Please input a argument:');
                    $response = trim(fgets(STDIN));
//                    $this->send($_sock, $response);                                                       # 第二個參數是獲取數據    要發送的信息
                    $this->send($_sock, '在線');
                }
            }
        }
    }

    /**
     * 握手處理
     * @param $newClient socket
     * @return int  接收到的信息
     */
    public function handshaking($newClient, $line){
        $headers = array();
        $lines = preg_split("/\r\n/", $line);   # 通過一個正則表達式分隔字符串。
        foreach($lines as $line)
        {
            $line = chop($line);    # 移除字符串右端的空白字符或其他預定義字符
            if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
            {
                $headers[$matches[1]] = $matches[2];
            }
        }
        $secKey = $headers['Sec-WebSocket-Key'];
        $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
        $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
            "Upgrade: websocket\r\n" .
            "Connection: Upgrade\r\n" .
            "WebSocket-Origin: $this->address\r\n" .
            "WebSocket-Location: ws://$this->address:$this->port/服務器地址\r\n".
            "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
        return socket_write($newClient, $upgrade, strlen($upgrade));    # socket_write的作用是向socket_create的套接流寫入信息，或者向socket_accept的套接流寫入信息
    }

    /**
     * 解析接收數據
     * @param $buffer
     * @return null|string
     */
    public function message($buffer){
        $len = $masks = $data = $decoded = null;
        $len = ord($buffer[1]) & 127;
        if ($len === 126)  {
            $masks = substr($buffer, 4, 4);
            $data = substr($buffer, 8);
        } else if ($len === 127)  {
            $masks = substr($buffer, 10, 4);
            $data = substr($buffer, 14);
        } else  {
            $masks = substr($buffer, 2, 4);
            $data = substr($buffer, 6);
        }
        for ($index = 0; $index < strlen($data); $index++) {
            $decoded .= $data[$index] ^ $masks[$index % 4];
        }
        return $decoded;
    }

    /**
     * 發送數據
     * @param $newClinet 新接入的socket
     * @param $msg   要發送的數據
     * @return int|string
     */
    public function send($newClinet, $msg){
        $msg = $this->frame($msg);
        socket_write($newClinet, $msg, strlen($msg));   # 寫入套接字
    }

    public function frame($s) {
        $a = str_split($s, 125);    # 把字符串分割到數組中 第二個長度參數
        if (count($a) == 1) {
            return "\x81" . chr(strlen($a[0])) . $a[0];
        }
        $ns = "";
        foreach ($a as $o) {
            $ns .= "\x81" . chr(strlen($o)) . $o;
        }
        return $ns;
    }

    /**
     * 關閉socket
     */
    public function close(){
        # socket_close的作用是關閉socket_create()或者socket_accept()所建立的套接流
        return socket_close($this->_sockets);
    }
}

$sock = new SocketService();
$sock->run();

 

網上看到很多說會斷開鏈接,設置心跳包也沒有用

我這里直接配置了下 set_time_limit(0);　　 改變 php.ini中的 max_execution_time設置時間 然后就沒有斷線的問題了! 也保證了持久連接!

 

HTML部分

<!DOCTYPE html>
<html>
<head>
    <title>Socket 測試</title>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no">
    <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>

</head>
<body>
<div class="container">
    <div class="title">Socket 測試長連接</div>
    <div class="content">
        <div class="show-area"></div>
        <div class="write-area">
            <div><button class="btn btn-default send" >發送</button></div>
            <div><input name="name" id="name" type="text" placeholder="input your name"></div>
            <div>
                <textarea name="message" id="message" cols="38" rows="4" placeholder="input your message..."></textarea>
            </div>
        </div>
    </div>
</div>

<script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>
<script src="https://cdn.bootcss.com/bootstrap/3.3.2/js/bootstrap.min.js"></script>
<script>
        var wsurl = 'ws://localhost:80/websocket/test2.php';
        var websocket;
        websocket = new WebSocket(wsurl);
            //連接建立
            websocket.onopen = function(evevt){
                console.log("Connected to WebSocket server.");
                $('.show-area').append('<p class="bg-info message"><i class="glyphicon glyphicon-info-sign"></i>Connected to WebSocket server!</p>');
            }
            //收到消息
            websocket.onmessage = function(event) {
                console.log(event);
                $('.show-area').append('<p class="bg-info message"><i class="glyphicon glyphicon-info-sign"></i>'+event.data+'</p>');
            }

            //發生錯誤
            websocket.onerror = function(event){
                console.log("Connected to WebSocket server error");
                $('.show-area').append('<p class="bg-danger message"><a name=""></a><i class="glyphicon glyphicon-info-sign"></i>Connect to WebSocket server error.</p>');
            }

            //連接關閉
            websocket.onclose = function(event){
                console.log('websocket Connection Closed. ');
                $('.show-area').append('<p class="bg-warning message"><a name=""></a><i class="glyphicon glyphicon-info-sign"></i>websocket Connection Closed.</p>');
            }

    // 發送信息
            function send(){
                var name = $('#name').val();
                var message = $('#message').val();
                if(!name){
                    alert('請輸入用戶名!');
                    return false;
                }
                if(!message){
                    alert('發送消息不能為空!');
                    return false;
                }
                 var msg = {
                     message: message,
                     name: name
                 };
                try{
                     websocket.send(JSON.stringify(msg));
                } catch(ex) {
                    console.log(ex);
                }
            }
            //點發送按鈕發送消息
            $('.send').bind('click',function(){
                send();
            });

</script>
</body>
</html>