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

如何利用Redis分布式鎖實現(xiàn)控制并發(fā)操作

 更新時間:2020年09月30日 10:29:16   作者:拉里·佩奇  
這篇文章主要介紹了如何利用Redis分布式鎖實現(xiàn)控制并發(fā)操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧

redis命令解釋

說道Redis的分布式鎖都是通過setNx命令結合getset來實現(xiàn)的,在講之前我們先了解下setNx和getset的意思,在redis官網(wǎng)是這樣解釋的

注:redis的命令都是原子操作

SETNX key value

將 key 的值設為 value ,當且僅當 key 不存在。

若給定的 key 已經(jīng)存在,則 SETNX 不做任何動作。

SETNX 是『SET if Not eXists』(如果不存在,則 SET)的簡寫。

可用版本:

1.0.0+

時間復雜度:

O(1)

返回值:

設置成功,返回 1 。

設置失敗,返回 0 。

redis> EXISTS job    # job 不存在
(integer) 0
redis> SETNX job "programmer" # job 設置成功
(integer) 1
redis> SETNX job "code-farmer" # 嘗試覆蓋 job ,失敗
(integer) 0
redis> GET job     # 沒有被覆蓋
"programmer"

GETSET key value

將給定 key 的值設為 value ,并返回 key 的舊值(old value)。

當 key 存在但不是字符串類型時,返回一個錯誤。

可用版本:

1.0.0+

時間復雜度:

O(1)

返回值:

返回給定 key 的舊值。

當 key 沒有舊值時,也即是, key 不存在時,返回 nil 。

redis> GETSET db mongodb # 沒有舊值,返回 nil
(nil)
redis> GET db
"mongodb"
redis> GETSET db redis  # 返回舊值 mongodb
"mongodb"
redis> GET db
"redis"

代碼示例

注意:為了讓分布式鎖的算法更穩(wěn)鍵些,持有鎖的客戶端在解鎖之前應該再檢查一次自己的鎖是否已經(jīng)超時,再去做DEL操作,因為可能客戶端因為某個耗時的操作而掛起,操作完的時候鎖因為超時已經(jīng)被別人獲得,這時就不必解鎖了。

我們看下代碼涉及以下幾個類,這里有關業(yè)務邏輯相關的只定義了方法沒有具體實現(xiàn),關鍵是學習思路

OrderBiz.java

/**
 * 使用redis鎖來控制并發(fā)搶單
 * @author fuyuwei
 */
public class OrderBiz {
 public int createOrder(){
  // 下單之前的參數(shù)、合法性校驗這里就不在演示
  OrderLock<Boolean> orderLock = new RedisOrderLock<Boolean>("pro-12345678901");
  boolean isSyn = orderLock.isSyn(new OrderLockBiz<Boolean>(){
   @Override
   public Boolean createOrder() {
    // 省去創(chuàng)建訂單邏輯
    return null;
   }
  });
  if(!isSyn){
   BizLogger.info("創(chuàng)建訂單失敗");
  }
  return 0;
 }
}

OrderLock.java

public interface OrderLock<T> {
 public boolean isSyn(OrderLockBiz<T> orderBiz);

}

OrderLockBiz.java

public interface OrderLockBiz<T> {
 public T createOrder();
}

RedisOrderLock.java

public class RedisOrderLock<T> implements OrderLock<T> {

 // 鎖等待超時,防止線程饑餓,永遠沒有入鎖執(zhí)行代碼的機會 
 public static final long timeout = 10000;//ms

 // 鎖持有超時,防止線程在入鎖以后,無限的執(zhí)行下去,讓鎖無法釋放 
 public static final long expireMsecs = 10000;// ms

 public String lockKey = "orderLockKey";

 public Jedis jedis;

 private static volatile JedisPool jedisPool;

 public RedisOrderLock(String lockKey) {
  this.lockKey = lockKey;
 }
 /**
  * 初始化redis 
  * @return
  */
 public Jedis getInstance() {
  if(jedisPool == null) {
   synchronized(RedisOrderLock.class) {
    if(jedisPool == null) {
     JedisPoolConfig config = new JedisPoolConfig();
     config.setMaxIdle(100);
     jedisPool = new JedisPool(config,"localhost",6379, 3000,"test");
    }
   }
  }
  return jedisPool.getResource();
 }

 /**
  * 線程安全的業(yè)務邏輯處理
  */
 @Override
 public boolean isSyn(OrderLockBiz<T> orderBiz) {
  jedis = this.getInstance();
  try {
   // 獲取到鎖
   if(acquire(jedis)){
    // 執(zhí)行創(chuàng)建訂單邏輯
    orderBiz.createOrder();
   }else{
    BizLogger.info("waiting other thread creating");
   }
  } catch (Exception e) {
   BizLogger.error(e,"acquire lock failre");
  }finally{
   // 解鎖
   this.releaseLock(jedis);
  }
  return false;
 }

