Redis 事务使用详解

一、简介

本文今天主要是Redis的事务的使用，以及redis对应的Java实现该怎么用。因为篇幅问题，我这里写了一个测试类，引入 RedisTemplate对象，后面例子里就不一一引入了。大家理解就行，如果大家还不知道如何通过Spring Boot 整合redis则可以查看我之前的文章：SpringBoot整合redis（redis支持单节点和集群）

package com.alian.datastruct;import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import java.util.List;
import java.util.concurrent.TimeUnit;@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class RedisTransactionTest {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;
}

二、常用方法

2.1、MULTI、EXEC、DISCARD、WATCH、UNWATCH

MULTI 标记一个事务块的开始
EXEC 执行所有事务块内的命令
DISCARD 取消事务，放弃执行事务块内的所有命令
WATCH 监视一个(或多个) key ，如果在事务执行之前这个(或这些) key 被其他命令所改动，那么事务将被打断
UNWATCH 取消 WATCH 命令对所有 key 的监视

一个事务从开始到执行会经历以下三个阶段：

开始事务
命令入队
执行事务

2.2、提交事务

MULTI
命令1
命令2
...
命令n
EXEC

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set name alian
QUEUED
127.0.0.1:6379> set age 28
QUEUED
127.0.0.1:6379> set sex nan
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) OK
127.0.0.1:6379> get name
"alian"
127.0.0.1:6379> get age
"28"
127.0.0.1:6379> get sex
"nan"

Java操作

    @Testpublic void startTransaction() {redisTemplate.delete(Arrays.asList("name", "age", "sex"));redisTemplate.execute(new SessionCallback<List<Object>>() {public List<Object> execute(RedisOperations operations) throws DataAccessException {operations.multi();operations.opsForValue().set("name", "alian");operations.opsForValue().set("age", "28");operations.opsForValue().set("sex", "男");return operations.exec();}});log.info("事务提交后的姓名：{}", redisTemplate.opsForValue().get("name"));log.info("事务提交后的年龄：{}", redisTemplate.opsForValue().get("age"));log.info("事务提交后的性别：{}", redisTemplate.opsForValue().get("sex"));}

事务提交后的姓名：alian
事务提交后的年龄：28
事务提交后的性别：男

2.3、取消事务

MULTI
命令1
命令2
...
命令n
DISCARD

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set orderId 202212230102
QUEUED
127.0.0.1:6379> set title BirthdayCake
QUEUED
127.0.0.1:6379> set price 168
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> get orderId
(nil)
127.0.0.1:6379> get title
(nil)
127.0.0.1:6379> get price
(nil)

Java操作

    @Testpublic void cancelTransaction() {redisTemplate.delete(Arrays.asList("orderId", "title", "price"));redisTemplate.execute(new SessionCallback<List<Object>>() {public List<Object> execute(RedisOperations operations) throws DataAccessException {operations.multi();operations.opsForValue().set("orderId", "202212230102");operations.opsForValue().set("title", "BirthdayCake");operations.opsForValue().set("price", "168");operations.discard();return null;}});log.info("事务取消后的姓名：{}", redisTemplate.opsForValue().get("orderId"));log.info("事务取消后的年龄：{}", redisTemplate.opsForValue().get("title"));log.info("事务取消后的性别：{}", redisTemplate.opsForValue().get("price"));}

事务取消后的姓名：null
事务取消后的年龄：null
事务取消后的性别：null

从这里可以看到，取消事务后，命令都未执行。

2.4、编译时异常

一般是命令写错了或者命令不存在导致，比如不存在的命令

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set name alian
QUEUED
127.0.0.1:6379> set age 28
QUEUED
127.0.0.1:6379> setget sex man    ##故意写错命令
(error) ERR unknown command `setget`, with args beginning with: `sex`, `man`,
127.0.0.1:6379> set hobby write
QUEUED
127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get name
(nil)
127.0.0.1:6379> get age
(nil)
127.0.0.1:6379> get hobby
(nil)

编译时异常后面的命令都执行失败

2.5、运行时异常

