Redis之相关拓展
- 一、事务
- 1、介绍
- 2、流程
- 3、shell命令
- 3.1 开启事务
- 3.2 放弃事务
- 3.3 编译型异常(代码有问题,命令有错)
- 3.4 运行时异常
- 二、监控(watch)
- 1、锁
- 1.1 悲观锁
- 1.2 乐观锁
- 2、注意
- 2.1 原理
- 2.2 流程
- 三、Jedis
- 1、简介
- 2、依赖
- 2.1 主要依赖
- 2.2 其次依赖
- 2、样例
- 3、基础操作相关命令
- 4、事务相关操作
一、事务
1、介绍
Redis事务本质:一组命令的集合,一个事务中的所有命令都会被序列化,在事务执行过程中,会按照顺序执行。一次性、顺序性、排他性执行一些列的命令
Redis事务没有隔离级的概念
所有的命令在事务中,并没有直接被执行,只有发起执行命令的时候才会执行,
Redis单条命令式保存原子性的,但是事务不保证原子性。
2、流程
开启事务(multi)
命令入队(…)
执行事务(exec)
3、shell命令
3.1 开启事务
# 开启事务
127.0.0.1:6379> multi
OK
# 命令入队
127.0.0.1:6379(TX)> set k1 v1
QUEUED
127.0.0.1:6379(TX)> set k2 v2
QUEUED
127.0.0.1:6379(TX)> get k2
QUEUED
127.0.0.1:6379(TX)> set k3 v3
QUEUED
# 执行事务
127.0.0.1:6379(TX)> exec
1) OK
2) OK
3) "v2"
4) OK
3.2 放弃事务
事务队列中命令都不会被执行
# 开启事务
127.0.0.1:6379> multi
OK
# 命令入队
127.0.0.1:6379(TX)> set k1 v1
QUEUED
127.0.0.1:6379(TX)> set k2 v2
QUEUED
127.0.0.1:6379(TX)> get k2
QUEUED
127.0.0.1:6379(TX)> set k3 v3
QUEUED
# 放弃事务
127.0.0.1:6379(TX)> discard
ok
3.3 编译型异常(代码有问题,命令有错)
事务中所有的命令都不会被执行
3.4 运行时异常
如果事务队列中存在语法性错误,那么执行命令的时候,其他命令是可以正常执行,错误命令抛出异常。
二、监控(watch)
1、锁
1.1 悲观锁
很悲观,认为什么时候都会出问题,对于任何事都会加锁。
1.2 乐观锁
很乐观,认为什么时候都不会出问题,所以不会上锁,更新数据的时候去判断一下,在此期间是否有人修改过这个数据。
获取version
更新的时候比较version
127.0.0.1:6379> set money 100
OK
127.0.0.1:6379> set out 0
OK
# 监视money对象(加乐观锁)
127.0.0.1:6379> watch money
OK
# 事务正常结束,数据期间没有发生变动,这个时候就正常执行成功
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec
1) (integer) 80
2) (integer) 20
2、注意
2.1 原理
使用多线程修改值时,使用watch可以当做redis的乐观锁操作
也就是执行这个线程(A)之前,另外一个线程(B),修改了被监视的对象(C)的值,这个时候,如果这个线程(A)继续执行一些操作,就会导致事务执行失败。除非这个线程(A)先放弃监视这个对象(C),然后再重新监视这个对象(C),执行一些操作后,事务才能执行成功。
2.2 流程
(1)如果发现事务执行失败,就先解锁
unwatch
(2)然后获取新的值,再次监视
watch money
(3)比对监视的值是否发生了变化,如果没有变化,那么可以执行成功,如果变化就执行失败。
exec
三、Jedis
1、简介
jedis基于java语言的redis客户端,集成了redis的命令操作,提供了连接池管理。
2、依赖
2.1 主要依赖
用来进行redis连接
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<!-- jedis库 -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.2.3</version>
</dependency>
2.2 其次依赖
用来进行json操作
<!--HUTool工具-->
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.9</version>
</dependency>
2、样例
@Test
void contextLoads() {
// 1、new jedis对象
Jedis jedis = new Jedis("127.0.0.1",6379);
System.out.println(jedis.ping());
}
结果
3、基础操作相关命令
由于之前博客写了非常完整的命令,Redis之2022最全五大基本数据类型相关知识及shell命令
所以下面关于jedis的操作大致写一下,仅作理解使用
@Test
void testAll(){
// 1、new jedis对象
Jedis jedis = new Jedis("127.0.0.1",6379);
System.out.println("清空数据:" + jedis.flushDB());
System.out.println("新增键值对:" + jedis.set("name", "zhangsan"));
System.out.println("判断某个数据是否存在:" + jedis.exists("name"));
System.out.println("查看系统中所有的键:");
Set<String> keys = jedis.keys("*");
System.out.println(keys);
System.out.println("删除键:" + jedis.del("name"));
}
结果
4、事务相关操作
@Test
void test2(){
// 1、new jedis对象
Jedis jedis = new Jedis("124.223.218.196",6379);
jedis.flushDB();
JSONObject jsonObject = new JSONObject();
jsonObject.set("hello", "world");
jsonObject.set("name", "zhangsan");
// 开启事务
Transaction multi = jedis.multi();
String result = jsonObject.toString();
try{
multi.set("user1", result);
multi.set("user2", result);
// 执行事务
multi.exec();
}catch (Exception e) {
// 放弃事务
multi.discard();
e.printStackTrace();
}finally {
System.out.println(jedis.get("user1"));
System.out.println(jedis.get("user2"));
// 关闭连接
jedis.close();
}
}
结果