创建一个 PHP websockets 服务器答案

【问题标题】：Creating a PHP websockets server创建一个 PHP websockets 服务器
【发布时间】：2014-10-09 11:05:22
【问题描述】：

我是 websockets 技术的新手。我试图创建一个 websockets php 服务器并使用 javascript 客户端连接到服务器。我正在使用 xampp 1.8.3。

我做了这个简单的 PHP 服务器：

<?php 
    error_reporting(E_ALL);
    set_time_limit(0);

    $address = "127.0.0.1";
    $port = 1777;
    $maxConnections = 10;

    if(!($sock = socket_create(AF_INET, SOCK_STREAM, 0))){
        $errorCode = socket_last_error();
        $errorMsg = socket_strerror($errorCode);
        die("socket_create() failed -> {$errorCode}:{$errorMsg}\n");
    }
    echo "Server created.\n";

    if(!(socket_bind($sock, $address, $port))){
        $errorCode = socket_last_error();
        $errorMsg = socket_strerror($errorCode);
        die("socket_bind() failed -> {$errorCode}:{$errorMsg}\n");
    }
    echo "Server opened on {$address}:{$port}\n";

    if(!(socket_listen($sock, $maxConnections))){
        $errorCode = socket_last_error();
        $errorMsg = socket_strerror($errorCode);
        die("socket_listen() failed -> {$errorCode}:{$errorMsg}\n");
    }
    echo "Waiting for connections...\n";

    $client = socket_accept($sock);
    if(socket_getpeername($client, $address, $port)){
        echo "The client {$address}:{$port} is online.\n";
    }
    $msg = socket_read($client, 1024000);
    if(!(socket_write($client, $msg, strlen($msg)))){
        $errorCode = socket_last_error();
        $errorMsg = socket_strerror($errorCode);
        die("socket_write() failed -> {$errorCode}:{$errorMsg}\n");
    }
    echo "Message sent\n";

    socket_close($client);
    socket_close($sock);


?>

我使用以下表达式在 xampp shell 中运行了这个 php 文件：

php htdocs/server.php

我在 shell 上收到了这条消息：

php htdocs/server.php
Server created.
Server opened on 127.0.0.1:1777
Waiting for connections...

然后我在 chrome 上打开了我的 client.html（我支持 websockets）。我的 client.html 代码是：

<html>
    <head>
        <meta charset="UTF-8" />
        <title>Websockets web-server connection</title>
    </head>
    <body>
        <p>Websockets connection. Status: <span id="status"></span></p>
        <script type="text/javascript">
            var webSockets = new WebSocket("ws://127.0.0.1:1777/");
            webSockets.onopen = function(){
                document.getElementById("status").innerHTML="connected";
                webSockets.send("ping");
            }
        </script>
    </body>
</html>

我在 javascript 控制台日志中收到了这条消息：

WebSocket connection to 'ws://127.0.0.1:1777/' failed:  client.html:9

我的外壳有这样的消息：

php htdocs/server.php
Server created.
Server opened on 127.0.0.1:1777
Waiting for connections...
The client 127.0.0.1:64446 is online
Message sent

但是我没有在客户端收到任何消息，我什至没有获得连接状态。

发生了什么？我的错误在哪里？

谢谢。

【问题讨论】：

标签： javascript php apache websocket

【解决方案1】：

WebSocket 不是原始 TCP 套接字。它们需要相当复杂的类似 HTTP 的握手来建立连接，并且需要通过它们传输的数据以非常特殊的方式进行编码和构建。协议在RFC 6455中定义。

除非您感到难以置信的自虐，否则您不想尝试自己实现这一点。使用 Ratchet 之类的库在 PHP 中实现 WebSockets。

【讨论】：

【解决方案2】：

兄弟，我也遇到了同样的问题，但不需要使用 Ratchet 或其他库，您可以编写自己的简单代码。握手过程和消息的屏蔽 - 取消屏蔽相当困难，所以我复制了这些代码

function perform_handshaking($receved_header,$client_conn, $host, $port)
{
    $headers = array();
    $lines = preg_split("/\r\n/", $receved_header);
    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')));
    //hand shaking header
    $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
    "Upgrade: websocket\r\n" .
    "Connection: Upgrade\r\n" .
    "WebSocket-Origin: $host\r\n" .
    "WebSocket-Location: ws://$host:$port/\r\n".
    "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
    socket_write($client_conn,$upgrade,strlen($upgrade));
    return $upgrade;
}

function unmask($text) {
    $length = ord($text[1]) & 127;
    if($length == 126) {
        $masks = substr($text, 4, 4);
        $data = substr($text, 8);
    }
    elseif($length == 127) {
        $masks = substr($text, 10, 4);
        $data = substr($text, 14);
    }
    else {
        $masks = substr($text, 2, 4);
        $data = substr($text, 6);
    }
    $text = "";
    for ($i = 0; $i < strlen($data); ++$i) {
        $text .= $data[$i] ^ $masks[$i%4];
    }
    return $text;
}

//Encode message for transfer to client.
function mask($text)
{
    $b1 = 0x80 | (0x1 & 0x0f);
    $length = strlen($text);

    if($length <= 125)
        $header = pack('CC', $b1, $length);
    elseif($length > 125 && $length < 65536)
        $header = pack('CCn', $b1, 126, $length);
    elseif($length >= 65536)
        $header = pack('CCNN', $b1, 127, $length);
    return $header.$text;
}

而不是 socket_accept 用户 socket_read 来获取包含来自网页的请求的 http 标头，它希望将其 http conn 升级到 websocket 然后使用上面的握手功能编写一个接受标头消息。然后您的连接将建立。但仍然在客户端你必须添加这样的事件

if("WebSocket" in window){
    var a = "ws://"+serverip+":9000";
    var ws = new WebSocket(a);
    var error = null;

    ws.onopen = function(){
        open();
    }

    ws.onerror = function(err){
        errorhandler(err);

    }
    ws.onmessage = function(e){
        messagehandler(e);

    }
    ws.onclose = function(){
        close();
    }

}

function  open(){
               document.getElementById('logs').innerHTML+='<p>WebSocket Connection OPened</p>';

}

function errorhandler(err){
               document.getElementById('logs').innerHTML+='<p>WebSocket Connection Error occured &nbsp'+err.data+'</p>';

}

function messagehandler(a){
               document.getElementById('logs').innerHTML+="<p>"+a.data+"</p>";

}

function close(){
                document.getElementById('logs').innerHTML+='<p>WebSocket Connection Closed</p>';
                ws = null;

}

【讨论】：