利用PHP和Swoole实现实时通信完全教程-php教程-PHP中文网

随着互联网和移动通信技术的迅猛发展，实时通信越来越受到人们的关注。实时通信可以实现用户之间的即时信息传递、在线音视频通话、游戏对战等功能，为互联网应用带来了更多可能性。

本文将介绍如何利用 PHP 和 Swoole 实现实时通信，从简单的 WebSocket 应用开始，逐步介绍 Socket 编程的基础知识和 Swoole 的应用实践。阅读本文需要了解 PHP 基础和网络编程的基本知识。

一、WebSocket 基础

WebSocket 是一种基于 HTTP 协议的双向通信协议，它使用了一种被称为“握手”的协议来启用双向通信。WebSocket 连接的优点是它的开销非常小，通信的实时性很好，可以在客户端和服务器之间建立双向的实时通信。

WebSocket 的建立需要经历以下几个步骤：

1.浏览器向服务器发起 WebSocket 握手请求，请求头包含了一些关键字段，如 Upgrade、Connection、Sec-WebSocket-Key 等。

2.服务器处理客户端的 WebSocket 请求，如果符合规范，则返回一个响应报文，响应头中包含 Upgrade、Connection、Sec-WebSocket-Accept 等字段。

3.客户端收到服务器的响应报文，校验 Sec-WebSocket-Accept 字段，确认 WebSocket 握手成功建立。

4.双方可以开始进行数据通信，可以发送文本、二进制、Ping、Pong 等消息。

在 PHP 中使用 WebSocket，我们可以通过 Swoole 所提供的 WebSocket 服务来进行实现。下面介绍 Swoole 的基础应用。

二、Swoole 基础

1.安装 Swoole

在开始使用 Swoole 之前，我们需要在服务器上安装 Swoole 扩展。可以通过以下命令来安装：

pecl install swoole

PHP 8.5.5

PHP 8.5.5 是 PHP 8.5 分支的维护更新版本。该版本延续了“小步快跑”的迭代逻辑，通过深度错误修复、底层性能微调以及安全加固，旨在为开发者提供一个更健壮、更高效的运行环境。该版本严格遵守语义化版本规范，不包含破坏性变更。

下载

或者通过源码安装：

$ wget https://github.com/swoole/swoole-src/archive/v4.3.3.tar.gz
$ tar zxvf v4.3.3.tar.gz
$ cd swoole-src-4.3.3
$ phpize
$ ./configure
$ make && make install --with-swoole

Swoole WebSocket 服务

下面我们来实现一个简单的 WebSocket 服务，监听 9501 端口，当客户端与服务器建立连接时，向客户端发送 hello 消息。

<?php $server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    $server->push($request->fd, "hello");
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
});

$server->start();

在该代码中，我们创建了一个新的 WebSocket 服务器，并监听了 9501 端口。在客户端与服务器建立连接时，会触发 open 事件，向客户端发送 hello 消息。当客户端向服务器发送消息时，会触发 message 事件，我们可以通过 echo 输出客户端发送的信息。

在启动上面的代码后，我们可以使用浏览器或者 WebSocket 客户端来连接该服务器：

let ws = new WebSocket('ws://127.0.0.1:9501');
ws.onopen = function(event) {
    console.log('WebSocket connected');
};
ws.onmessage = function(event) {
    console.log('Received:', event.data);
};
ws.send('Hello, Server');

在客户端成功连接后，控制台会输出以下信息：

WebSocket connected
Received: hello

表示客户端已经成功接收到服务器发送的 hello 消息。

三、实现实时聊天应用

下面，让我们来实现一个实时聊天应用，允许多个用户在一个聊天室内实时通信。这需要我们继续扩展上面的 WebSocket 服务器，实现聊天室的基本功能。

<?php $server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->set([
    'worker_num' => 2,    //启动2个Worker进程
]);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    foreach($server->connections as $fd) {
        $server->push($fd, "{$request->fd} joined the room");
    }
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    foreach($server->connections as $fd) {
        if ($fd != $frame->fd) {
            $server->push($fd, "user {$frame->fd}: {$frame->data}");
        }
    }
});

$server->on('close', function ($server, $fd) {
    echo "client {$fd} closed
";
    foreach($server->connections as $fds) {
        $server->push($fds, "{$fd} quited the room");
    }
});

$server->start();

在上面的代码中，我们添加了对 open 和 close 事件的处理。当有用户连接或者关闭连接时，会向其他连接的用户发送加入或离开聊天室的消息。当某个用户在聊天室内发送消息时，会将该消息广播给其他在线用户。

在启动上面的代码后，我们可以使用多个浏览器窗口分别连接服务器，进入同一个聊天室。当某个用户发送消息时，其他的用户可以实时地接收到该消息。

本文介绍了如何利用 PHP 和 Swoole 实现实时通信，从基础的 WebSocket 应用到实时聊天室应用。Swoole 提供了更加灵活的异步编程方式，使得编写高性能、高并发、低延时的应用变得更加容易。