欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Redis實(shí)現(xiàn)分布式鎖的幾種方法總結(jié)

 更新時(shí)間：2017年07月10日 14:37:49   作者：小飛鶴  
這篇文章主要介紹了Redis實(shí)現(xiàn)分布式鎖的幾種方法總結(jié)的相關(guān)資料, Redis實(shí)現(xiàn)與Zookeeper實(shí)現(xiàn)和數(shù)據(jù)庫實(shí)現(xiàn)，需要的朋友可以參考下

Redis實(shí)現(xiàn)分布式鎖的幾種方法總結(jié)

分布式鎖是控制分布式系統(tǒng)之間同步訪問共享資源的一種方式。在分布式系統(tǒng)中，常常需要協(xié)調(diào)他們的動(dòng)作。如果不同的系統(tǒng)或是同一個(gè)系統(tǒng)的不同主機(jī)之間共享了一個(gè)或一組資源，那么訪問這些資源的時(shí)候，往往需要互斥來防止彼此干擾來保證一致性，在這種情況下，便需要使用到分布式鎖。

我們來假設(shè)一個(gè)最簡單的秒殺場景：數(shù)據(jù)庫里有一張表，column分別是商品ID，和商品ID對(duì)應(yīng)的庫存量，秒殺成功就將此商品庫存量-1?，F(xiàn)在假設(shè)有1000個(gè)線程來秒殺兩件商品，500個(gè)線程秒殺第一個(gè)商品，500個(gè)線程秒殺第二個(gè)商品。我們來根據(jù)這個(gè)簡單的業(yè)務(wù)場景來解釋一下分布式鎖。

通常具有秒殺場景的業(yè)務(wù)系統(tǒng)都比較復(fù)雜，承載的業(yè)務(wù)量非常巨大，并發(fā)量也很高。這樣的系統(tǒng)往往采用分布式的架構(gòu)來均衡負(fù)載。那么這1000個(gè)并發(fā)就會(huì)是從不同的地方過來，商品庫存就是共享的資源，也是這1000個(gè)并發(fā)爭搶的資源，這個(gè)時(shí)候我們需要將并發(fā)互斥管理起來。這就是分布式鎖的應(yīng)用。

1.實(shí)現(xiàn)分布式鎖的幾種方案

    1.Redis實(shí)現(xiàn)   (推薦)
    2.Zookeeper實(shí)現(xiàn)
    3.數(shù)據(jù)庫實(shí)現(xiàn)

Redis實(shí)現(xiàn)分布式鎖
*
* 在集群等多服務(wù)器中經(jīng)常使用到同步處理一下業(yè)務(wù)，這是普通的事務(wù)是滿足不了業(yè)務(wù)需求，需要分布式鎖
*
* 分布式鎖的常用3種實(shí)現(xiàn)：
*        0.數(shù)據(jù)庫樂觀鎖實(shí)現(xiàn)
*        1.Redis實(shí)現(xiàn)  --- 使用redis的setnx()、get()、getset()方法，用于分布式鎖，解決死鎖問題
*        2.Zookeeper實(shí)現(xiàn)
*           參考：http://surlymo.iteye.com/blog/2082684
*              http://www.dbjr.com.cn/article/103617.htm
*              http://www.hollischuang.com/archives/1716?utm_source=tuicool&utm_medium=referral
*          1、實(shí)現(xiàn)原理：
基于zookeeper瞬時(shí)有序節(jié)點(diǎn)實(shí)現(xiàn)的分布式鎖，其主要邏輯如下（該圖來自于IBM網(wǎng)站）。大致思想即為：每個(gè)客戶端對(duì)某個(gè)功能加鎖時(shí)，在zookeeper上的與該功能對(duì)應(yīng)的指定節(jié)點(diǎn)的目錄下，生成一個(gè)唯一的瞬時(shí)有序節(jié)點(diǎn)。判斷是否獲取鎖的方式很簡單，只需要判斷有序節(jié)點(diǎn)中序號(hào)最小的一個(gè)。當(dāng)釋放鎖的時(shí)候，只需將這個(gè)瞬時(shí)節(jié)點(diǎn)刪除即可。同時(shí)，其可以避免服務(wù)宕機(jī)導(dǎo)致的鎖無法釋放，而產(chǎn)生的死鎖問題。
2、優(yōu)點(diǎn)
鎖安全性高，zk可持久化
3、缺點(diǎn)
性能開銷比較高。因?yàn)槠湫枰獎(jiǎng)討B(tài)產(chǎn)生、銷毀瞬時(shí)節(jié)點(diǎn)來實(shí)現(xiàn)鎖功能。
4、實(shí)現(xiàn)
可以直接采用zookeeper第三方庫curator即可方便地實(shí)現(xiàn)分布式鎖
*
* Redis實(shí)現(xiàn)分布式鎖的原理：
*  1.通過setnx(lock_timeout)實(shí)現(xiàn)，如果設(shè)置了鎖返回1， 已經(jīng)有值沒有設(shè)置成功返回0
*  2.死鎖問題：通過實(shí)踐來判斷是否過期，如果已經(jīng)過期，獲取到過期時(shí)間get(lockKey)，然后getset(lock_timeout)判斷是否和get相同，
*   相同則證明已經(jīng)加鎖成功，因?yàn)榭赡軐?dǎo)致多線程同時(shí)執(zhí)行g(shù)etset(lock_timeout)方法，這可能導(dǎo)致多線程都只需getset后，對(duì)于判斷加鎖成功的線程，
*   再加expire(lockKey, LOCK_TIMEOUT, TimeUnit.MILLISECONDS)過期時(shí)間，防止多個(gè)線程同時(shí)疊加時(shí)間，導(dǎo)致鎖時(shí)效時(shí)間翻倍
*  3.針對(duì)集群服務(wù)器時(shí)間不一致問題，可以調(diào)用redis的time()獲取當(dāng)前時(shí)間

