Quelle est la raison pour laquelle la valeur de retour est vide lors de l'utilisation de Redemplate pour la requête par lots? Comment résoudre ce problème?

Cet article analyse la raison pour laquelle la valeur de retour est vide lors de l'utilisation RedisTemplate de Spring Data Redis pour la requête par lots et fournit des solutions correspondantes. Lorsque vous utilisez la méthode executePipelined pour le fonctionnement GET lots, si le résultat est traité directement à l'intérieur du pipeline, la valeur de retour sera vide. En effet, l'opération de pipeline mettra en cache toutes les commandes et ne sera pas envoyée au serveur Redis jusqu'à ce que executePipelined est appelé et que le traitement interne ne puisse pas obtenir de retours en temps opportun.

Description de la question:

Deux exemples d'erreur sont donnés dans l'article, qui essaient tous deux de traiter les résultats de la commande GET dans l' executePipelined , ce qui entraîne la liste finale renvoyée null .

Analyse des problèmes et solutions:

Le cœur du problème réside dans les caractéristiques asynchrones des opérations de pipeline. L'approche correcte doit être effectuée après que executePipelined renvoie le résultat puis géré uniformément. La première méthode fournie dans cet article désérialise dans une boucle, ce qui détruit l'efficacité des opérations de pipeline. Bien que la deuxième méthode utilise SessionCallback , elle effectue toujours un traitement de résultat dans le pipeline.

Solutions améliorées:

Une méthode batchGetList améliorée est fournie dans l'article, qui utilise correctement la valeur de retour de executePipelined :

 publique<t> Liste<t> Batchgetlist (collection<string> touches) {
    if (CollectionUtil.iSempty (Keys)) {
        renvoyer un nouveau ArrayList  ();
    }

    Liste<object> Résultats = reidemplate.execurePipelined ((connexion de redéconnexion) -> {
        Redéaliseur<string> keySerializer = (redesserializer<string> ) redemplate.getKeySerializer ();
        for (String Key: Keys) {
            connection.get (keySerializer.serialize (key));
        }
        retourner null;
    });

    // Exécuter les résultats du traitement externe dans les résultats de retour des pipelines.
                  .map (result -> (t) reidemplate.getValueSerializer (). Deserialize ((byte []) résultat)))
                  .Collect (collectionners.tolist ());
}</string></string></object></string></t></t>

Cette méthode vérifie d'abord si keys sont vides, puis utilisent executePipelined pour effectuer des opérations GET par lots. La clé est qu'après la fin de l'exécution du pipeline, il utilise Stream pour traverser results et désérialiser chaque résultat à l'aide de redisTemplate.getValueSerializer().deserialize , renvoyant finalement une liste contenant les données correctes. Cela évite la mauvaise pratique de traitement des résultats à l'intérieur du pipeline et garantit que les données de Redis sont correctement récupérées. Il convient de noter que cette méthode suppose que toutes les paires de valeurs clés utilisent le même désérialiseur. S'il existe plusieurs types de données, il doit être ajusté en fonction des conditions réelles.

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!