Commandes d'opération de transaction Redis et opérations d'exécution (code)-tutoriel mysql-php.cn

Commandes d'opération de transaction Redis et opérations d'exécution (code)

不言

Libérer： 2018-09-19 16:06:01

original

2403 Les gens l'ont consulté

Ce que cet article vous apporte concerne les commandes et les opérations d'exécution (code) des opérations de transaction Redis. Il a une certaine valeur de référence. Les amis dans le besoin peuvent s'y référer.

Préface

Cet article étudie principalement le fonctionnement transactionnel de redis

commande

multi et exec

Ligne de commande

127.0.0.1:6379> multi
OK
127.0.0.1:6379> incr total
QUEUED
127.0.0.1:6379> incr len
QUEUED
127.0.0.1:6379> exec
1) (integer) 2
2) (integer) 2
127.0.0.1:6379> get total
"2"
127.0.0.1:6379> get len
"2"

Copier après la connexion

instance de laitue

    @Test
    public void testMultiExec(){
        RedisClient client = RedisClient.create("redis://192.168.99.100:6379/0");
        StatefulRedisConnection<String, String> connection = client.connect();
        RedisCommands<String, String> syncCommands = connection.sync();

        syncCommands.set("hello","1");
        syncCommands.set("world","2");

        syncCommands.multi();
        syncCommands.incr("hello");
        syncCommands.incr("world");

        //DefaultTransactionResult[wasRolledBack=false,result=[1, 2, 1, 3, 1]]
        TransactionResult transactionResult = syncCommands.exec();
        System.out.println(transactionResult);
        System.out.println(syncCommands.get("hello"));
        System.out.println(syncCommands.get("world"));
    }

Copier après la connexion

Exécution partielle

Ligne de commande

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a hello
QUEUED
127.0.0.1:6379> set b world
QUEUED
127.0.0.1:6379> incr a
QUEUED
127.0.0.1:6379> set c part
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) (error) ERR value is not an integer or out of range
4) OK
127.0.0.1:6379> get a
"hello"
127.0.0.1:6379> get b
"world"
127.0.0.1:6379> get c
"part"

Copier après la connexion

instance de laitue

    @Test
    public void testMultiExecError(){
        RedisClient client = RedisClient.create("redis://192.168.99.100:6379/0");
        StatefulRedisConnection<String, String> connection = client.connect();
        RedisCommands<String, String> syncCommands = connection.sync();

        syncCommands.multi();
        syncCommands.set("a","hello");
        syncCommands.set("b","world");
        syncCommands.incr("a");
        syncCommands.set("c","part");
        //DefaultTransactionResult[wasRolledBack=false,result=[OK, OK, io.lettuce.core.RedisCommandExecutionException: ERR value is not an integer or out of range, OK, 1]]
        TransactionResult transactionResult = syncCommands.exec();
        System.out.println(transactionResult);
        System.out.println(syncCommands.get("a"));
        System.out.println(syncCommands.get("b"));
        System.out.println(syncCommands.get("c"));
    }

Copier après la connexion

multi et rejet

Ligne de commande

127.0.0.1:6379> set sum 1
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incr sum
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> get sum
"1"

Copier après la connexion

instance de laitue

    @Test
    public void testMultiDiscard(){
        RedisClient client = RedisClient.create("redis://192.168.99.100:6379/0");
        StatefulRedisConnection<String, String> connection = client.connect();
        RedisCommands<String, String> syncCommands = connection.sync();
        syncCommands.incr("key1");
        syncCommands.multi();
        syncCommands.incr("key1");
        //需要有multi才可以执行discard，成功返回OK
        String result = syncCommands.discard();
        System.out.println(result);
        System.out.println(syncCommands.get("key1"));
    }

Copier après la connexion

vérifier et set

    @Test
    public void testWatch(){
        RedisClient client = RedisClient.create("redis://192.168.99.100:6379/0");
        StatefulRedisConnection<String, String> connection = client.connect();
        RedisCommands<String, String> syncCommands = connection.sync();

        String key = "key";
        syncCommands.watch(key);

        //another connection
        StatefulRedisConnection<String, String> conn2 = client.connect();
        RedisCommands<String, String> syncCommands2 = conn2.sync();
        syncCommands2.set(key, "a");

        syncCommands.multi();
        syncCommands.append(key, "b");
        //DefaultTransactionResult [wasRolledBack=true, responses=0]
        TransactionResult transactionResult = syncCommands.exec();
        System.out.println(transactionResult);

        System.out.println(syncCommands.get(key));
    }

Copier après la connexion

Résumé

reids fournit des instructions multi-exécution/rejet, similaires à l'ouverture d'une transaction de validation/annulation, mais l'exécution ne sera pas lancée lorsqu'elle rencontre des erreurs telles que en tant qu'opérations de type. , la commande qui doit être exécutée avec succès sera toujours exécutée avec succès, et la commande qui devrait échouer échouera toujours
Ce que multi exec garantit, c'est que tant que l'exécutable La commande est exécutée avec succès, une série de commandes dans la transaction peut être exécutée, si exec n'est pas reçu par le serveur en raison de problèmes de réseau, etc., une série de commandes dans la transaction ne sera pas exécutée
discard ne peut être utilisé qu'après avoir appelé multi. Cette commande effacera la file d'attente des transactions en attente d'exécution des commandes.
redis fournit la commande watch, qui peut être utilisée avec. multi exec pour implémenter un mécanisme de verrouillage optimiste similaire à la base de données. Une fois la clé de surveillance utilisée par d'autres. Si le client est mis à jour, toute l'opération d'exécution échoue

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!