redisson.tryLock()參數的使用及理解

更新時間：2024年04月29日 10:18:28 作者：九伯都

這篇文章主要介紹了redisson.tryLock()參數的使用,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

依賴

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

配置

package com.hmdp.config;

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RedissonConfig {

    @Bean
    public RedissonClient redissonClient(){

        Config config = new Config();

        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
//        config.useSingleServer().setAddress("redis://127.0.0.1:6379").setPassword("123456");

        return Redisson.create(config);
    }

}

使用

package com.hmdp;

import com.hmdp.entity.SeckillVoucher;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.impl.SeckillVoucherServiceImpl;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;

@SpringBootTest
public class HmDianPingApplicationTests {


    @Resource
    private RedissonClient redissonClient;


    @Test
    public void testRedisson() {

        long shopId = 147852478L;

        /*這樣獲取的是一把 可重入鎖*/
        RLock lock = redissonClient.getLock("lock:order:" + shopId);

        /*等待時間，超時施放時間，時間單位
        * 不傳遞參數默認值是：不等待（-1），30秒*/
        boolean b = lock.tryLock();

        if (!b) {
            System.out.println("獲取鎖失敗");
        }

        try{
            System.out.println("執(zhí)行業(yè)務邏輯");
        }finally {
            lock.unlock();
        }

    }


}

這里有三個參數

waitTime ----等待時間
leaseTime ----超時施放時間
TimeUnit ----時間單位

等待時間

如果ABC…多個線程去搶奪一把鎖，A成功了，如果設置的是 -1，那么BCD。。。。就不等待，直接返回失敗，也就是不再去搶奪鎖了，一次失敗，直接放棄。

如果不是-1，假如說是 10（單位是秒）那么BCD…失敗后會擇機再次去搶奪，這里的擇機搶奪，就代表著不是與A搶奪失敗后的立馬再次搶奪，因為【明知道A搶過鎖之后會執(zhí)行自己的業(yè)務，需要一定的時間，那么

BCD。。。立馬再去搶奪鎖的意義在哪里呢？除了徒增cpu的負擔，沒有太大意義】。所以這里的擇機搶奪，其實是利用了發(fā)布，訂閱機制。

從上面的圖片可以看到，A搶過鎖之后，執(zhí)行業(yè)務，結束之后釋放鎖，釋放鎖的時候還 publish （發(fā)布）了一個信號，而有人發(fā)布，就有人訂閱，發(fā)布人是A，訂閱人是BCD…，所以說這里的擇機再次搶奪是在BCD…接收到A發(fā)布的消息之后再去搶奪。

當然了，從第一次與A搶奪失敗，到等待A完成業(yè)務發(fā)布消息這段等待時間+ 第一次和A搶奪鎖的時間總數不能超過10s，畢竟10s 就是硬性規(guī)定，10s之內，不論發(fā)生多么復雜的邏輯，只要拿到鎖就行，不行就直接放棄。

超時施放時間

就是說 A拿到了鎖之后，如果發(fā)生了一些異常錯誤，內部業(yè)務沒能正常的執(zhí)行，沒能正常執(zhí)行釋放鎖的操作，這個時候這個超時施放時間才會起作用，也就是說，在A搶到鎖之后，即便A的業(yè)務出現了堵塞，但是只要沒發(fā)生一些異常情況，這里的超時施放時間是不起作用的，因為只要不發(fā)生異常，內部就會有一個看門狗，每隔超時施放時間/3就會刷新一次鎖的過期時間（是一個定時任務），確保A能夠執(zhí)行完成業(yè)務，當然，A執(zhí)行完業(yè)務后，會刪除刷新有效期的定時任務。

所以說，超時釋放時間在正常執(zhí)行業(yè)務的時候，是不發(fā)揮作用的，只在出現異常的時候才會起作用。