2.Redis分分布式鎖的代碼實(shí)現(xiàn)

  1.定義鎖接口

package com.jay.service.redis; 
 
/** 
 * Redis分布式鎖接口 
 * Created by hetiewei on 2017/4/7. 
 */ 
public interface RedisDistributionLock { 
  /** 
   * 加鎖成功，返回加鎖時(shí)間 
   * @param lockKey 
   * @param threadName 
   * @return 
   */ 
  public long lock(String lockKey, String threadName); 
 
  /** 
   * 解鎖， 需要更新加鎖時(shí)間，判斷是否有權(quán)限 
   * @param lockKey 
   * @param lockValue 
   * @param threadName 
   */ 
  public void unlock(String lockKey, long lockValue, String threadName); 
 
  /** 
   * 多服務(wù)器集群，使用下面的方法，代替System.currentTimeMillis()，獲取redis時(shí)間，避免多服務(wù)的時(shí)間不一致問題！?。?
   * @return 
   */ 
  public long currtTimeForRedis(); 
}

   2.定義鎖實(shí)現(xiàn)

package com.jay.service.redis.impl; 
 
import com.jay.service.redis.RedisDistributionLock; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.dao.DataAccessException; 
import org.springframework.data.redis.connection.RedisConnection; 
import org.springframework.data.redis.core.RedisCallback; 
import org.springframework.data.redis.core.StringRedisTemplate; 
import org.springframework.data.redis.serializer.RedisSerializer; 
 
import java.util.concurrent.TimeUnit; 
 
/** 
 * Created by hetiewei on 2017/4/7. 
 */ 
public class RedisLockImpl implements RedisDistributionLock { 
 
  //加鎖超時(shí)時(shí)間，單位毫秒， 即：加鎖時(shí)間內(nèi)執(zhí)行完操作，如果未完成會(huì)有并發(fā)現(xiàn)象 
  private static final long LOCK_TIMEOUT = 5*1000; 
 
  private static final Logger LOG = LoggerFactory.getLogger(RedisLockImpl.class); 
 
  private StringRedisTemplate redisTemplate; 
 
  public RedisLockImpl(StringRedisTemplate redisTemplate) { 
    this.redisTemplate = redisTemplate; 
  } 
 
