快捷導(dǎo)航

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

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

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

依賴

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

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

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

    }


}

這里有三個(gè)參數(shù)

waitTime ----等待時(shí)間
leaseTime ----超時(shí)施放時(shí)間
TimeUnit ----時(shí)間單位

等待時(shí)間

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

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

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

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

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

超時(shí)施放時(shí)間

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

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