1. 程式人生 > >高性能分布式鎖-redisson的使用

高性能分布式鎖-redisson的使用

使用方式 eas 加鎖 group bsp 鎖對象 AC 過期 獲取鎖

1,概述:在一些高並發的場景中,比如秒殺,搶票,搶購這些場景,都存在對核心資源,商品庫存的爭奪,控制不好,庫存數量可能被減少到負數,出現超賣的情況,或者 產生唯一的一個遞增ID,由於web應用部署在多個機器上,簡單的同步加鎖是無法實現的,給數據庫加鎖的話,對於高並發,1000/s的並發,數據庫可能由行鎖變成表鎖,性能下降會厲害。那相對而言,redis的分布式鎖,相對而言,是個很好的選擇,redis官方推薦使用的Redisson就提供了分布式鎖和相關服務。
下面介紹下如何使用Redisson。

2,Redisson的使用方式十分簡單,詳見官方文檔:https://github.com/redisson/redisson/wiki/2.-%E9%85%8D%E7%BD%AE%E6%96%B9%E6%B3%95

3,加入jar包的依賴:

<dependency>
        <groupId>org.redisson</groupId>
        <artifactId>redisson</artifactId>
         <version>2.7.0</version> 
 </dependency>

4,配置Redisson

public class RedissonManager {
    private static Config config = new Config();
    
//聲明redisso對象 private static Redisson redisson = null; //實例化redisson public static void init(String key,String value){ try { //使用單機版配置 config.useSingleServer().setAddress("127.0.0.1:6379"); //得到redisson對象 redisson = (Redisson) Redisson.create(config); }
catch (Exception e){ e.printStackTrace(); } } //獲取redisson對象的方法 public static Redisson getRedisson(){ return redisson; } }

5,鎖的獲取和釋放

public class DistributedRedisLock {
   //從配置類中獲取redisson對象
    private static Redisson redisson = RedissonManager.getRedisson();
    private static final String LOCK_TITLE = "redisLock_";
   //加鎖
    public static boolean acquire(String lockName){
       //聲明key對象
        String key = LOCK_TITLE + lockName;
       //獲取鎖對象
        RLock mylock = redisson.getLock(key);
       //加鎖,並且設置鎖過期時間,防止死鎖的產生
        mylock.lock(2, TimeUnit.MINUTES); 
        System.err.println("======lock======"+Thread.currentThread().getName());
       //加鎖成功
        return  true;
    }
  //鎖的釋放
    public static void release(String lockName){
       //必須是和加鎖時的同一個key
        String key = LOCK_TITLE + lockName;
       //獲取所對象
        RLock mylock = redisson.getLock(key);
      //釋放鎖(解鎖)
        mylock.unlock();
        System.err.println("======unlock======"+Thread.currentThread().getName());
    }
}

6,業務邏輯中使用分布式鎖

@RequestMapping("/redder")
    @ResponseBody
    public String redder() throws IOException{
         String key = "test123";
        //加鎖 
        DistributedRedisLock.acquire(key);
        //執行具體業務邏輯
        dosoming
        //釋放鎖
        DistributedRedisLock.release(key);
       //返回結果
        return soming; 
    }

  

 

  

高性能分布式鎖-redisson的使用