L'intégration PHP et WebSocket réalise le développement d'un salon de discussion en temps réel

Dans le domaine du développement web, les fonctions de chat en temps réel sont devenues de plus en plus populaires. Il aide les utilisateurs à interagir facilement en temps réel et à améliorer la communication et la compréhension. Afin de mettre en œuvre le chat en temps réel, nous devons utiliser le protocole WebSocket et avoir besoin d'un langage de programmation capable de gérer les requêtes WebSocket. Dans cet article, nous présenterons comment mettre en œuvre le développement de salles de discussion en temps réel à l'aide de l'intégration PHP et WebSocket.

WebSocket est un protocole de communication full-duplex qui permet la transmission de données en temps réel entre le navigateur et le serveur. Contrairement aux requêtes HTTP, le serveur peut transmettre les données au navigateur une fois la connexion WebSocket établie. Par conséquent, nous pouvons effectuer une communication de données bidirectionnelle entre le client et le serveur via WebSocket. Lorsqu'un utilisateur rejoint ou quitte la salle de discussion, le message peut être immédiatement transmis aux autres utilisateurs en ligne. C'est le principe de base du chat en temps réel.

Tout d'abord, nous devons créer un script PHP côté serveur pour gérer les requêtes WebSocket. L'extension swoole de PHP peut nous aider à développer des serveurs WebSocket. Ensuite, nous mettrons en œuvre notre application de chat étape par étape.

1. Installez l'extension swoole

Pour utiliser l'extension swoole, nous devons d'abord l'installer. Utilisez la commande suivante pour installer swoole dans un système Linux :

pecl install swoole

Si vous utilisez PHP dans un système Windows, vous pouvez télécharger et installer manuellement les fichiers DLL appropriés à partir du référentiel GitHub de swoole.

2. Configurer le serveur WebSocket

Une fois que nous avons installé avec succès l'extension swoole, nous pouvons commencer à l'utiliser pour créer un serveur WebSocket. Voici le code de base pour créer un serveur WebSocket :

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

Dans cet extrait de code, nous créons un serveur WebSocket et enregistrons la fonction de gestionnaire d'événements. Dans l'événement "open", nous imprimerons le message indiquant que la connexion WebSocket est ouverte. Dans l'événement "message", nous imprimerons des informations sur la session WebSocket et enverrons un message au client. Dans l'événement "close", nous imprimerons le message indiquant que la connexion WebSocket est fermée.

3. Configurez la logique de la salle de discussion

Nous avons maintenant créé avec succès le serveur WebSocket et configuré la fonction de gestion des événements. Ensuite, nous pouvons commencer à implémenter notre logique de salle de discussion.

Nous devons mettre en place une fonction de diffusion de messages pour avertir tous les utilisateurs en ligne lorsqu'un utilisateur rejoint ou quitte le salon de discussion. Voici le code de la fonction de diffusion de messages :

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

Dans cet extrait de code, nous utilisons des instructions switch pour gérer différents types de messages. Lorsqu'un utilisateur rejoint ou quitte la salle de discussion, nous mettons à jour la liste des utilisateurs et envoyons un message de notification. Lorsqu'un utilisateur envoie un message, nous préfixerons le message avec le nom d'utilisateur et le diffuserons à tous les utilisateurs en ligne.

4. Code complet du salon de discussion

Maintenant que tous les composants nécessaires sont prêts, nous pouvons commencer à écrire le code complet du salon de discussion. Ce qui suit est un code complet de salle de discussion :

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//定义用户列表
$users = [];

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) use ($users) {
    broadcast($server, $frame, $users);
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) use ($users) {
    unset($users[$fd]);
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

Dans cet extrait de code, nous enregistrons les informations de tous les utilisateurs en ligne dans le tableau $users. Nous mettrons à jour ce tableau lorsqu'un utilisateur rejoindra ou quittera la salle de discussion. Dans l'événement de message WebSocket, nous diffuserons le message à l'aide de la fonction Broadcast(). Dans l'événement de fermeture de connexion WebSocket, nous supprimerons l'utilisateur déconnecté du tableau $users.

5. Testez votre salle de discussion

Nous avons maintenant créé avec succès notre application de salle de discussion. Nous pouvons le tester dans tous les navigateurs prenant en charge WebSocket, tels que Google Chrome, Firefox et Safari, etc. Voici les étapes à suivre pour tester votre salon de discussion :

1. Exécutez le code ci-dessus à l'aide des commandes PHP
2. Ouvrez le fichier index.html dans votre navigateur#🎜 🎜 #
Entrez le nom d'utilisateur et cliquez sur le bouton "Entrer dans le salon de discussion"
3. Entrez le message dans la boîte de discussion et cliquez sur le bouton "Envoyer"
4. #🎜 🎜#Vous devriez pouvoir voir votre message diffusé dans la boîte de discussion de tous les utilisateurs en ligne.

Résumé

Dans cet article, nous avons présenté comment mettre en œuvre le développement de salles de discussion en temps réel à l'aide de l'intégration PHP et WebSocket. Nous avons utilisé l'extension swoole pour créer un serveur WebSocket et écrit une application simple de salle de discussion. Grâce à cet article, vous pouvez apprendre à utiliser le protocole WebSocket pour établir une connexion de transmission de données en temps réel, implémenter un serveur WebSocket en PHP et l'utiliser pour implémenter une application de salle de discussion.

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!