PHP如何使用WebSockets

介绍

WebSocket是一种持续连接TCP的技术，它使得客户端和服务器之间可以双向实时通信。对于实时的Web应用程序，这是一个非常有用的功能。在本文中，我们将讨论如何使用PHP来实现WebSocket。

准备工作

安装扩展

为了使用PHP WebSocket，我们需要安装php-sockets扩展。在Linux终端中，我们可以使用以下命令来安装：

sudo apt-get install php-sockets

如果您使用的是Windows，请前往 PECL下载php_sockets.dll并将其放入您的php/ext目录中。

创建WebSocket服务器

接下来，我们需要创建一个WebSocket服务器，这个服务器可以接受客户端的连接并在收到消息时提供响应。以下是一个简单的WebSocket服务器的示例代码：

$server = stream_socket_server("tcp://127.0.0.1:8080", $errno, $errorMessage);
if ($server === false) {
    throw new UnexpectedValueException("Could not bind to socket: $errorMessage");
}
while (true) {
    $client = @stream_socket_accept($server);
    if ($client) {
        $message = 'Hello, I am a WebSocket server!';
        $response = "HTTP/1.1 101 Switching Protocols\r\n";
        $response .= "Upgrade: websocket\r\n";
        $response .= "Connection: Upgrade\r\n";
        $response .= "Sec-WebSocket-Accept: " . base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)) . "\r\n\r\n";
        fwrite($client, $response);
        while (!feof($client)) {
            $message = fread($client, 4096);
            $message = parseMessage($message);
            $response = encodeMessage($message);
            fwrite($client, $response);
        }
        fclose($client);
    }
}
function parseMessage($message) {
    $opcode = ord($message[0]) & 0x0F;
    $length = ord($message[1]) & 0x7F;
    if ($length == 126) {
        $length = (ord($message[2]) << 8) + ord($message[3]);
        $mask = substr($message, 4, 4);
        $data = substr($message, 8);
    } elseif ($length == 127) {
        $length = (ord($message[2]) << 56) + (ord($message[3]) << 48) + (ord($message[4]) << 40) + (ord($message[5]) << 32) + (ord($message[6]) << 24) + (ord($message[7]) << 16) + (ord($message[8]) << 8) + ord($message[9]);
        $mask = substr($message, 10, 4);
        $data = substr($message, 14);
    } else {
        $mask = substr($message, 2, 4);
        $data = substr($message, 6);
    }
    $decodedData = '';
    for ($i = 0; $i < strlen($data); $i++) {
        $decodedData .= $data[$i] ^ $mask[$i % 4];
    }
    return json_decode($decodedData);
}
function encodeMessage($message) {
    $length = strlen($message);
    $response = chr(129);
    if ($length <= 125) {
        $response .= chr($length);
    } else if ($length >= 126 && $length <= 65535) {
        $response .= chr(126);
        $response .= chr(($length >> 8) & 0xFF);
        $response .= chr($length & 0xFF);
    } else {
        $response .= chr(127);
        $response .= chr(($length >> 56) & 0xFF);
        $response .= chr(($length >> 48) & 0xFF);
        $response .= chr(($length >> 40) & 0xFF);
        $response .= chr(($length >> 32) & 0xFF);
        $response .= chr(($length >> 24) & 0xFF);
        $response .= chr(($length >> 16) & 0xFF);
        $response .= chr(($length >> 8) & 0xFF);
        $response .= chr($length & 0xFF);
    }
    $response .= $message;
    return $response;
}

此代码通过监听TCP端口上的连接并通过WebSocket协议进行通信。当有客户端连接到这个服务器时，它会发送一个简单的欢迎消息“Hello, I am a WebSocket server!”作为响应。它还解析客户端发送的消息并对其进行编码以发送回客户端。

创建WebSocket客户端

与服务器不同，客户端不需要通过任何特殊的扩展或库来实现WebSocket。原生的JavaScript已经支持客户端WebSocket。以下是一个简单的JavaScript WebSocket客户端的示例代码：

var ws = new WebSocket('ws://127.0.0.1:8080');
ws.onopen = function(event) {
  ws.send('Hello, I am a WebSocket client!');
};
ws.onmessage = function(event) {
  var message = event.data;
  console.log('Message received: ' + message);
};
ws.onclose = function(event) {
  console.log('WebSocket closed');
};

此代码会创建一个WebSocket，并在打开连接时发送一个简单的消息“Hello, I am a WebSocket client!”。它还定义了一个事件，用于在接收到由服务器发送的消息时记录其内容。

结论

本文介绍了如何使用PHP和JavaScript来实现WebSocket。我们创建了一个简单的服务器和客户端，并演示了如何通过WebSocket协议实现实时通信。虽然本文所示的代码是基于原生JavaScript和PHP编写的，但是有许多现成的库和框架可用于简化WebSocket应用程序的开发，例如Socket.IO和Ratchet。