SpringBoot执行Lua脚本
Lua
Lua 是一种轻量小巧的脚本语言,用标准C语言编写并以源代码形式开放, 其设计目的是为了嵌入应用程序中,从而为应用程序提供灵活的扩展和定制功能。
- lua执行过程
客户端把整个lua脚本发送给服务器,服务分别执行每个脚本。注:脚本执行过程不会被打断。 - 事务和lua
redis中lua执行不同于事务,redis中事务是基于乐观锁(watch),而lua脚本基于redis单线程执行。
相同点:
都有一致性、隔离性和持久性,但没有实现原子性,无论是redis事务,还是lua脚本,如果执行期间出现运行错误,之前的执行过的命令是不会回滚的。
不同点:
1、redis事务是基于乐观锁,lua脚本是基于redis的单线程执行命令。
2、redis事务的执行原理就是一次命令的批量执行,而lua脚本可以加入自定义逻辑。
RedisTemplate执行lua
DefaultRedisScript<String> rs = new DefaultRedisScript<>("return 'Hello Redis' ", String.class);
//指定传递参数序列化方式
RedisSerializer argsSerializer = redisTemplate.getDefaultSerializer();
//指定返回结果序列化方式
RedisSerializer<String> resultSerializer = redisTemplate.getStringSerializer();
//执行Lua脚本
String res = (String) redisTemplate.execute(rs, argsSerializer, resultSerializer, null);
也可传递多行lua
//注意脚本中KYS[l]和KYS[2] 的写法,它们代表客户端传递的第一个键和第二个键,
//而ARGV[l]和ARGV[2]则表示客户端传递的第一个和第二个参数
String lua = "redis.call ('set', KEYS[1], ARGV[1]) \n"
+ "redis.call ('set', KEYS[2], ARGV[2]) \n "
+ " local str1 = redis.call ('get', KEYS [1]) \n "
+ " local str2 = redis.call ('get', KEYS [2]) \n "
+ " if str1 == str2 then \n "
+ " return 1 \n "
+ " end \n "
+ " return 0 \n ";
lua中KEYS
和ARGV
值从redisTemplate.execute
传递List<K> keys, Object... args
参数中获得。
上面脚本需要两个KEYS和两个ARGV:
redisTemplate.execute(rs, argsSerializer, resultSerializer, Arrays.asList(KYS[l], KYS[2]), ARGV[1], ARGV[1])
执行异常处理
有小伙伴有调用时候没有指定序列化方式直接:
redisTemplate.execute(rs, Arrays.asList(KYS[l], KYS[2]), ARGV[1], ARGV[1])
没有指定充列化方式,返回字符串会提示:
com.fasterxml.jackson.core.JsonParseException: Unrecognized token ‘Hello’: was expecting (JSON String, Number, Array, Object or token ‘null’, ‘true’ or ‘false’)
因为redis中不是直接存储string,是数组形式,——redis原理
它无法直接序列化,所以得指定序列化方式。
还没有评论,来说两句吧...