Tair (Redis® OSS-Compatible):Atténuer les problèmes de clés à forte sollicitation avec la séparation lecture/écriture

Cas d'utilisation

La séparation lecture/écriture convient aux charges de travail qui tolèrent des données légèrement obsolètes lors des pics d'écriture, car les nœuds en lecture seule se répliquent depuis le nœud principal de manière asynchrone, avec un décalage faible mais non nul. Voici quelques scénarios typiques :

• Contenu de page mis en cache : caches HTML pour les pages d'accueil de sites web, actualisés rarement.

• Classements de jeux : classements horaires où un léger délai de mise à jour n'a aucun impact significatif.

• Données de prévisions météorologiques : données fréquemment interrogées et mises à jour selon un calendrier fixe.

Fonctionnement

Tous les nœuds en lecture seule répliquent les données depuis le nœud principal de manière asynchrone, offrant ainsi une cohérence à terme. Le nœud principal traite 100 % des requêtes d'écriture et 1/N des requêtes de lecture, où N représente le nombre total de nœuds (principal + lecture seule). Par exemple, avec un nœud principal et trois nœuds en lecture seule, N vaut 4 et les performances en lecture peuvent être multipliées par 4. Cela permet de réduire la pression sur le processeur, le trafic réseau et la surcharge des connexions sur le nœud principal.

Un composant Proxy intégré achemine automatiquement les requêtes : les requêtes d'écriture sont dirigées vers le nœud principal, tandis que les requêtes de lecture sont distribuées entre les nœuds en lecture seule. Aucune modification du code client n'est nécessaire pour les instances mono-zone.

La séparation lecture/écriture est prise en charge par les architectures standard (principal-réplica) et en cluster. Dans une architecture en cluster, chaque shard de données peut disposer de son propre nœud en lecture seule. Pour plus de détails sur l'architecture, consultez la rubrique Séparation lecture/écriture.

Prérequis

Avant de commencer, assurez-vous de disposer des éléments suivants :

• Une instance déployée en mode cloud-native

• Un type d'instance Redis Open-Source Edition, Tair (Enterprise Edition) optimisé pour la DRAM ou Tair (Enterprise Edition) optimisé pour la mémoire persistante

• Une instance dotée d'au moins 1 Go de mémoire

• Une instance haute disponibilité

Activer la séparation lecture/écriture

Sur la page des détails de l'instance, cliquez sur Node Management dans le volet de navigation de gauche, puis activez l'option Read/write Splitting. Pour des instructions détaillées, consultez la procédure d'activation de la séparation lecture/écriture.

Connecter votre client

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class MasterReadWrite {
    public static void main(String[] args) {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxIdle(200);
        config.setMaxTotal(300);
        config.setTestOnBorrow(false);
        config.setTestOnReturn(false);

        // Primary zone endpoint, port, and password
        String host = "r-bp1vtq8tnrquy****pd.redis.rds.aliyuncs.com";
        int port = 6379;
        String password = "default:Passw***2";

        JedisPool pool = new JedisPool(config, host, port, 3000, password);
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            jedis.set("foo", "bar");
            System.out.println(jedis.get("foo"));
        }
        catch (Exception e) {
            // Handle timeouts or other exceptions.
            e.printStackTrace();
        }
        finally {
            if (jedis != null) {
                jedis.close();
            }
        }
        pool.destroy();    // On application exit, call this method to release connections and resources.
    }
}

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class ReplicaRead {
    public static void main(String[] args) {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxIdle(200);
        config.setMaxTotal(300);
        config.setTestOnBorrow(false);
        config.setTestOnReturn(false);

        // Secondary zone endpoint, port, and password
        String host = "r-bp1vtq8tnrquy****pd.redis.rds.aliyuncs.com";
        int port = 6379;
        String password = "default:Passw***2";

        JedisPool pool = new JedisPool(config, host, port, 3000, password);
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            System.out.println(jedis.get("foo"));
        }
        catch (JedisDataException e) {
            // The secondary zone endpoint is read-only. Catch this exception if a write command is sent by mistake.
            e.getMessage();
        }
        catch (Exception e) {
            // Handle timeouts or other exceptions.
            e.printStackTrace();
        }
        finally {
            if (jedis != null) {
                jedis.close();
            }
        }
        pool.destroy();    // On application exit, call this method to release connections and resources.
    }
}

Rubriques connexes

• Séparation lecture/écriture

• Fonctionnalités de Tair Proxy