日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關閉右側工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Redis 分布式鎖遇到的序列化問題

Redis 分布式鎖遇到的序列化問題

作者： jaxer 2021-03-24 08:41:38

開發(fā)

前端

分布式

Redis 最近使用 Redis 遇到了一個類似分布式鎖的場景，跟 Redis 實現(xiàn)分布式鎖類比一下，就是釋放鎖失敗，也就是緩存刪不掉。又踩了一個 Redis 的坑……本文主要對此做個復盤。

為淮陰等地區(qū)用戶提供了全套網(wǎng)頁設計制作服務，及淮陰網(wǎng)站建設行業(yè)解決方案。主營業(yè)務為成都網(wǎng)站設計、做網(wǎng)站、淮陰網(wǎng)站設計，以傳統(tǒng)方式定制建設網(wǎng)站，并提供域名空間備案等一條龍服務，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

場景描述

最近使用 Redis 遇到了一個類似分布式鎖的場景，跟 Redis 實現(xiàn)分布式鎖類比一下，就是釋放鎖失敗，也就是緩存刪不掉。又踩了一個 Redis 的坑……

這是什么個情況、又是怎樣排查的呢?

本文主要對此做個復盤。

問題排查

既然是釋放鎖有問題，那就先看看釋放鎖的代碼吧。

釋放鎖

釋放鎖使用了 Lua 腳本，代碼邏輯和 Lua 腳本如下：

釋放鎖示例代碼

  
 
 
 
       
  
  
  
  1. public Object release(String key, String value) { 
    2.    
  
  
  
  2.   Object existedValue = stringRedisTemplate.opsForValue().get(key); 
    3.    
  
  
  
  3.   log.info("key:{}, value:{}, redis舊值：{}", key, value, existedValue); 
    4.    
  
  
  
  4.    
    5.    
  
  
  
  5.   DefaultRedisScript redisScript = new DefaultRedisScript<>(COMPARE_AND_DELETE, Long.class); 
    6.    
  
  
  
  6.   return stringRedisTemplate.execute(redisScript, Collections.singletonList(key), value); 
    7.    
  
  
  
  7. } 
    8.

釋放鎖使用的 Lua 腳本

  
 
 
 
       
  
  
  
  1. if redis.call('get',KEYS[1]) == ARGV[1] 
    2.    
  
  
  
  2. then 
    3.    
  
  
  
  3.     return redis.call('del',KEYS[1]) 
    4.    
  
  
  
  4. else 
    5.    
  
  
  
  5.     return 0 
    6.    
  
  
  
  6. end; 
    7.

刪除腳本中，會先獲取 Redis key 的舊值，并與入?yún)?value 比較，二者相等時才會刪除。

如果釋放成功，也就是 Redis 緩存刪除成功，返回值為 1，否則失敗返回為 0。

乍一看代碼似乎沒啥問題，測一下試試?

不過既然要釋放鎖，在此之前肯定要加鎖，先看看加鎖的邏輯吧。

加鎖

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

示例代碼一

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

示例代碼二

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

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

  • Q: 等等……為什么會有兩個 template??
  • A: 憋說了，是我挖的坑，RedisTemplate 是我加的……現(xiàn)在回想都沒想明白當初為什么這樣搞，可能真是腦子一時抽風了。

先測試一下這兩個方法?

測試一下

使用兩種方式分別加鎖，其中：lock01 為 k1 和 v1，lock02 為 k2 和 v2。

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

可以看到 v1 是有雙引號的，而 v2 沒有。

猜測應該是序列化的問題，看看 Redis 配置?

RedisTemplate 配置

