Une brève analyse de la façon dont php+mysql réalise la séparation en lecture et en écriture

MySQL, en tant que l'une des bases de données les plus populaires à l'heure actuelle, est largement utilisé dans les applications. Dans le cas d'une concurrence élevée et d'un volume de données important, en raison de performances de concurrence de lecture et d'écriture insuffisantes de MySQL, afin d'améliorer les performances de concurrence de MySQL, la séparation de lecture et d'écriture est devenue une solution nécessaire.

Le principe de la séparation de lecture et d'écriture est de placer les opérations de lecture et d'écriture sur différentes instances MySQL, de sorte que la charge des opérations de lecture et d'écriture puisse être supportée respectivement par différentes instances MySQL, atteignant ainsi l'objectif d'amélioration des performances de la base de données.

PHP, en tant que langage dynamique populaire, est très étroitement intégré à MySQL. Ainsi, cet article expliquera comment utiliser PHP pour obtenir une séparation en lecture et en écriture MySQL.

PHP implémente la séparation lecture-écriture MySQL et doit implémenter les fonctions suivantes :

1 Différencier les opérations de lecture et d'écriture : dans le code PHP, les opérations de base de données doivent être distinguées et les opérations de lecture et d'écriture sont placées dans des positions différentes. Instances MySQL supérieures.

2. Stratégie d'équilibrage de charge : Il est nécessaire de mettre en œuvre une stratégie d'équilibrage de charge pour répartir uniformément les requêtes de lecture sur différentes instances MySQL selon différents algorithmes.

Ci-dessous, nous présenterons en détail comment implémenter les fonctions ci-dessus.

Distinguer les opérations de lecture et d'écriture

La mise en œuvre de la séparation en lecture et en écriture de MySQL nécessite la prise en charge de la technologie de réplication maître-esclave MySQL. Dans la réplication maître-esclave MySQL, toutes les opérations d'écriture sont envoyées à la base de données maître, tandis que la base de données esclave n'effectue que des opérations de lecture.

Dans le code PHP, les opérations de lecture et d'écriture MySQL doivent être distinguées. Les opérations d'écriture sont envoyées à la bibliothèque principale, tandis que les opérations de lecture sont envoyées à la bibliothèque esclave.

Les deux méthodes suivantes peuvent être utilisées pour une implémentation spécifique :

1. Connexion de commutation manuelle : implémentez manuellement les connexions de commutation pour les opérations de lecture et d'écriture dans le code. Connectez-vous respectivement à la base de données principale et à la base de données esclave et exécutez les instructions SQL correspondantes sur différentes instances MySQL connectées selon vos besoins.

Par exemple, pour l'instruction SQL suivante :

SELECT * FROM users WHERE age>18;

Le code suivant peut être utilisé pour implémenter la connexion de commutation pour l'opération de lecture :

//生成一个读取从库的连接
$slaveConn = mysqli_connect($slaveHost, $slaveUser, $slavePass, $dbName);
mysqli_query($slaveConn, "SET NAMES utf8");

//查询数据
$result = mysqli_query($slaveConn, "SELECT * FROM users WHERE age>18");

De même, pour l'opération d'écriture :

INSERT INTO users (name,age,sex) VALUES ('jack',18,'male');

Le code suivant peut être utilisé pour implémentez la connexion de commutation pour l'opération d'écriture :

//生成一个写入主库的连接
$masterConn = mysqli_connect($masterHost, $masterUser, $masterPass, $dbName);
mysqli_query($masterConn, "SET NAMES utf8");

//插入数据
$result = mysqli_query($masterConn, "INSERT INTO users (name,age,sex) VALUES ('jack',18,'male')");

Dans le code ci-dessus, la fonction mysqli_connect est utilisée pour générer une connexion à la base de données et la méthode mysqli_query est utilisée pour faire fonctionner la base de données MySQL. Parmi eux, $slaveHost, $slaveUser et $slavePass sont les informations de connexion de la bibliothèque esclave, et $masterHost, $masterUser et $masterPass sont les informations de connexion de la bibliothèque principale.

2. Utilisez le framework : dans le framework PHP, vous pouvez utiliser l'implémentation intégrée du framework pour basculer entre les opérations de lecture et d'écriture. Par exemple, dans le framework Yii2, vous pouvez utiliser le code suivant pour basculer entre les opérations de lecture et d'écriture :

//生成一个读取从库的连接
$slaveConn = Yii::$app->slaveDb->getConnection();

//查询数据
$query = new \yii\db\Query();
$result = $query->from('users')->where(['age' > 18])->all($slaveConn);

De même, utilisez le code suivant pour basculer entre les opérations d'écriture :

//生成一个写入主库的连接
$masterConn = Yii::$app->masterDb->getConnection();

//插入数据
$result = Yii::$app->db->createCommand()->insert('users', [
'name' => 'jack',
'age' => 18,
'sex' => 'male'
])->execute($masterConn);

Dans le code ci-dessus, Yii::$app ->slaveDb et Yii ::$app->masterDb sont des composants de connexion à la base de données intégrés du framework Yii2, fournissant des méthodes de lecture à partir de la bibliothèque esclave et d'écriture dans la bibliothèque maître.

Stratégie d'équilibrage de charge

Pour la mise en œuvre de la séparation en lecture et en écriture MySQL, l'équilibrage de charge est un élément très important. Ce n'est que si toutes les demandes de lecture sont réparties uniformément sur chaque base de données esclave que les avantages de la séparation en lecture et en écriture de MySQL peuvent être pleinement utilisés.

Les stratégies d'équilibrage de charge couramment utilisées incluent :

1. Stratégie aléatoire : distribuer de manière aléatoire les requêtes de lecture à chaque base de données esclave.

2. Stratégie de polling : allouez les requêtes de lecture à chaque bibliothèque esclave à tour de rôle et utilisez-les de manière cyclique.

3. Stratégie de priorité de disponibilité : utilisez une méthode de surveillance de la disponibilité pour sélectionner les bibliothèques esclaves disponibles avant les opérations de lecture.

Cet article adopte une stratégie d'interrogation et l'implémentation spécifique est la suivante :

//从库连接信息
$slave1 = array(
'host' => 'slave1.host.com', 
'user' => 'slave1user', 
'pass' => 'slave1pass',
'name' => 'dbname'
);

$slave2 = array(
'host' => 'slave2.host.com', 
'user' => 'slave2user', 
'pass' => 'slave2pass',
'name' => 'dbname'
);

$slave3 = array(
'host' => 'slave3.host.com', 
'user' => 'slave3user', 
'pass' => 'slave3pass',
'name' => 'dbname'
);


//增加从库列表
$slaveList = array($slave1, $slave2, $slave3);


//轮询获取从库连接信息
function getSlaveConn() {
global $slaveList;
static $index = 0;
if ($index >= count($slaveList)) {
    $index = 0;
}
$slave = $slaveList[$index];
$index++;
$conn = mysqli_connect($slave['host'], $slave['user'], $slave['pass'], $slave['name']);
mysqli_query($conn, "SET NAMES utf8");
return $conn;
}

Dans le code ci-dessus, $slave1, $slave2, $slave3 sont les informations de connexion à la bibliothèque esclave et $slaveList est la liste des bibliothèques esclaves. Dans la fonction getSlaveConn, $index est le nombre de connexions à la bibliothèque esclave. Lorsque le nombre de connexions est égal à la longueur de la liste des bibliothèques esclaves, $index est remis à zéro et la connexion est reconnectée depuis la première bibliothèque esclave. Chaque fois que vous vous connectez, utilisez la fonction mysqli_connect pour générer une connexion à la base de données et vous connecter à une base de données esclave.

Grâce à l'implémentation ci-dessus, la fonction PHP consistant à réaliser la séparation en lecture et en écriture MySQL a été implémentée. Vous pouvez utiliser le code ci-dessus pour implémenter la fonction de séparation lecture-écriture MySQL dans les applications PHP et ajouter ou modifier des stratégies d'équilibrage de charge si nécessaire.

Dans le cas d'une concurrence élevée et d'un volume de données important, l'utilisation de PHP pour séparer la lecture et l'écriture de MySQL peut améliorer efficacement les performances de lecture et d'écriture de la base de données MySQL, réduire le temps de réponse de l'application et améliorer l'expérience utilisateur.

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!