  /** 
   * 加鎖 
   * 取到鎖加鎖，取不到鎖一直等待知道獲得鎖 
   * @param lockKey 
   * @param threadName 
   * @return 
   */ 
  @Override 
  public synchronized long lock(String lockKey, String threadName) { 
    LOG.info(threadName+"開始執(zhí)行加鎖"); 
    while (true){ //循環(huán)獲取鎖 
      //鎖時(shí)間 
      Long lock_timeout = currtTimeForRedis()+ LOCK_TIMEOUT +1; 
      if (redisTemplate.execute(new RedisCallback<Boolean>() { 
        @Override 
        public Boolean doInRedis(RedisConnection redisConnection) throws DataAccessException { 
          //定義序列化方式 
          RedisSerializer<String> serializer = redisTemplate.getStringSerializer(); 
          byte[] value = serializer.serialize(lock_timeout.toString()); 
          boolean flag = redisConnection.setNX(lockKey.getBytes(), value); 
          return flag; 
        } 
      })){ 
        //如果加鎖成功 
        LOG.info(threadName +"加鎖成功 ++++ 111111"); 
        //設(shè)置超時(shí)時(shí)間，釋放內(nèi)存 
        redisTemplate.expire(lockKey, LOCK_TIMEOUT, TimeUnit.MILLISECONDS); 
        return lock_timeout; 
      }else { 
        //獲取redis里面的時(shí)間 
        String result = redisTemplate.opsForValue().get(lockKey); 
        Long currt_lock_timeout_str = result==null?null:Long.parseLong(result); 
        //鎖已經(jīng)失效 
        if (currt_lock_timeout_str != null && currt_lock_timeout_str < System.currentTimeMillis()){ 
          //判斷是否為空，不為空時(shí)，說明已經(jīng)失效，如果被其他線程設(shè)置了值，則第二個(gè)條件判斷無法執(zhí)行 
          //獲取上一個(gè)鎖到期時(shí)間，并設(shè)置現(xiàn)在的鎖到期時(shí)間 
          Long old_lock_timeout_Str = Long.valueOf(redisTemplate.opsForValue().getAndSet(lockKey, lock_timeout.toString())); 
          if (old_lock_timeout_Str != null && old_lock_timeout_Str.equals(currt_lock_timeout_str)){ 
            //多線程運(yùn)行時(shí)，多個(gè)線程簽好都到了這里，但只有一個(gè)線程的設(shè)置值和當(dāng)前值相同，它才有權(quán)利獲取鎖 
            LOG.info(threadName + "加鎖成功 ++++ 22222"); 
            //設(shè)置超時(shí)間，釋放內(nèi)存 
            redisTemplate.expire(lockKey, LOCK_TIMEOUT, TimeUnit.MILLISECONDS); 
 
            //返回加鎖時(shí)間 
            return lock_timeout; 
          } 
        } 
      } 
 
      try { 
        LOG.info(threadName +"等待加鎖， 睡眠100毫秒"); 
//        TimeUnit.MILLISECONDS.sleep(100); 
        TimeUnit.MILLISECONDS.sleep(200); 
      } catch (InterruptedException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
 
  /** 
   * 解鎖 
   * @param lockKey 
   * @param lockValue 
   * @param threadName 
   */ 
  @Override 
  public synchronized void unlock(String lockKey, long lockValue, String threadName) { 
    LOG.info(threadName + "執(zhí)行解鎖==========");//正常直接刪除 如果異常關(guān)閉判斷加鎖會(huì)判斷過期時(shí)間 
    //獲取redis中設(shè)置的時(shí)間 
    String result = redisTemplate.opsForValue().get(lockKey); 
    Long currt_lock_timeout_str = result ==null?null:Long.valueOf(result); 
 
    //如果是加鎖者，則刪除鎖， 如果不是，則等待自動(dòng)過期，重新競爭加鎖 
    if (currt_lock_timeout_str !=null && currt_lock_timeout_str == lockValue){ 
      redisTemplate.delete(lockKey); 
      LOG.info(threadName + "解鎖成功------------------"); 
    } 
  } 
 
  /** 
   * 多服務(wù)器集群，使用下面的方法，代替System.currentTimeMillis()，獲取redis時(shí)間，避免多服務(wù)的時(shí)間不一致問題?。。?
   * @return 
   */ 
  @Override 
  public long currtTimeForRedis(){ 
    return redisTemplate.execute(new RedisCallback<Long>() { 
      @Override 
      public Long doInRedis(RedisConnection redisConnection) throws DataAccessException { 
        return redisConnection.time(); 
      } 
    }); 
  } 
 
}

  3.分布式鎖驗(yàn)證      

@RestController 
@RequestMapping("/distribution/redis") 
public class RedisLockController { 
 
  private static final String LOCK_NO = "redis_distribution_lock_no_"; 
 
  private static int i = 0; 
 
  private ExecutorService service; 
 
  @Autowired 
  private StringRedisTemplate redisTemplate; 
 
  /** 
   * 模擬1000個(gè)線程同時(shí)執(zhí)行業(yè)務(wù)，修改資源 
   * 
   * 使用線程池定義了20個(gè)線程 
   * 
   */ 
  @GetMapping("lock1") 
  public void testRedisDistributionLock1(){ 
 
    service = Executors.newFixedThreadPool(20); 
 
    for (int i=0;i<1000;i++){ 
      service.execute(new Runnable() { 
        @Override 
        public void run() { 
          task(Thread.currentThread().getName()); 
        } 
      }); 
    } 
 
  } 
 
  @GetMapping("/{key}") 
  public String getValue(@PathVariable("key") String key){ 
    Serializable result = redisTemplate.opsForValue().get(key); 
    return result.toString(); 
  } 
 
  private void task(String name) { 
//    System.out.println(name + "任務(wù)執(zhí)行中"+(i++)); 
 
    //創(chuàng)建一個(gè)redis分布式鎖 
    RedisLockImpl redisLock = new RedisLockImpl(redisTemplate); 
    //加鎖時(shí)間 
    Long lockTime; 
    if ((lockTime = redisLock.lock((LOCK_NO+1)+"", name))!=null){ 
      //開始執(zhí)行任務(wù) 
      System.out.println(name + "任務(wù)執(zhí)行中"+(i++)); 
      //任務(wù)執(zhí)行完畢 關(guān)閉鎖 
      redisLock.unlock((LOCK_NO+1)+"", lockTime, name); 
    } 
 
  } 
}

4.結(jié)果驗(yàn)證：

      在Controller中模擬了1000個(gè)線程，通過線程池方式提交，每次20個(gè)線程搶占分布式鎖，搶到分布式鎖的執(zhí)行代碼，沒搶到的等待

     結(jié)果如下：

2017-04-07 16:27:17.385 INFO 8652 --- [pool-2-thread-4] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-4等待加鎖， 睡眠100毫秒
2017-04-07 16:27:17.385 INFO 8652 --- [pool-2-thread-7] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-7解鎖成功------------------
    2017-04-07 16:27:17.391 INFO 8652 --- [pool-2-thread-5] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-5加鎖成功 ++++ 111111
pool-2-thread-5任務(wù)執(zhí)行中994
2017-04-07 16:27:17.391 INFO 8652 --- [pool-2-thread-5] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-5執(zhí)行解鎖==========
    2017-04-07 16:27:17.391 INFO 8652 --- [pool-2-thread-1] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-1等待加鎖， 睡眠100毫秒
2017-04-07 16:27:17.391 INFO 8652 --- [pool-2-thread-5] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-5解鎖成功------------------
    2017-04-07 16:27:17.397 INFO 8652 --- [pool-2-thread-6] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-6加鎖成功 ++++ 111111
pool-2-thread-6任務(wù)執(zhí)行中995
2017-04-07 16:27:17.398 INFO 8652 --- [pool-2-thread-6] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-6執(zhí)行解鎖==========
    2017-04-07 16:27:17.398 INFO 8652 --- [pool-2-thread-6] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-6解鎖成功------------------
    2017-04-07 16:27:17.400 INFO 8652 --- [ool-2-thread-19] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-19加鎖成功 ++++ 111111
pool-2-thread-19任務(wù)執(zhí)行中996
2017-04-07 16:27:17.400 INFO 8652 --- [ool-2-thread-19] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-19執(zhí)行解鎖==========
    2017-04-07 16:27:17.400 INFO 8652 --- [ool-2-thread-19] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-19解鎖成功------------------
    2017-04-07 16:27:17.571 INFO 8652 --- [ool-2-thread-11] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-11加鎖成功 ++++ 111111
pool-2-thread-11任務(wù)執(zhí)行中997
2017-04-07 16:27:17.572 INFO 8652 --- [ool-2-thread-11] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-11執(zhí)行解鎖==========
    2017-04-07 16:27:17.572 INFO 8652 --- [ool-2-thread-11] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-11解鎖成功------------------
    2017-04-07 16:27:17.585 INFO 8652 --- [pool-2-thread-4] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-4加鎖成功 ++++ 111111
pool-2-thread-4任務(wù)執(zhí)行中998
2017-04-07 16:27:17.586 INFO 8652 --- [pool-2-thread-4] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-4執(zhí)行解鎖==========
    2017-04-07 16:27:17.586 INFO 8652 --- [pool-2-thread-4] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-4解鎖成功------------------
    2017-04-07 16:27:17.591 INFO 8652 --- [pool-2-thread-1] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-1加鎖成功 ++++ 111111
pool-2-thread-1任務(wù)執(zhí)行中999
2017-04-07 16:27:17.591 INFO 8652 --- [pool-2-thread-1] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-1執(zhí)行解鎖==========
    2017-04-07 16:27:17.591 INFO 8652 --- [pool-2-thread-1] c.jay.service.redis.impl.RedisLockImpl  : pool-2-thread-1解鎖成功------------------

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

相關(guān)文章

  • Redis RDB與AOF持久化方式詳細(xì)講解

    Redis RDB與AOF持久化方式詳細(xì)講解

    Redis是基于內(nèi)存的數(shù)據(jù)結(jié)構(gòu)服務(wù)器，保存了大量的鍵值對(duì)數(shù)據(jù)，所以持久化到磁盤是非常必要的，Redis提供了兩種持久化的方式，分別是RDB和AOF。下面我們看下這兩種持久化方式的具體實(shí)現(xiàn)原理
    2022-11-11
  • 將音頻文件轉(zhuǎn)二進(jìn)制分包存儲(chǔ)到Redis的實(shí)現(xiàn)方法（奇淫技巧操作）

    將音頻文件轉(zhuǎn)二進(jìn)制分包存儲(chǔ)到Redis的實(shí)現(xiàn)方法（奇淫技巧操作）

    這篇文章主要介紹了將音頻文件轉(zhuǎn)二進(jìn)制分包存儲(chǔ)到Redis的實(shí)現(xiàn)方法（奇淫技巧操作），本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-07-07
  • 使用Redis實(shí)現(xiàn)向量相似度搜索

    使用Redis實(shí)現(xiàn)向量相似度搜索

    在自然語言處理領(lǐng)域，有一個(gè)常見且重要的任務(wù)就是文本相似度搜索，所以本文為大家介紹一下如何利用Redis實(shí)現(xiàn)向量相似度搜索，解決文本、圖像和音頻之間的相似度匹配問題，需要的可以了解下
    2023-07-07
  • CentOS Linux系統(tǒng)下安裝Redis過程和配置參數(shù)說明

    CentOS Linux系統(tǒng)下安裝Redis過程和配置參數(shù)說明

    這篇文章主要介紹了CentOS Linux系統(tǒng)下安裝Redis過程和配置參數(shù)說明,需要的朋友可以參考下
    2014-10-10
  • Redis Sentinel實(shí)現(xiàn)哨兵模式搭建小結(jié)

    Redis Sentinel實(shí)現(xiàn)哨兵模式搭建小結(jié)

    這篇文章主要介紹了Redis Sentinel實(shí)現(xiàn)哨兵模式搭建小結(jié)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2018-12-12
  • 使用注解實(shí)現(xiàn)Redis緩存功能

    使用注解實(shí)現(xiàn)Redis緩存功能

    這篇文章主要為大家詳細(xì)介紹了使用注解實(shí)現(xiàn)Redis緩存功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2022-07-07
  • 使用Jedis線程池returnResource異常注意事項(xiàng)

    使用Jedis線程池returnResource異常注意事項(xiàng)

    這篇文章主要介紹了使用Jedis線程池returnResource異常注意事項(xiàng)，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
    2022-03-03
  • Redis搜索日期范圍內(nèi)的查詢示例

    Redis搜索日期范圍內(nèi)的查詢示例

    Redis作為內(nèi)存數(shù)據(jù)結(jié)構(gòu)存儲(chǔ)系統(tǒng),雖未專為日期范圍查詢?cè)O(shè)計(jì),但可通過存儲(chǔ)日期數(shù)據(jù)、使用KEYS命令或有序集合（SortedSet）實(shí)現(xiàn)查詢功能,下面就來介紹一下
    2024-09-09
  • 基于Redis驗(yàn)證碼發(fā)送及校驗(yàn)方案實(shí)現(xiàn)

    基于Redis驗(yàn)證碼發(fā)送及校驗(yàn)方案實(shí)現(xiàn)

    本文主要介紹了基于Redis驗(yàn)證碼發(fā)送及校驗(yàn)方案實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-01-01
  • 淺談Redis位圖(Bitmap)及Redis二進(jìn)制中的問題

    淺談Redis位圖(Bitmap)及Redis二進(jìn)制中的問題

    這篇文章主要介紹了Redis位圖(Bitmap)及Redis二進(jìn)制中的問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2021-07-07

最新評(píng)論