cadre php
Swoole
Comment utiliser Swoole pour implémenter l'interaction du serveur WebSocket et de la base de données
Comment utiliser Swoole pour implémenter l'interaction du serveur WebSocket et de la base de données
Nov 07, 2023 am 09:32 AM
Comment utiliser Swoole pour implémenter l'interaction du serveur WebSocket et de la base de données
Introduction?:
WebSocket est un protocole de communication full-duplex basé sur le protocole TCP, qui peut établir une communication bidirectionnelle en temps réel entre le client et le serveur . Swoole est une extension PHP qui peut facilement implémenter une programmation asynchrone et simultanée hautes performances. Dans cet article, nous présenterons en détail comment utiliser Swoole pour créer un serveur WebSocket et interagir avec la base de données.
étape 1?: Installez l'extension Swoole
Tout d'abord, nous devons installer l'extension Swoole. Il peut être installé via la commande suivante :
pecl install swoole
étape 2 : Créer un serveur WebSocket
Ensuite, nous créons un serveur WebSocket, écoutons le port spécifié et établissons une connexion avec le client. Ceci peut être réalisé en utilisant le code suivant :
<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);
$server->on('open', function (SwooleWebSocketServer $server, $request) {
echo "new connection open: {$request->fd}
";
});
$server->on('message', function (SwooleWebSocketServer $server, $frame) {
echo "received message: {$frame->data}
";
// 處理數(shù)據(jù)庫交互
$db = new mysqli('localhost', 'username', 'password', 'database');
$result = $db->query("SELECT * FROM users");
while ($row = $result->fetch_assoc()) {
$server->push($frame->fd, json_encode($row));
}
$db->close();
});
$server->on('close', function ($ser, $fd) {
echo "connection close: {$fd}
";
});
$server->start();
?> Dans le code ci-dessus, nous créons un serveur WebSocket et ajoutons trois fonctions de rappel d'événement. Lorsqu'une connexion est établie, l'événement open sera déclenché?; lorsqu'un message est re?u, l'événement message sera déclenché lorsque la connexion est fermée, le ?; L'événement close sera déclenché. >L'événement sera déclenché. Dans l'événement message, nous pouvons effectuer des opérations interactives sur la base de données. open事件將被觸發(fā)；當(dāng)收到消息時(shí)，message事件將被觸發(fā)；當(dāng)連接關(guān)閉時(shí)，close事件將被觸發(fā)。在message事件中，我們可以進(jìn)行數(shù)據(jù)庫的交互操作。
步驟三：與數(shù)據(jù)庫交互
在message事件回調(diào)函數(shù)中，我們使用了MySQLi擴(kuò)展來與數(shù)據(jù)庫進(jìn)行交互。首先，我們創(chuàng)建了一個(gè)$db對象，并使用mysqli的構(gòu)造函數(shù)連接到數(shù)據(jù)庫。接著，我們執(zhí)行了一條查詢語句，并通過while循環(huán)將查詢結(jié)果發(fā)送給客戶端。最后，我們關(guān)閉了數(shù)據(jù)庫連接。
需要注意的是，為了安全起見，我們應(yīng)該將數(shù)據(jù)庫的相關(guān)信息（如用戶名和密碼）設(shè)置為環(huán)境變量，并通過getenv()函數(shù)來獲取這些值，以避免直接暴露在代碼中。
步驟四：運(yùn)行服務(wù)器
最后，我們使用命令行來運(yùn)行上述代碼。在命令行中切換到代碼所在的目錄，并執(zhí)行以下命令：
php server.php
如果一切正常，你將看到WebSocket服務(wù)器成功啟動，并等待客戶端的連接。當(dāng)有客戶端連接到服務(wù)器時(shí)，open事件將被觸發(fā)，并在命令行中顯示連接的ID。當(dāng)收到客戶端發(fā)來的消息時(shí)，message事件將被觸發(fā)，并在命令行中顯示收到的消息。當(dāng)連接關(guān)閉時(shí)，close事件將被觸發(fā)，同樣在命令行中顯示連接的關(guān)閉。
總結(jié)：
本文詳細(xì)介紹了如何使用Swoole實(shí)現(xiàn)WebSocket服務(wù)器與數(shù)據(jù)庫的交互。通過創(chuàng)建WebSocket服務(wù)器，并在message
message, nous utilisons l'extension MySQLi pour interagir avec la base de données. Tout d'abord, nous créons un objet $db et utilisons le constructeur de mysqli pour nous connecter à la base de données. Ensuite, nous avons exécuté une instruction de requête et envoyé les résultats de la requête au client via une boucle while. Enfin, nous fermons la connexion à la base de données. ????Il convient de noter que pour des raisons de sécurité, nous devons définir les informations liées à la base de données (telles que le nom d'utilisateur et le mot de passe) comme variables d'environnement et obtenir ces valeurs via la fonction getenv() pour éviter directement exposé dans le code. ????étape 4?: Exécuter le serveur????Enfin, nous utilisons la ligne de commande pour exécuter le code ci-dessus. Basculez vers le répertoire où se trouve le code sur la ligne de commande et exécutez la commande suivante : ??rrreee?? Si tout se passe bien, vous verrez que le serveur WebSocket démarre avec succès et attend que le client se connecte. Lorsqu'un client se connecte au serveur, l'événement open sera déclenché et l'ID de connexion sera affiché sur la ligne de commande. Lorsqu'un message du client est re?u, l'événement message sera déclenché et le message re?u sera affiché sur la ligne de commande. Lorsque la connexion est fermée, l'événement close sera déclenché et la fermeture de la connexion sera également affichée sur la ligne de commande. ????Résumé?: ??Cet article détaille comment utiliser Swoole pour implémenter l'interaction entre le serveur WebSocket et la base de données. En créant un serveur WebSocket et en effectuant une interaction avec la base de données dans la fonction de rappel d'événement message, nous pouvons réaliser une communication bidirectionnelle en temps réel. Grace aux extensions Swoole, nous pouvons facilement effectuer une programmation asynchrone et simultanée hautes performances. J'espère que cet article vous sera utile pour utiliser Swoole pour interagir avec la base de données. ??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!
Outils d'IA chauds
Undress AI Tool
Images de déshabillage gratuites
Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes
AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.
Clothoff.io
Dissolvant de vêtements AI
Video Face Swap
échangez les visages dans n'importe quelle vidéo sans effort grace à notre outil d'échange de visage AI entièrement gratuit?!
Article chaud
Outils chauds
Bloc-notes++7.3.1
éditeur de code facile à utiliser et gratuit
SublimeText3 version chinoise
Version chinoise, très simple à utiliser
Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP
Dreamweaver CS6
Outils de développement Web visuel
SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)
iOS 18 ajoute une nouvelle fonction d'album 'Récupéré' pour récupérer les photos perdues ou endommagées
Jul 18, 2024 am 05:48 AM
Les dernières versions d'Apple des systèmes iOS18, iPadOS18 et macOS Sequoia ont ajouté une fonctionnalité importante à l'application Photos, con?ue pour aider les utilisateurs à récupérer facilement des photos et des vidéos perdues ou endommagées pour diverses raisons. La nouvelle fonctionnalité introduit un album appelé "Récupéré" dans la section Outils de l'application Photos qui appara?tra automatiquement lorsqu'un utilisateur a des photos ou des vidéos sur son appareil qui ne font pas partie de sa photothèque. L'émergence de l'album ??Récupéré?? offre une solution aux photos et vidéos perdues en raison d'une corruption de la base de données, d'une application d'appareil photo qui n'enregistre pas correctement dans la photothèque ou d'une application tierce gérant la photothèque. Les utilisateurs n'ont besoin que de quelques étapes simples
Comment enregistrer les données JSON dans la base de données dans Golang ?
Jun 06, 2024 am 11:24 AM
Les données JSON peuvent être enregistrées dans une base de données MySQL à l'aide de la bibliothèque gjson ou de la fonction json.Unmarshal. La bibliothèque gjson fournit des méthodes pratiques pour analyser les champs JSON, et la fonction json.Unmarshal nécessite un pointeur de type cible pour désorganiser les données JSON. Les deux méthodes nécessitent la préparation d'instructions SQL et l'exécution d'opérations d'insertion pour conserver les données dans la base de données.
MySQL: Concepts simples pour l'apprentissage facile
Apr 10, 2025 am 09:29 AM
MySQL est un système de gestion de base de données relationnel open source. 1) Créez une base de données et des tables: utilisez les commandes CreateDatabase et CreateTable. 2) Opérations de base: insérer, mettre à jour, supprimer et sélectionner. 3) Opérations avancées: jointure, sous-requête et traitement des transactions. 4) Compétences de débogage: vérifiez la syntaxe, le type de données et les autorisations. 5) Suggestions d'optimisation: utilisez des index, évitez de sélectionner * et utilisez les transactions.
Comment gérer les erreurs de connexion à la base de données en PHP
Jun 05, 2024 pm 02:16 PM
Pour gérer les erreurs de connexion à la base de données en PHP, vous pouvez utiliser les étapes suivantes : Utilisez mysqli_connect_errno() pour obtenir le code d'erreur. Utilisez mysqli_connect_error() pour obtenir le message d'erreur. En capturant et en enregistrant ces messages d'erreur, les problèmes de connexion à la base de données peuvent être facilement identifiés et résolus, garantissant ainsi le bon fonctionnement de votre application.
Pourquoi une erreur se produit-elle lors de l'installation d'une extension à l'aide de PECL dans un environnement Docker? Comment le résoudre?
Apr 01, 2025 pm 03:06 PM
Causes et solutions pour les erreurs Lors de l'utilisation de PECL pour installer des extensions dans un environnement Docker Lorsque nous utilisons un environnement Docker, nous rencontrons souvent des maux de tête ...
Le r?le d'Oracle dans le monde des affaires
Apr 23, 2025 am 12:01 AM
Oracle n'est pas seulement une entreprise de base de données, mais aussi un leader des systèmes de cloud computing et ERP. 1. Oracle fournit des solutions complètes de la base de données aux services cloud et aux systèmes ERP. 2. OracleCloud défie AWS et Azure, fournissant des services IaaS, PaaS et SaaS. 3. Les systèmes ERP d'Oracle tels que E-BusinessSuite et FusionApplications aident les entreprises à optimiser les opérations.
MySQL: une introduction à la base de données la plus populaire au monde
Apr 12, 2025 am 12:18 AM
MySQL est un système de gestion de la base de données relationnel open source, principalement utilisé pour stocker et récupérer les données rapidement et de manière fiable. Son principe de travail comprend les demandes des clients, la résolution de requête, l'exécution des requêtes et les résultats de retour. Des exemples d'utilisation comprennent la création de tables, l'insertion et la question des données et les fonctionnalités avancées telles que les opérations de jointure. Les erreurs communes impliquent la syntaxe SQL, les types de données et les autorisations, et les suggestions d'optimisation incluent l'utilisation d'index, les requêtes optimisées et la partition de tables.
Mysql vs autres bases de données: comparaison des options
Apr 15, 2025 am 12:08 AM
MySQL convient aux applications Web et aux systèmes de gestion de contenu et est populaire pour son open source, ses performances élevées et sa facilité d'utilisation. 1) Par rapport à PostgreSQL, MySQL fonctionne mieux dans les requêtes simples et les opérations de lecture simultanées élevées. 2) Par rapport à Oracle, MySQL est plus populaire parmi les petites et moyennes entreprises en raison de son open source et de son faible co?t. 3) Par rapport à Microsoft SQL Server, MySQL est plus adapté aux applications multiplateformes. 4) Contrairement à MongoDB, MySQL est plus adapté aux données structurées et au traitement des transactions.
