SpringBoot执行Lua脚本

蔚落 2023-01-07 08:54 80阅读 0赞

# 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原理][redis]

它无法直接序列化，所以得指定序列化方式。

[redis]: https://blog.csdn.net/h273979586/article/details/110845962