关系型数据库的事务具备：原子性、隔离性、持久性、一致性。在Redis中也同样拥有事务的概念，本文主要介绍Redis事务的使用、特性。

如何使用Redis事务

Redis中与事务相关的命令有5个，分别是MULTI EXEC DISCARD WATCH UNWATCH。

MULTI命令用于开启事务：

MULTI => "OK"

开启事务后，可以开始执行操作：

SET mykey 1 => "QUEUED"
INCR mykey => "QUEUED"
INCR mykey => "QUEUED"

能看到开启事务后命令的返回都是”QUEUED”，Redis Server收到这些命令后将他们保存在队列中，只有收到EXEC命令才会真正执行：

EXEC 
=> "1) OK"
=> "2) (integer) 2"
=> "3) (integer) 3"

EXEC命令的返回结果是一个Array结构的数据，其中每个元素是事务中执行的命令的结果。�

当执行了MULTI命令和一些操作后，想放弃当前事务，可以使用DISCARD命令，DISCARD命令会清空事务命令队列，并退出事务。

WATCH命令使得Redis事务具有compare-and-set语义，WATCH命令用法：

Client1 > WATCH mykey => "OK"
Client1 > MULTI => "OK"
Client1 > INCR mykey => "OK"

Client2 > INCR mykey => "(integer) 4"

Client1 > EXEC => "nil"

Client1对mykey使用WATCH命令后开启事务，在执行EXEC命令前，Client2修改了mykey的值，Client1执行EXEC命令会失败。

UNWATCH用于解除WATCH命令的限制，UNWATCH没有参数，只能解除所有的watch。

Redis事务的特性

Redis事务提供了以下两点保证：

• 所有事务内的命令都会按照顺序执行，并且事务会被看作是一个单独隔离的操作，执行中不会被其他客户端影响。
• 事务内所有的命令要么都执行，要么都不被执行。

Redis的持久性与使用的持久化机制有关，会放在RDB和AOF处再研究。

这两点保证包含了隔离性与原子性语义。但Redis的原子性与关系数据库原子性还是有一些差别的，差别源于Redis对事务中错误的处理方式。在Redis事务中会出现两类错误：

• 命令语法错误、参数错误等，命令没有进入事务的命令队列，直接就返回错误。
• 命令进入事务的命令队列，但在执行EXEC后出错，例如对错误的数据类型使用了不支持的操作。

客户端可以在事务提交前就感知到第一类错误，一般客户端在收到第一类错误时会discard当前事务。

Redis2.6.5之前的版本在执行EXEC时会忽略第一类错误，执行队列中的其他命令。
Redis2.6.5之后的版本会记录第一类错误，当执行EXEC命令时返回：
(error) EXECABORT Transaction discarded because of previous errors.

对于第二类错误，Redis会忽略失败的命令，继续执行队列中的其他命令。即一个事务内的操作，可能会出现一部分成功，一部分失败的情况。

对于Redis不支持回滚官方的解释是：

• Redis命令失败的情况只有语法错误和对某一数据类型使用了错误的命令。这意味着命令执行失败是因为程序错误，这些错误应该在开发中就被排除，而不是留到线上靠回滚挽救数据。
• Redis之所以简单、快速是因为不需要支持回滚。

Jedis中使用事务

public class JedisTransactions {

    public static void main(String[] args) {
        Jedis jedis = null;
        Pipeline pipeline = null;
        try{
            jedis = new Jedis("localhost", 6379);
            //事务是可以跟pipelining一起使用的
            pipeline = jedis.pipelined();
            //首先设置value的值为100
            pipeline.set("value", "100");
            //设置watch
            pipeline.watch("value");
            //开启事务
            pipeline.multi();
            //递增value 10
            pipeline.incrBy("value", 10);
            //执行错误的操作lpush
            pipeline.lpush("value", "error");
            //再次递增value 10
            pipeline.incrBy("value", 10);
            //执行exec命令,获取"未来"的返回结果
            Response<List<Object>> listResponse = pipeline.exec();
            //执行pipelining
            pipeline.sync();

            List<Object> result = listResponse.get();
            if(result != null && result.size() > 0){
                for(Object o : result){
                    System.out.println(o.toString());
                }
            }

            //虽然事务中第二个操作失败了,但不影响value的值
            System.out.println("\nvalue is " + jedis.get("value"));
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(jedis != null){
                jedis.close();
            }
        }
    }

}

=>

110
redis.clients.jedis.exceptions.JedisDataException: WRONGTYPE Operation against a key holding the wrong kind of value
120

value is 120

事务可以与pipelining一起使用，可以看到第二条命令LPUSH因为数据类型错误失败了，但并没有影响第一条、第三条递增命令。