Pratique de programmation réseau Workerman : créer un système de messagerie instantanée performant

Pratique de programmation réseau Workerman : créer un système de messagerie instantanée haute performance

Introduction :
Avec le développement rapide d'Internet, les systèmes de messagerie instantanée ont attiré de plus en plus l'attention des utilisateurs. Les systèmes de messagerie instantanée traditionnels, tels que QQ, WeChat, etc., sont souvent confrontés à des goulots d'étranglement en termes de performances lorsque le nombre d'utilisateurs est important et que les messages sont fortement simultanés. Afin de résoudre ce problème, le projet open source Workerman a vu le jour. Cet article explique comment utiliser Workerman pour créer un système de messagerie instantanée hautes performances.

1. Introduction à Workerman
   Workerman est un framework de communication réseau hautes performances développé sur la base de PHP. Par rapport aux modes de fonctionnement PHP traditionnels, tels qu'Apache, Nginx, etc., Workerman adopte un mode de fonctionnement entièrement asynchrone et non bloquant, ce qui améliore considérablement l'efficacité de la communication réseau. Dans le même temps, Workerman prend en charge plusieurs protocoles, tels que TCP, UDP, etc., nous permettant de choisir de manière flexible en fonction des différents besoins. De plus, Workerman prend en charge parfaitement la simultanéité élevée et peut facilement faire face à la pression d'un grand nombre d'utilisateurs.
2. Préparation
   Pour commencer à développer notre système de messagerie instantanée, nous devons d'abord installer Workerman. Il peut être installé via la commande suivante :

composer require workerman/workerman

Une fois l'installation terminée, nous pouvons utiliser toutes les fonctionnalités de Workerman.

3. Créer un serveur TCP
   Nous créons d'abord un simple serveur TCP, en écoute sur le port spécifié. Lorsqu'un utilisateur se connecte au serveur, le serveur renvoie un message de bienvenue et reçoit les messages envoyés par l'utilisateur. Voici un exemple de code simple :

use WorkermanWorker;

// 创建一个Worker监听端口
$tcp_worker = new Worker("tcp://0.0.0.0:1234");

// 当客户端连接时的回调函数
$tcp_worker->onConnect = function ($connection) {
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$tcp_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

Avec le code ci-dessus, nous avons créé un TCP Worker écoutant sur le port 1234. Lorsqu'un client se connecte au serveur, le serveur envoie un message de bienvenue. Lorsque le client envoie un message, le serveur renvoie le message inchangé. Vous pouvez utiliser des outils tels que Telnet pour vous connecter au serveur à des fins de test.

4. Créer un serveur WebSocket
   WebSocket est un protocole de communication full-duplex qui peut établir une connexion persistante entre le client et le serveur. Workerman prend en charge le protocole WebSocket et nous pouvons utiliser Workerman pour créer un serveur WebSocket. Voici un exemple de code simple :

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);
    // 发送欢迎消息
    $connection->send("Welcome to the chat room!
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    echo "Received message: " . $data . "
";
    $connection->send("You said: " . $data . "
");
};

// 启动Worker
Worker::runAll();

Avec le code ci-dessus, nous créons un WebSocket Worker écoutant sur le port 1234. Lorsqu'un client se connecte au serveur, le serveur envoie un message de bienvenue. Lorsque le client envoie un message, le serveur renvoie le message inchangé.

5. Mise en œuvre d'un système de messagerie instantanée
   Avec la base ci-dessus, nous pouvons continuer à mettre en œuvre un système de messagerie instantanée plus complet. Nous utilisons ici le protocole WebSocket pour le développement.

Tout d'abord, créez un serveur WebSocket en écoute sur le port spécifié. Lorsqu'un utilisateur se connecte au serveur, le serveur ajoutera la connexion à la liste des utilisateurs et diffusera le message indiquant que l'utilisateur est entré dans la salle de discussion ; lorsque l'utilisateur envoie un message, le serveur diffusera le message à tous les utilisateurs en ligne ; l'utilisateur se déconnecte, le serveur le supprimera de la liste des utilisateurs et diffusera un message indiquant que l'utilisateur a quitté la salle de discussion.

Ce qui suit est un exemple de code simple :

use WorkermanWorker;
use WorkermanProtocolsWebsocket;

// 创建一个WebSocket Worker监听端口
$websocket_worker = new Worker("websocket://0.0.0.0:1234");

// 设置协议处理类
$websocket_worker->onWebSocketConnect = function ($connection, $http_header) {
    // 处理握手请求
    Websocket::dealHandshake($connection, $http_header);

    // 将连接添加到用户列表中
    global $user_list;
    $user_list[$connection->id] = $connection;

    // 广播用户进入聊天室的消息
    broadcastMessage("User #$connection->id entered the chat room.
");
};

// 当接收到客户端消息时的回调函数
$websocket_worker->onMessage = function ($connection, $data) {
    // 处理接收到的消息
    broadcastMessage("User #$connection->id: $data");
};

// 当用户断开连接时的回调函数
$websocket_worker->onClose = function ($connection) {
    // 将连接从用户列表中移除
    global $user_list;
    unset($user_list[$connection->id]);

    // 广播用户离开聊天室的消息
    broadcastMessage("User #$connection->id left the chat room.");
};

// 启动Worker
Worker::runAll();

// 广播消息给所有在线用户
function broadcastMessage($message)
{
    global $user_list;
    foreach ($user_list as $connection) {
        $connection->send($message);
    }
}

Grâce au code ci-dessus, nous avons implémenté un système de messagerie instantanée simple. Chaque fois qu'un nouvel utilisateur entre dans la salle de discussion, envoie un message ou quitte la salle de discussion, le serveur diffuse le message correspondant à tous les utilisateurs en ligne.

Conclusion :
Dans cet article, nous utilisons le framework Workerman pour démontrer comment créer un système de messagerie instantanée hautes performances à l'aide d'un exemple de code simple. Grâce au mode de fonctionnement asynchrone non bloquant de Workerman et à la prise en charge d'une concurrence élevée, nous pouvons facilement faire face à la pression d'un grand nombre d'utilisateurs. J'espère que grâce à l'introduction de cet article, les lecteurs pourront avoir une compréhension plus approfondie de Workerman et pouvoir l'appliquer dans des projets réels.

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!