SpringBoot+Redis执行lua脚本的方法步骤
1、背景
有时候，我们需要一次性操作多个Redis命令，但是这样的多个操作不具备原子性，而且Redis的事务也不够强大，不支持事务的回滚，还无法实现命令之间的逻辑关系计算。所以，一般在开发中，我们会利用lua脚本来实现Redis的事务。
2、lua脚本
Redis中使用lua脚本，我们需要注意的是，从Redis2.6.0后才支持lua脚本的执行。
使用lua脚本的好处：
- 原子操作：lua脚本是作为一个整体执行的，所以中间不会被其他命令插入。
- 减少网络开销：可以将多个请求通过脚本的形式一次发送，减少网络时延。
- 复用性：lua脚本可以常驻在redis内存中，所以在使用的时候，可以直接拿来复用，也减少了代码量。
3、Redis中执行lua脚本
1、命令格式：
EVALscriptnumkeyskey[key...]arg[arg...]
说明：
- script是第一个参数，为Lua5.1脚本(字符串)。
- 第二个参数numkeys指定后续参数有几个key。
- key[key...]，被操作的key，可以多个，在lua脚本中通过KEYS[1],KEYS[2]获取
- arg[arg...]，参数，可以多个，在lua脚本中通过ARGV[1],ARGV[2]获取。
2、如果直接使用redis-cli命令：
redis-cli--evallua_filekey1key2,arg1arg2arg3
说明：
- eval命令后不再是lua脚本的字符串形式，而是一个lua脚本文件。后缀为.lua
- 不再需要numkeys参数，而是用,隔开多个key和多个arg
4、使用RedisTemplate执行lua脚本
例子：删除Redis分布式锁
引入依赖：此依赖为我们整合了Redis，并且提供了非常好用的RedisTemplate。
org.springframework.boot spring-boot-starter-data-redis
方式一：lua脚本文件
1、新建lua脚本文件：
ifredis.call("get",KEYS[1])==ARGV[1]then
returnredis.call("del",KEYS[1])
else
return0
end
说明：先获取指定key的值，然后和传入的arg比较是否相等，相等值删除key，否则直接返回0。
2、代码测试：
/**
*@authorHowinfun
*@desclua测试
*@date2019/11/5
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ActiveProfiles("test")
@SpringBootTest(classes=ThirdPartyServerApplication.class)
publicclassRedisTest{
@Autowired
privateStringRedisTemplateredisTemplate;
@Test
publicvoidcontextLoads(){
StringlockKey="123";
StringUUID=cn.hutool.core.lang.UUID.fastUUID().toString();
booleansuccess=redisTemplate.opsForValue().setIfAbsent(lockKey,UUID,3,TimeUnit.MINUTES);
if(!success){
System.out.println("锁已存在");
}
//执行lua脚本
DefaultRedisScriptredisScript=newDefaultRedisScript<>();
//指定lua脚本
redisScript.setScriptSource(newResourceScriptSource(newClassPathResource("redis/DelKey.lua")));
//指定返回类型
redisScript.setResultType(Long.class);
//参数一：redisScript，参数二：key列表，参数三：arg（可多个）
Longresult=redisTemplate.execute(redisScript,Collections.singletonList(lockKey),UUID);
System.out.println(result);
}
}
方式二：直接编写lua脚本（字符串）
1、代码测试：
/**
*@authorHowinfun
*@desclua脚本测试
*@date2019/11/5
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ActiveProfiles("test")
@SpringBootTest(classes=ThirdPartyServerApplication.class)
publicclassRedisTest{
/**释放锁lua脚本*/
privatestaticfinalStringRELEASE_LOCK_LUA_SCRIPT="ifredis.call('get',KEYS[1])==ARGV[1]thenreturnredis.call('del',KEYS[1])elsereturn0end";
@Autowired
privateStringRedisTemplateredisTemplate;
@Test
publicvoidcontextLoads(){
StringlockKey="123";
StringUUID=cn.hutool.core.lang.UUID.fastUUID().toString();
booleansuccess=redisTemplate.opsForValue().setIfAbsent(lockKey,UUID,3,TimeUnit.MINUTES);
if(!success){
System.out.println("锁已存在");
}
//指定lua脚本，并且指定返回值类型
DefaultRedisScriptredisScript=newDefaultRedisScript<>(RELEASE_LOCK_LUA_SCRIPT,Long.class);
//参数一：redisScript，参数二：key列表，参数三：arg（可多个）
Longresult=redisTemplate.execute(redisScript,Collections.singletonList(lockKey),UUID);
System.out.println(result);
}
}
注意：可能会有同学发现，为什么返回值不用Integer接收而是用Long。这里是因为spring-boot-starter-data-redis提供的返回类型里面不支持Integer。
大家可以看看源码：
/**
*RepresentsadatatypereturnedfromRedis,currentlyusedtodenotetheexpectedreturntypeofRedisscripting
*commands
*
*@authorJenniferHickey
*@authorChristophStrobl
*/
publicenumReturnType{
/**
*ReturnedasBoolean
*/
BOOLEAN,
/**
*Returnedas{@linkLong}
*/
INTEGER,
/**
*Returnedas{@linkList
所以当我们使用Integer作为返回值的时候，是报以下错误：
org.springframework.data.redis.RedisSystemException:Redisexception;nestedexceptionisio.lettuce.core.RedisException:java.lang.IllegalStateException
atorg.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:74)
atorg.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:41)
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。