Redis常用技术----事务

秃头哥编程

发布于 2019-06-11 17:38:18

4410

发布于 2019-06-11 17:38:18

文章被收录于专栏：秃头哥编程

一、事务

Redis的事务是使用MULTI-EXEC的命令组合，使用它可以提供两个重要的保证：

事务是一个被隔离的操作，事务中的方法都会被Redis进行序列化并按顺序执行，事务在执行的过程中不会被其他客户端发生的命令所打断。
事务是一个原子性的操作，它要么全部执行，要么全部不执行。

在Redis中使用事务会经过三个过程：

开启事务
命令进入队列
执行事务

在spring中要使用同一个连接操作Redis命令的场景，这时可以使用Spring提供的SessionCallback接口。

package com.codeliu.transaction;

import java.util.List;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.redis.core.RedisOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.SessionCallback;

/**
 * 测试Redis事务命令
 * @author liu
 */
public class TestTransaction {

    @SuppressWarnings({ "resource", "rawtypes", "unchecked" })
    @Test
    public void testTransaction() {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
        RedisTemplate rt = (RedisTemplate)applicationContext.getBean("redisTemplate");
        @SuppressWarnings("unused")
        SessionCallback callBack = (SessionCallback)(RedisOperations ops)->{
            ops.multi();
            ops.boundValueOps("key1").set("value1");
            // 由于命令只是入队列而没有执行，所以此处采用get命令，value返回为null
            String value = (String)ops.boundValueOps("key1").get();
            System.out.println(value);
            // list会保存之前入队列的所有命令执行结果
            // 执行事务
            List<String> list = ops.exec();
            for(String l:list) {
                System.out.println(l);
            }
            // 事务结束后，再获取value
            value = (String)ops.boundValueOps("key1").get();
            return value;
        };
        // 执行redis命令
        String value = (String)rt.execute(callBack);
        System.out.println(value);
    }
}