Redis 分布式锁遇到的序列化问题

这是什么个情况、又是怎样排查的呢?

本文主要对此做个复盘。

问题排查

既然是释放锁有问题，那就先看看释放锁的代码吧。

释放锁

释放锁使用了 Lua 脚本，代码逻辑和 Lua 脚本如下：

释放锁示例代码

public Object release(String key, String value) { 
  Object existedValue = stringRedisTemplate.opsForValue().get(key); 
  log.info("key:{}, value:{}, redis旧值：{}", key, value, existedValue); 
   
  DefaultRedisScript redisScript = new DefaultRedisScript<>(COMPARE_AND_DELETE, Long.class); 
  return stringRedisTemplate.execute(redisScript, Collections.singletonList(key), value); 
} 

释放锁使用的 Lua 脚本

if redis.call('get',KEYS[1]) == ARGV[1] 
then 
    return redis.call('del',KEYS[1]) 
else 
    return 0 
end; 

删除脚本中，会先获取 Redis key 的旧值，并与入参 value 比较，二者相等时才会删除。

如果释放成功，也就是 Redis 缓存删除成功，返回值为 1，否则失败返回为 0。

乍一看代码似乎没啥问题，测一下试试?

不过既然要释放锁，在此之前肯定要加锁，先看看加锁的逻辑吧。

加锁

说到加锁这里的逻辑，代码里有两种实现方式：

示例代码一

public Object lock01(String key, String value) { 
  log.info("lock01, key={}, value={}", key, value); 
  return redisTemplate.opsForValue().setIfAbsent(key, value, LOCKED_TIME, TimeUnit.SECONDS); 
} 

示例代码二

public Object lock02(String key, String value) { 
  log.info("lock02, key={}, value={}", key, value); 
  return stringRedisTemplate.opsForValue().setIfAbsent(key, value, LOCKED_TIME, TimeUnit.SECONDS); 
} 

其实它们的区别就在于前者使用了 RedisTemplate，而后者使用的是 StringRedisTemplate。

• Q: 等等……为什么会有两个 template??
• A: 憋说了，是我挖的坑，RedisTemplate 是我加的……现在回想都没想明白当初为什么这样搞，可能真是脑子一时抽风了。

先测试一下这两个方法?

测试一下

使用两种方式分别加锁，其中：lock01 为 k1 和 v1，lock02 为 k2 和 v2。

分别看下 k1、k2 的值(使用工具：RDM, Redis Desktop Manager)：

可以看到 v1 是有双引号的，而 v2 没有。

猜测应该是序列化的问题，看看 Redis 配置?

RedisTemplate 配置

加锁那里可以看到，k1 使用了 RedisTemplate，而 k2 是 StringRedisTemplate，它们两个的配置有什么区别呢?

其中 RedisTemplate 的配置是自定义的，如下：

@Configuration 
@AutoConfigureAfter(RedisAutoConfiguration.class) 
public class RedisConfig { 
  @Bean 
  public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { 
    RedisTemplate redisTemplate = new RedisTemplate<>(); 
    redisTemplate.setConnectionFactory(redisConnectionFactory); 
 
    // 使用 Jackson2JsonRedisSerialize 替换默认序列化 
    Jackson2JsonRedisSerializer