详解Redis 分布式锁遇到的序列化问题
场景描述
最近使用 Redis 遇到了一个类似分布式锁的场景，跟 Redis 实现分布式锁类比一下，就是释放锁失败，也就是缓存删不掉。又踩了一个 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<Long> 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<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(redisConnectionFactory);
// 使用 Jackson2JsonRedisSerialize 替换默认序列化
Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer
= new Jackson2JsonRedisSerializer<>(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
// 设置 key、value 的序列化规则（尤其是 value）
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}
StringRedisTemplate 的配置是 SpringBoot 默认的，即：
@Configuration
@ConditionalOnClass({RedisOperations.class})
@EnableConfigurationProperties({RedisProperties.class})
@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})
public class RedisAutoConfiguration {
public RedisAutoConfiguration() {
}
@Bean
@ConditionalOnMissingBean
public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
StringRedisTemplate template = new StringRedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
}
PS: SpringBoot 版本为 2.1.13.RELEASE
点进去 StringRedisTemplate 看下：
public class StringRedisTemplate extends RedisTemplate<String, String> {
public StringRedisTemplate() {
// 注意这里的序列化设置
setKeySerializer(RedisSerializer.string());
setValueSerializer(RedisSerializer.string());
setHashKeySerializer(RedisSerializer.string());
setHashValueSerializer(RedisSerializer.string());
}
// ...
}
注意下序列化设置，继续跟进，看到底是什么方式：
public interface RedisSerializer<T> {
static RedisSerializer<String> string() {
return StringRedisSerializer.UTF_8;
}
}
public class StringRedisSerializer implements RedisSerializer<String> {
public static final StringRedisSerializer UTF_8 = new StringRedisSerializer(StandardCharsets.UTF_8);
// ...
}
可以看到，StringRedisTemplate 的 key 和 value 默认都是用 StringRedisSerializer(StandardCharsets.UTF_8) 进行序列化的。
而 RedisTemplate 的 key 使用 StringRedisSerializer，value 使用的是 Jackson2JsonRedisSerializer 序列化（至于为什么用这个，这里就不是我写的了）。
到这里，基本可以定位到问题所在了：就是 RedisTemplate 的 value 序列化和 StringRedisTemplate 不一致。
如果改成一致就可以了吗？验证一下试试。
验证推论
把 RedisTemplate 的 value 序列化方式修改为 StringRedisSerializer：
@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
// ...
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new StringRedisSerializer());
// ...
return redisTemplate;
}
}
再调用两种加锁逻辑，看下 k1、k2 的值：
可以看到，v1 的双引号没了，释放锁的服务也能正常删掉了。
嗯，就是这里的问题。
至于两者序列化的源码，有兴趣的盆友们可以继续研究，这里就不再深入探讨了。
小结
本文遇到的这个问题，主要是因为使用了不同的 RedisTemplate 来加锁和释放锁，而这两个 template 使用了不同的序列化方式，最终还是序列化带来的问题。
当初真是草率了，而且一时还没测出来……
对于生产环境，还是要慎之又慎：如临深渊，如履薄冰。
到此这篇关于Redis 分布式锁遇到的序列化问题的文章就介绍到这了,更多相关Redis 分布式锁遇到的序列化问题内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
Redis HyperLogLog数据统计轻量级解决方案详解
这篇文章主要为大家介绍了Redis HyperLogLog数据统计轻量级解决方案详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-12-12
限流就是限制API访问频率,当访问频率超过某个阈值时进行拒绝访问等操作,本文主要介绍了Redis和Nginx实现限制接口请求频率的示例,具有一定的参考价值,感兴趣的可以了解一下2024-02-02
这篇文章主要介绍了Redis实现信息已读未读状态提示的相关资料,需要的朋友可以参考下2016-04-04
内存碎片是redis服务中分配器分配存储对象内存的时产生的,下面这篇文章主要给大家介绍了关于Redis内存碎片处理的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2022-05-05
这篇文章主要介绍了使用redis获取自增序列号实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
开发中,一般会使用Redis缓存一些常用的热点数据用来减少数据库IO,提高系统的吞吐量,本文将给大家介绍了Redis与MySQL数据一致性问题的策略模式及解决方案,文中通过代码示例介绍的非常详细,需要的朋友可以参考下2024-07-07
这篇文章主要介绍了Redis集群下过期key监听的实现代码，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下2019-09-09
Redis缓存的过期策略是保证缓存可靠性和性能的关键之一,本文主要介绍了Redis缓存过期的实现示例,具有一定的参考价值,感兴趣的可以了解一下2023-12-12
这篇文章主要介绍了redis模糊批量清除key的操作方法，包括命令行删除和golang代码删除，本文结合示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-12-12
这篇文章主要介绍了Redis总结笔记（二）：C#连接Redis简单例子,需要的朋友可以参考下2015-01-01
最新评论