 /**
  * accqure lock
  * @param jedis
  * @return
  * @throws InterruptedException
  */
 public synchronized boolean acquire(Jedis jedis){
  boolean locked = false;
  while(timeout > 0){
   long expires = System.currentTimeMillis() + expireMsecs + 1;
   // 10秒之后鎖到期
   String expiresStr = String.valueOf(expires);
   // 獲取到鎖
   if(jedis.setnx(lockKey, expiresStr) == 1){
    locked = true;
    return locked;
   }
   // 沒有獲取到鎖
   String oldValue = jedis.get(lockKey);
   // expireMsecs(10秒)鎖的有效期內無法進入if判斷,如果鎖超時了
   if(oldValue != null 
     && Long.parseLong(oldValue) < System.currentTimeMillis()){
    // 如果鎖超時重新設置
    String oldValue_ = jedis.getSet(lockKey, expiresStr);
    // 值相同說明是同一個線程的操作,獲取鎖成功
    if(Long.valueOf(oldValue_) == Long.valueOf(oldValue)){
     locked = true;
    }else{
     // 被其他線程搶先獲取鎖
     locked = false;
    }
   }
   // 鎖沒有超時,繼續(xù)等待
   return false;
  }
 }
 /**
  * 釋放鎖
  * @param jedis
  */
 public synchronized void releaseLock(Jedis jedis){
  try {
   long current = System.currentTimeMillis(); 
   // 避免刪除非自己獲取得到的鎖
   if (current < Long.valueOf(jedis.get(lockKey)))
    jedis.del(lockKey);
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
   // 把用完的連接放到連接池匯中供其他線程調用
   jedisPool.returnResource(jedis);
  }
 }
}

以上這篇如何利用Redis分布式鎖實現(xiàn)控制并發(fā)操作就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • Redis慢查詢日志及慢查詢分析詳解

    Redis慢查詢日志及慢查詢分析詳解

    這篇文章主要為大家介紹了Redis慢查詢日志及慢查詢分析詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-01-01
  • redis 億級數(shù)據(jù)讀取的實現(xiàn)

    redis 億級數(shù)據(jù)讀取的實現(xiàn)

    本文主要介紹了redis 億級數(shù)據(jù)讀取的實現(xiàn),億級數(shù)據(jù)規(guī)模下實現(xiàn)高效的數(shù)據(jù)讀取成為了許多企業(yè)和開發(fā)者面臨的重大挑戰(zhàn),下面就來介紹一下,感興趣的可以了解一下
    2024-08-08
  • Redis?腳本和連接命令示例詳解

    Redis?腳本和連接命令示例詳解

    Redis腳本是一種可以實現(xiàn)復雜任務的腳本語言,可以用來快速履行復雜任務,靈活處理數(shù)據(jù)管理和管理復雜的利用場景,這篇文章主要介紹了Redis?腳本和連接命令,需要的朋友可以參考下
    2023-09-09
  • Redis排序命令Sort深入解析

    Redis排序命令Sort深入解析

    這篇文章主要為大家介紹了Redis排序命令Sort深入解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-12-12
  • redis?bitmap數(shù)據(jù)結構之java對等操作詳解

    redis?bitmap數(shù)據(jù)結構之java對等操作詳解

    bitmap是以其高性能出名。其基本原理是一位存儲一個標識,其他衍生知道咱就不說了,而redis就是以這種原生格式存儲的,這篇文章主要介紹了redis?bitmap數(shù)據(jù)結構之java對等操作,需要的朋友可以參考下
    2022-10-10
  • Redis數(shù)據(jù)一致性問題的三種解決方案

    Redis數(shù)據(jù)一致性問題的三種解決方案

    Redis(Remote?Dictionary?Server?),是一個高性能的基于Key-Value結構存儲的NoSQL開源數(shù)據(jù)庫,大部分公司采用Redis來實現(xiàn)分布式緩存,用來提高數(shù)據(jù)查詢效率,本文就給大家介紹三種Redis數(shù)據(jù)一致性問題的解決方案,需要的朋友可以參考下
    2023-07-07
  • 詳解Redis中的List類型

    詳解Redis中的List類型

    這篇文章主要介紹了Redis中的List類型,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-11-11
  • 淺談Redis內存回收策略

    淺談Redis內存回收策略

    本文主要介紹了淺談Redis內存回收策略,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2023-06-06
  • 一文搞懂Redis最常用String字符串技能

    一文搞懂Redis最常用String字符串技能

    想要一文搞懂Redis最常用字符串技能?你來對地方了,這篇指南將帶你深入淺出,輕松掌握Redis字符串的強大功能,別眨眼,跟我們一起,讓數(shù)據(jù)操作變得前所未有的簡單,需要的朋友可以參考下
    2024-03-03
  • redis分布式鎖的8大坑總結梳理

    redis分布式鎖的8大坑總結梳理

    這篇文章主要介紹了redis分布式鎖的8大坑總結梳理,使用redis的分布式鎖,我們首先想到的可能是setNx命令,文章圍繞setNx命令展開詳細的內容介紹,感興趣的小伙伴可以參考一下
    2022-07-07

最新評論