詳解Redis 分布式鎖遇到的序列化問(wèn)題

更新時(shí)間：2021年03月29日 08:48:02 作者：WriteOnRead

這篇文章主要介紹了Redis 分布式鎖遇到的序列化問(wèn)題,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

場(chǎng)景描述

最近使用 Redis 遇到了一個(gè)類(lèi)似分布式鎖的場(chǎng)景，跟 Redis 實(shí)現(xiàn)分布式鎖類(lèi)比一下，就是釋放鎖失敗，也就是緩存刪不掉。又踩了一個(gè) Redis 的坑……
這是什么個(gè)情況、又是怎樣排查的呢？
本文主要對(duì)此做個(gè)復(fù)盤(pán)。

問(wèn)題排查

既然是釋放鎖有問(wèn)題，那就先看看釋放鎖的代碼吧。

釋放鎖

釋放鎖使用了 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;

刪除腳本中，會(huì)先獲取 Redis key 的舊值，并與入?yún)?value 比較，二者相等時(shí)才會(huì)刪除。
如果釋放成功，也就是 Redis 緩存刪除成功，返回值為 1，否則失敗返回為 0。
乍一看代碼似乎沒(méi)啥問(wèn)題，測(cè)一下試試？
不過(guò)既然要釋放鎖，在此之前肯定要加鎖，先看看加鎖的邏輯吧。

加鎖

說(shuō)到加鎖這里的邏輯，代碼里有兩種實(shí)現(xiàn)方式：

示例代碼一

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);
}

其實(shí)它們的區(qū)別就在于前者使用了 RedisTemplate，而后者使用的是 StringRedisTemplate。

Q: 等等……為什么會(huì)有兩個(gè) template？？
A: 憋說(shuō)了，是我挖的坑，RedisTemplate 是我加的……現(xiàn)在回想都沒(méi)想明白當(dāng)初為什么這樣搞，可能真是腦子一時(shí)抽風(fēng)了。

先測(cè)試一下這兩個(gè)方法？

測(cè)試一下

使用兩種方式分別加鎖，其中：lock01 為 k1 和 v1，lock02 為 k2 和 v2。
分別看下 k1、k2 的值（使用工具：RDM, Redis Desktop Manager）：

可以看到 v1 是有雙引號(hào)的，而 v2 沒(méi)有。
猜測(cè)應(yīng)該是序列化的問(wèn)題，看看 Redis 配置？

RedisTemplate 配置

加鎖那里可以看到，k1 使用了 RedisTemplate，而 k2 是 StringRedisTemplate，它們兩個(gè)的配置有什么區(qū)別呢？
其中 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 替換默認(rèn)序列化
 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);

 // 設(shè)置 key、value 的序列化規(guī)則（尤其是 value）
 redisTemplate.setKeySerializer(new StringRedisSerializer());
 redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
 redisTemplate.afterPropertiesSet();

 return redisTemplate;
 }
}

StringRedisTemplate 的配置是 SpringBoot 默認(rèn)的，即：

@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

點(diǎn)進(jìn)去 StringRedisTemplate 看下：

public class StringRedisTemplate extends RedisTemplate<String, String> {
 
 public StringRedisTemplate() {
 // 注意這里的序列化設(shè)置
 setKeySerializer(RedisSerializer.string());
 setValueSerializer(RedisSerializer.string());
 setHashKeySerializer(RedisSerializer.string());
 setHashValueSerializer(RedisSerializer.string());
 }
 // ...
}

注意下序列化設(shè)置，繼續(xù)跟進(jìn)，看到底是什么方式：

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 默認(rèn)都是用 StringRedisSerializer(StandardCharsets.UTF_8) 進(jìn)行序列化的。

而 RedisTemplate 的 key 使用 StringRedisSerializer，value 使用的是 Jackson2JsonRedisSerializer 序列化（至于為什么用這個(gè)，這里就不是我寫(xiě)的了）。
到這里，基本可以定位到問(wèn)題所在了：就是 RedisTemplate 的 value 序列化和 StringRedisTemplate 不一致。

如果改成一致就可以了嗎？驗(yàn)證一下試試。

驗(yàn)證推論

把 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;
 }
}

再調(diào)用兩種加鎖邏輯，看下 k1、k2 的值：

可以看到，v1 的雙引號(hào)沒(méi)了，釋放鎖的服務(wù)也能正常刪掉了。
嗯，就是這里的問(wèn)題。
至于兩者序列化的源碼，有興趣的盆友們可以繼續(xù)研究，這里就不再深入探討了。

小結(jié)

本文遇到的這個(gè)問(wèn)題，主要是因?yàn)槭褂昧瞬煌?RedisTemplate 來(lái)加鎖和釋放鎖，而這兩個(gè) template 使用了不同的序列化方式，最終還是序列化帶來(lái)的問(wèn)題。
當(dāng)初真是草率了，而且一時(shí)還沒(méi)測(cè)出來(lái)……
對(duì)于生產(chǎn)環(huán)境，還是要慎之又慎：如臨深淵，如履薄冰。

到此這篇關(guān)于Redis 分布式鎖遇到的序列化問(wèn)題的文章就介紹到這了,更多相關(guān)Redis 分布式鎖遇到的序列化問(wèn)題內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: