快捷導(dǎo)航

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

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

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

依賴

        <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);

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

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

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

    }


}

這里有三個參數(shù)

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

等待時間

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

如果不是-1，假如說是 10（單位是秒）那么BCD…失敗后會擇機(jī)再次去搶奪，這里的擇機(jī)搶奪，就代表著不是與A搶奪失敗后的立馬再次搶奪，因?yàn)椤久髦繟搶過鎖之后會執(zhí)行自己的業(yè)務(wù)，需要一定的時間，那么

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

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

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

超時施放時間

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

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