WebSocket est devenu un élément essentiel des applications Web modernes. Il fournit une méthode de communication en duplex intégral qui permet une communication en temps réel entre le serveur et le client. Swoole est un framework de communication réseau hautes performances basé sur PHP, qui peut facilement implémenter des serveurs WebSocket.

Cet article expliquera comment utiliser Swoole pour créer un serveur WebSocket.

Installer Swoole

Pour installer Swoole, vous devez utiliser PECL (PHP Extension Community Library). Ouvrez un terminal et entrez la commande suivante :

pecl install swoole

Une fois l'installation terminée, l'extension Swoole sera automatiquement chargée dans la liste des extensions PHP.

Création d'un serveur WebSocket

Le moyen le plus simple de créer un serveur WebSocket consiste à utiliser la classe WebSocket Server de Swoole :

$server = new SwooleWebsocketServer("127.0.0.1", 9501);

$server->on('open', function (SwooleWebsocketServer $server, $request) {
    echo "Client {$request->fd} connected
";
});

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

    // Broadcast message to all connected clients
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

$server->on('close', function (SwooleWebsocketServer $server, $fd) {
    echo "Client {$fd} disconnected
";
});

$server->start();

Cet exemple crée un serveur WebSocket local et le configure pour écouter sur le port 9501. Il ajoute également trois fonctions de rappel :

• open - sera appelé lorsqu'un nouveau client WebSocket se connectera au serveur.
open - 当新的WebSocket客户端连接到服务器时，将被调用。
• message - 当服务器接收到来自客户端的消息时，将被调用。
• close - 当客户端断开连接时，将被调用。

在open函数中，我们向控制台输出一个简单的消息，提示我们已经连接了一个新的客户端。

在message函数中，我们向控制台输出接收到的消息，并向所有已连接的客户端广播此消息。

在close函数中，我们向控制台输出一个消息，提示已断开连接的客户端的fd。

最后，我们通过调用start方法启动WebSocket服务器。

测试WebSocket服务器

为了测试WebSocket服务器，可以使用JavaScript的WebSocket API编写一个简单的客户端。这里提供一个非常简单的例子：

// Connect to WebSocket server
const ws = new WebSocket('ws://127.0.0.1:9501');

// Send a message to the server
ws.onopen = function() {
    ws.send('Hello, server!');
};

// Receive a message from the server
ws.onmessage = function(event) {
    console.log('Received message:', event.data);
};

在这个例子中，我们创建一个WebSocket对象，并连接到刚才创建的WebSocket服务器。我们还定义了两个回调函数：

• onopen - 当WebSocket连接成功建立时，将被调用。在这里我们向服务器发送了一个消息。
• onmessage - 当WebSocket接收到来自服务器的消息时，将被调用。

要测试这个客户端，只需在浏览器中打开控制台并将代码复制粘贴到控制台中即可。

实现更多功能

除了在该例子中演示的功能之外，Swoole还提供了许多其他有用的功能。例如，您可以通过调用pushmessage - Sera appelé lorsque le serveur recevra un message du client.

Dans la fonction open, nous envoyons un simple message à la console, indiquant que nous avons connecté un nouveau client.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!