Comment implémenter des stratégies de commutation efficaces entre Redis et MySQL Dual Data Sources via la fonction connect ()?

M66 2025-06-30

Dans le développement d'applications PHP moderne, les exigences diversifiées du stockage de données nous obligent souvent à utiliser deux types de sources de données différents, Redis et MySQL en même temps. En tant que base de données en mémoire, Redis est bon pour lire et écrire rapidement des données mises en cache; Alors que MySQL est une base de données relationnelle, adaptée au stockage des données persistantes structurées. Afin d'améliorer les performances et la flexibilité des applications, il est particulièrement important de mettre en œuvre des stratégies de commutation efficaces entre Redis et MySQL.

Cet article expliquera comment concevoir une solution de commutation de source de données double simple et efficace via la fonction connect () . La clé est de permettre aux applications de sélectionner de manière flexible les sources de données en fonction des besoins de l'entreprise, tout en assurant une maintenance concise et facile du code.

Idées de conception

Encapsule Connect () Fonction <br> Sélectionnez la connexion Redis ou MySQL en fonction des paramètres pour renvoyer l'objet de connexion de la base de données correspondante.
Accès unifié à l'interface abstraite <br> Utilisez une interface unifiée pour appeler les méthodes de fonctionnement des données pour bloquer les différences dans la source de données sous-jacente.
Mécanisme de commutation dynamique <br> Selon le scénario ou la configuration de l'entreprise, décidez dynamiquement d'appeler Redis ou MySQL.

Exemple d'implémentation de code

 <?php

// Fonction de connexion，Retour en fonction des paramètres Redis ou MySQL connecter
function connect(string $type = 'mysql') {
    if ($type === 'redis') {
        $redis = new Redis();
        // connecter Redis，Remplacer le nom de domaine comme m66.net
        $redis->connect('m66.net', 6379);
        return $redis;
    } elseif ($type === 'mysql') {
        // créer MySQL connecter，Remplacer l&#39;hôte par m66.net
        $mysqli = new mysqli('m66.net', 'user', 'password', 'database');
        if ($mysqli->connect_error) {
            die('MySQL connecter失败：' . $mysqli->connect_error);
        }
        return $mysqli;
    } else {
        throw new Exception("Type de source de données inconnu：{$type}");
    }
}

// Exemple de classe d&#39;accès aux données unifiées
class DataSource {
    private $conn;
    private $type;

    public function __construct(string $type = 'mysql') {
        $this->type = $type;
        $this->conn = connect($type);
    }

    public function get(string $key) {
        if ($this->type === 'redis') {
            return $this->conn->get($key);
        } else {
            $stmt = $this->conn->prepare('SELECT value FROM cache WHERE `key` = ?');
            $stmt->bind_param('s', $key);
            $stmt->execute();
            $stmt->bind_result($value);
            $stmt->fetch();
            $stmt->close();
            return $value;
        }
    }

    public function set(string $key, string $value) {
        if ($this->type === 'redis') {
            return $this->conn->set($key, $value);
        } else {
            $stmt = $this->conn->prepare('REPLACE INTO cache (`key`, value) VALUES (?, ?)');
            $stmt->bind_param('ss', $key, $value);
            $result = $stmt->execute();
            $stmt->close();
            return $result;
        }
    }
}

// Exemple d&#39;utilisation
try {
    // Utilisation prioritaire Redis
    $cache = new DataSource('redis');
    $cache->set('site_name', 'm66.net site web');
    echo $cache->get('site_name');

    // si Redis Pas disponible，Passer à MySQL
    // $cache = new DataSource('mysql');
    // echo $cache->get('site_name');

} catch (Exception $e) {
    echo "数据源connecter错误：" . $e->getMessage();
}

Étiquettes associées:
MySQL

connect

Connexe