Comment utiliser MySQL pour le stockage de données dans Workerman

Comment utiliser MySQL pour le stockage de données dans Workerman

En tant que framework PHP Socket asynchrone hautes performances, Workerman est largement utilisé dans le développement de serveurs de communication réseau. Dans de nombreux projets pratiques, nous devons souvent utiliser MySQL pour le stockage et la gestion des données. Ci-dessous, nous présenterons comment utiliser MySQL pour le stockage de données dans Workerman et fournirons des exemples de code spécifiques.

1. Installez l'extension MySQL

Avant de commencer, nous devons nous assurer que l'extension MySQL a été installée. L'extension MySQL peut être installée via la commande suivante :

$ pecl install mysql

Si l'extension MySQL est déjà installée, vous pouvez ignorer cette étape.

2. Établir une connexion MySQL

Avant d'utiliser MySQL pour le stockage de données, vous devez d'abord établir une connexion avec MySQL. Dans Workerman, nous pouvons établir une connexion MySQL via le code suivant :

<?php
require_once __DIR__ . '/Workerman/Autoloader.php';

use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new Connection('host', 'username', 'password', 'database');
};

Worker::runAll();

Dans le code ci-dessus, nous avons d'abord introduit l'Autoloader du framework Workerman et déclaré un objet Worker. Dans la fonction de rappel onWorkerStart de l'objet Worker, nous établissons une connexion MySQL en utilisant l'hôte, le nom d'utilisateur, le mot de passe et le nom de la base de données spécifiés. Stockez l'objet de connexion dans la variable globale $GLOBALS['db'] pour une utilisation dans le code suivant. $GLOBALS['db']中，以便在后续的代码中使用。

三、执行SQL查询语句

在建立了MySQL连接之后，我们就可以使用MySQL连接对象来执行SQL查询语句了。下面是一个简单的例子：

<?php
use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new Connection('host', 'username', 'password', 'database');
};

$worker->onMessage = function($connection, $data) {
    $res = $GLOBALS['db']->query('SELECT * FROM users');
    if (!$res) {
        $connection->send('查询失败');
    } else {
        $connection->send(json_encode($res));
    }
};

Worker::runAll();

在上述代码中，我们在Worker对象的onMessage回调函数中执行了一个查询语句，查询了名为users的表中的所有数据。如果查询失败，则返回"查询失败"；否则将查询结果使用json_encode函数进行序列化，并发送给客户端。

这只是一个简单的例子，实际应用中，我们可以根据具体的需求，执行各种SQL语句，如插入、更新、删除等操作。

四、连接池优化

在高并发的网络应用中，经常需要用到连接池来优化数据库连接。Workerman框架提供了MySQL连接池的支持，可以有效地管理和复用MySQL连接。

以下是一个使用连接池的示例代码：

<?php
use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new WorkermanMySQLPool('host', 'username', 'password', 'database');
};

$worker->onMessage = function($connection, $data) {
    $GLOBALS['db']->pop(function($db) use ($connection) {
        $res = $db->query('SELECT * FROM users');
        if (!$res) {
            $connection->send('查询失败');
        } else {
            $connection->send(json_encode($res));
        }
        $db->push($db);
    });
};

Worker::runAll();

在上述代码中，我们使用Workerman框架提供的连接池类WorkermanMySQLPool来创建连接池对象。在onMessage回调函数中，使用$GLOBALS['db']->pop方法从连接池中获取一个连接，然后执行查询操作。最后使用$db->push

3. Exécuter des instructions de requête SQL

Après avoir établi la connexion MySQL, nous pouvons utiliser l'objet de connexion MySQL pour exécuter des instructions de requête SQL. Voici un exemple simple :

rrreee

Dans le code ci-dessus, nous avons exécuté une instruction de requête dans la fonction de rappel onMessage de l'objet Worker pour interroger toutes les données de la table nommée utilisateurs. Si la requête échoue, « Query failed » est renvoyé ; sinon, les résultats de la requête sont sérialisés à l'aide de la fonction json_encode et envoyés au client. 🎜🎜Ceci n'est qu'un exemple simple. Dans une application réelle, nous pouvons exécuter diverses instructions SQL en fonction de besoins spécifiques, telles que l'insertion, la mise à jour, la suppression et d'autres opérations. 🎜🎜4. Optimisation du pool de connexions🎜🎜Dans les applications réseau à haute concurrence, les pools de connexions sont souvent utilisés pour optimiser les connexions aux bases de données. Le framework Workerman prend en charge le regroupement de connexions MySQL, qui permet de gérer et de réutiliser efficacement les connexions MySQL. 🎜🎜Ce qui suit est un exemple de code utilisant le pool de connexions : 🎜rrreee🎜Dans le code ci-dessus, nous utilisons la classe de pool de connexions WorkermanMySQLPool fournie par le framework Workerman pour créer un objet pool de connexions. Dans la fonction de rappel onMessage, utilisez la méthode $GLOBALS['db']->pop pour obtenir une connexion à partir du pool de connexions, puis effectuez l'opération de requête. Enfin, utilisez la méthode $db->push pour renvoyer la connexion au pool de connexions pour qu'elle puisse être utilisée par d'autres requêtes. 🎜🎜5. Résumé🎜🎜Grâce à cet article, nous avons appris à utiliser MySQL pour le stockage de données dans Workerman. Tout d'abord, vous devez installer l'extension MySQL via la commande pecl install mysql, puis établir une connexion avec MySQL et exécuter l'instruction de requête SQL. Dans le cas d'une concurrence élevée, nous pouvons également utiliser des pools de connexions pour optimiser les connexions aux bases de données. J'espère que cet article pourra vous être utile et je vous souhaite un stockage fluide des données lorsque vous utilisez Workerman pour développer des applications réseau. 🎜

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!