一般是类型错误了，比如没有按指定类型获取值，或者是给非数字字符做自增等

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set title basketball
QUEUED
127.0.0.1:6379> set price 239
QUEUED
127.0.0.1:6379> hgetall title    ##title的类型是string不是hash
QUEUED
127.0.0.1:6379> set address shenzhen
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) (error) WRONGTYPE Operation against a key holding the wrong kind of value
4) OK
127.0.0.1:6379> get title
"basketball"
127.0.0.1:6379> get price
"239"
127.0.0.1:6379> get address
"shenzhen"

运行时异常并不影响后面命令的执行。

Redis单条命令是原子性的，但是Redis事务是不保证原子性的，会按照顺序一条条执行

2.6、乐观锁

用一个场景来模拟乐观锁。

终端1，监控key，开启事务
终端1，命令对key操作入队
终端2，命令对key的值进行修改
终端1，提交事务（失败）

终端1

127.0.0.1:6379> set money 0
OK
127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby money 100
QUEUED
127.0.0.1:6379> decrby num 1
QUEUED

初始化数据
监控key，开启事务
命令入队（还未执行）

终端2

127.0.0.1:6379> get money
"0"
127.0.0.1:6379> incrby money 50
(integer) 50

修改监控的值

终端1

127.0.0.1:6379> exec
(nil)
127.0.0.1:6379> get money
"50"
127.0.0.1:6379> get num
"10"

在终端2修改监控值之后，执行事务
发现全部执行失败

正常操作

127.0.0.1:6379> unwatch
OK
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby money 100
QUEUED
127.0.0.1:6379> decrby num 1
QUEUED
127.0.0.1:6379> exec
1) (integer) 150
2) (integer) 9

Redis 事务使用详解相关推荐

Redis事务机制详解
基本概念 1)什么是redis的事务? 简单理解为命令的集合,一个事务中的所有命令都会序列化,按顺序地串行化执行而不会被其它命令插入,不许加塞,并且有如下两个特点: a)事务是一个单独的隔离操作:事务 ...
Redis最全详解（一）——基础介绍
Redis介绍 redis是基于内存可持久化的日志型.Key-Value数据库.redis安装在磁盘,但是数据存储在内存.非关系型数据库NoSql.开源免费,遵守BSD协议,不用关注版权问题. red ...
Redis AOF 持久化详解
来自公众号:程序员历小冰 Redis 是一种内存数据库,将数据保存在内存中,读写效率要比传统的将数据保存在磁盘上的数据库要快很多.但是一旦进程退出,Redis 的数据就会丢失. 为了解决这个问题,Re ...
26.SpringBoot事务注解详解
转自:https://www.cnblogs.com/kesimin/p/9546225.html @Transactional spring 事务注解 1.简单开启事务管理 @EnableTrans ...
转-Redis AOF 持久化详解
转自: https://juejin.cn/post/6844903902991630349 Redis AOF 持久化详解 Redis 是一种内存数据库,将数据保存在内存中,读写效率要比传统的将数据 ...
Spring事务管理详解_基本原理_事务管理方式
Spring事务管理详解_基本原理_事务管理方式 1. 事务的基本原理 Spring事务的本质其实就是数据库对事务的支持,使用JDBC的事务管理机制,就是利用java.sql.Connection对象 ...
[转]Redis内部数据结构详解-sds
本文是<Redis内部数据结构详解>系列的第二篇,讲述Redis中使用最多的一个基础数据结构:sds. 不管在哪门编程语言当中,字符串都几乎是使用最多的数据结构.sds正是在Redis中被 ...
Redis配置文件redis.conf文件详解
Redis配置文件redis.conf文件详解唠嗑这里面的意思只要看得差不多其实就是已经对redis有熟悉的感觉,就比如推塔已经推到别人家的大门~~~~~~~~废话不多说直接开始了知道大家都不 ...
探索Redis设计与实现6：Redis内部数据结构详解——skiplist
Redis内部数据结构详解(6)--skiplist 2016-10-05 本文是<Redis内部数据结构详解>系列的第六篇.在本文中,我们围绕一个Redis的内部数据结构--skipl ...

Redis 事务使用详解

目录

一、简介

二、常用方法

2.1、MULTI、EXEC、DISCARD、WATCH、UNWATCH

2.2、提交事务

2.3、取消事务

2.4、编译时异常

2.5、运行时异常

2.6、乐观锁

Redis 事务使用详解相关推荐

最新文章

热门文章