加鎖那里可以看到，k1 使用了 RedisTemplate，而 k2 是 StringRedisTemplate，它們兩個的配置有什么區(qū)別呢?

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

  
 
 
 
       
  
  
  
  1. @Configuration 
    2.    
  
  
  
  2. @AutoConfigureAfter(RedisAutoConfiguration.class) 
    3.    
  
  
  
  3. public class RedisConfig { 
    4.    
  
  
  
  4.   @Bean 
    5.    
  
  
  
  5.   public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { 
    6.    
  
  
  
  6.     RedisTemplate redisTemplate = new RedisTemplate<>(); 
    7.    
  
  
  
  7.     redisTemplate.setConnectionFactory(redisConnectionFactory); 
    8.    
  
  
  
  8.  
    9.    
  
  
  
  9.     // 使用 Jackson2JsonRedisSerialize 替換默認序列化 
    10.    
  
  
  
  10.     Jackson2JsonRedisSerializer jackson2JsonRedisSerializer    
  
  
  
  11.         = new Jackson2JsonRedisSerializer<>(Object.class); 
    12.    
  
  
  
  12.  
    13.    
  
  
  
  13.     ObjectMapper objectMapper = new ObjectMapper(); 
    14.    
  
  
  
  14.     objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); 
    15.    
  
  
  
  15.     objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); 
    16.    
  
  
  
  16.     objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); 
    17.    
  
  
  
  17.  
    18.    
  
  
  
  18.     jackson2JsonRedisSerializer.setObjectMapper(objectMapper); 
    19.    
  
  
  
  19.  
    20.    
  
  
  
  20.     // 設置 key、value 的序列化規(guī)則（尤其是 value） 
    21.    
  
  
  
  21.     redisTemplate.setKeySerializer(new StringRedisSerializer()); 
    22.    
  
  
  
  22.     redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); 
    23.    
  
  
  
  23.     redisTemplate.afterPropertiesSet(); 
    24.    
  
  
  
  24.  
    25.    
  
  
  
  25.     return redisTemplate; 
    26.    
  
  
  
  26.   } 
    27.    
  
  
  
  27. } 
    28.   
 
 

    StringRedisTemplate 的配置是 SpringBoot 默認的，即：
      
 
 
 
         
  
  
  
    1. @Configuration 
      2.    
  
  
  
    2. @ConditionalOnClass({RedisOperations.class}) 
      3.    
  
  
  
    3. @EnableConfigurationProperties({RedisProperties.class}) 
      4.    
  
  
  
    4. @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class}) 
      5.    
  
  
  
    5. public class RedisAutoConfiguration { 
      6.    
  
  
  
    6.   public RedisAutoConfiguration() { 
      7.    
  
  
  
    7.   } 
      8.    
  
  
  
    8.  
      9.    
  
  
  
    9.   @Bean 
      10.    
  
  
  
    10.   @ConditionalOnMissingBean 
      11.    
  
  
  
    11.   public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException { 
      12.    
  
  
  
    12.     StringRedisTemplate template = new StringRedisTemplate(); 
      13.    
  
  
  
    13.     template.setConnectionFactory(redisConnectionFactory); 
      14.    
  
  
  
    14.     return template; 
      15.    
  
  
  
    15.   } 
      16.    
  
  
  
    16. } 
      17.   
 
 

    PS: SpringBoot 版本為 2.1.13.RELEASE
    點進去 StringRedisTemplate 看下：
      
 
 
 
         
  
  
  
    1. public class StringRedisTemplate extends RedisTemplate { 
      2.    
  
  
  
    2.      
      3.    
  
  
  
    3.   public StringRedisTemplate() { 
      4.    
  
  
  
    4.     // 注意這里的序列化設置 
      5.    
  
  
  
    5.     setKeySerializer(RedisSerializer.string()); 
      6.    
  
  
  
    6.     setValueSerializer(RedisSerializer.string()); 
      7.    
  
  
  
    7.     setHashKeySerializer(RedisSerializer.string()); 
      8.    
  
  
  
    8.     setHashValueSerializer(RedisSerializer.string()); 
      9.    
  
  
  
    9.   } 
      10.    
  
  
  
    10.   // ... 
      11.    
  
  
  
    11. } 
      12.   
 
 

    注意下序列化設置，繼續(xù)跟進，看到底是什么方式：
      
 
 
 
         
  
  
  
    1. public interface RedisSerializer { 
      2.    
  
  
  
    2.   static RedisSerializer string() { 
      3.    
  
  
  
    3.     return StringRedisSerializer.UTF_8; 
      4.    
  
  
  
    4.   } 
      5.    
  
  
  
    5. } 
      6.   
 
 

      
 
 
 
         
  
  
  
    1. public class StringRedisSerializer implements RedisSerializer { 
      2.    
  
  
  
    2.   public static final StringRedisSerializer UTF_8 = new StringRedisSerializer(StandardCharsets.UTF_8); 
      3.    
  
  
  
    3.     // ... 
      4.    
  
  
  
    4. } 
      5.   
 
 

    可以看到，StringRedisTemplate 的 key 和 value 默認都是用 StringRedisSerializer(StandardCharsets.UTF_8) 進行序列化的。
    而 RedisTemplate 的 key 使用 StringRedisSerializer，value 使用的是 Jackson2JsonRedisSerializer 序列化(至于為什么用這個，這里就不是我寫的了)。
    到這里，基本可以定位到問題所在了：就是 RedisTemplate 的 value 序列化和 StringRedisTemplate 不一致。
    如果改成一致就可以了嗎?驗證一下試試。
    驗證推論
    把 RedisTemplate 的 value 序列化方式修改為 StringRedisSerializer：
      
 
 
 
         
  
  
  
    1. @Configuration 
      2.    
  
  
  
    2. @AutoConfigureAfter(RedisAutoConfiguration.class) 
      3.    
  
  
  
    3. public class RedisConfig { 
      4.    
  
  
  
    4.   @Bean 
      5.    
  
  
  
    5.   public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { 
      6.    
  
  
  
    6.     RedisTemplate redisTemplate = new RedisTemplate<>(); 
      7.    
  
  
  
    7.        
      8.    
  
  
  
    8.     // ... 
      9.    
  
  
  
    9.  
      10.    
  
  
  
    10.     redisTemplate.setKeySerializer(new StringRedisSerializer()); 
      11.    
  
  
  
    11.     redisTemplate.setValueSerializer(new StringRedisSerializer()); 
      12.    
  
  
  
    12.  
      13.    
  
  
  
    13.     // ... 
      14.    
  
  
  
    14.     return redisTemplate; 
      15.    
  
  
  
    15.   } 
      16.    
  
  
  
    16. } 
      17.   
 
 

    再調用兩種加鎖邏輯，看下 k1、k2 的值：
    可以看到，v1 的雙引號沒了，釋放鎖的服務也能正常刪掉了。
    嗯，就是這里的問題。
    至于兩者序列化的源碼，有興趣的盆友們可以繼續(xù)研究，這里就不再深入探討了。
    小結
    本文遇到的這個問題，主要是因為使用了不同的 RedisTemplate 來加鎖和釋放鎖，而這兩個 template 使用了不同的序列化方式，最終還是序列化帶來的問題。
    當初真是草率了，而且一時還沒測出來……
    對于生產(chǎn)環(huán)境，還是要慎之又慎：如臨深淵，如履薄冰。
                                                    
    
                                                網(wǎng)頁名稱：Redis 分布式鎖遇到的序列化問題                                                
    
                                                文章URL：http://www.5511xx.com/article/djecdgc.html