Comment réaliser la séparation en lecture et en écriture en php+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. différents MySQL sur l'instance.

Vous devez concevoir une solution d'équilibrage de charge pour répartir uniformément les demandes de lecture sur plusieurs instances MySQL en utilisant 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 effectuées dans la base de données maître, tandis que seules les opérations de lecture sont effectuées dans la base de données esclave.

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 la base de données principale et la base de données esclave sur différentes instances MySQL selon vos besoins et exécutez les instructions SQL correspondantes.

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 maître.

Vous pouvez utiliser l'implémentation intégrée dans le framework PHP pour basculer entre les opérations de lecture et d'écriture. Dans le framework Yii2, le code suivant peut être utilisé 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 à une bibliothèque esclave, utilisez la fonction mysqli_connect pour vous connecter à la base de données.

Grâce à l'implémentation ci-dessus, la fonction PHP consistant à réaliser la séparation en lecture et en écriture de 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!