Spring Boot 集成Redis 的Lua脚本详解

1. 对比Lua脚本方案与Redis自身事务

对比表格

2. 两种运行Lua脚本的方法示例

方法1：直接发送Lua脚本（不缓存）

  
-- Lua脚本：将key1的值加1，并返回新值  
local value = tonumber(redis.call('GET', KEYS[1]))  
redis.call('SET', KEYS[1], value + 1)  
return value + 1  

Java代码：

  
// 直接执行Lua脚本，每次传递脚本内容  
RedisScript<Long> script = new DefaultRedisScript<>(  
    "local v=tonumber(redis.call('GET', KEYS[1])); " +  
    "redis.call('SET', KEYS[1], v+1); return v+1", Long.class);  
Long result = redisTemplate.execute(  
    script, Arrays.asList("key1"), new Object[]{});  

方法2：先缓存SHA1后调用

  
-- 先执行以下脚本缓存到Redis  
// 第一次执行时缓存脚本  
String script = "...（同上）...";  
String sha1 = redisTemplate.execute(new DefaultRedisScript<>(script, Object.class)).getSha();  // 获取SHA1  

// 后续调用时仅传SHA1和参数  
redisTemplate.execute(  
    new DefaultRedisScript<Long>(sha1, Long.class),  
    Arrays.asList("key1"), new Object[]{});  

3. RedisScript接口及子类详解

RedisScript接口方法说明

DefaultRedisScript类

• 构造方法：

  
  new DefaultRedisScript<>(scriptContent, returnType); // 传入脚本内容  
  new DefaultRedisScript<>(sha1, returnType);         // 传入SHA1  
  

• 关键方法：

  
  // 设置脚本内容  
  script.setScriptText("lua script content");  
  // 设置SHA1（需确保脚本已缓存）  
  script.setSha("computed_sha1");  
  // 设置参数数量  
  script.setArgsCount(2);  
  

4. RedisTemplate的execute()方法对比

方法1：默认序列化器

  
// 使用默认序列化器（如StringRedisSerializer）  
public <T> T execute(RedisScript<T> script, List<K> keys, Object... args) { ... }  

// 示例：执行计数器脚本  
RedisScript<Long> script = new DefaultRedisScript<>(  
    "return tonumber(redis.call('INCR', KEYS[1]))", Long.class);  
Long result = redisTemplate.execute(  
    script, Arrays.asList("counter_key"), new Object[]{});  

方法2：自定义序列化器

  
// 自定义参数和结果的序列化方式  
public <T> T execute(RedisScript<T> script,  
    RedisSerializer<?> argsSerializer,  
    RedisSerializer<T> resultSerializer,  
    List<K> keys, Object... args) { ... }  

// 示例：处理JSON参数和结果  
RedisScript<MyObject> script = ...;  
MyObject result = redisTemplate.execute(  
    script,  
    Jackson2JsonRedisSerializer.class,  // 参数序列化器  
    new Jackson2JsonRedisSerializer<>(MyObject.class), // 结果序列化器  
    Arrays.asList("key"),  
    new MyParamObject() // 自定义参数对象  
);  

对比表格