<!--使用redisson作為分布式鎖-->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.16.8</version>
        </dependency>

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 MyRedissonConfig {
    /**
     * 所有對Redisson的使用都是通過RedissonClient對象
     * @return
     */
    @Bean(destroyMethod = "shutdown")
    public RedissonClient redissonClient(){
        // 創(chuàng)建配置 指定redis地址及節(jié)點信息
        Config config = new Config();
        config.useSingleServer().setAddress("XXX.XX.XX.X(redis地址):端口").setPassword("xxxxxxxxx");

        // 根據(jù)config創(chuàng)建出RedissonClient實例
        RedissonClient redissonClient = Redisson.create(config);
        return redissonClient;
    }

}

 @Autowired
    RedissonClient redissonClient;


    @Test
    void redisson(){
        System.out.println(redissonClient);
    }

RLock lock = redisson.getLock("anyLock");
// 最常見的使用方法
lock.lock();

@ResponseBody
    @GetMapping("/hello")
    public String hello() {
        // 1.獲取一把鎖，只要鎖的名字一樣，就是同一把鎖
        RLock lock = redisson.getLock("my-lock");
        lock.lock(); // 阻塞式等待。默認加的鎖是30s時間
        try {
            // 1、鎖的自動續(xù)期，運行期間自動給鎖續(xù)上新的30s，無需擔心業(yè)務時間長，鎖過期會自動被釋放
            // 2、加鎖的業(yè)務只要運行完成，就不會給當前鎖續(xù)期，即使不手動釋放鎖，鎖默認在30s后自動釋放，避免死鎖
            System.out.println("加鎖成功，執(zhí)行業(yè)務代碼..."+Thread.currentThread().getId());
            Thread.sleep(30000);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            System.out.println("釋放鎖..."+Thread.currentThread().getId());
            lock.unlock();
        }
        return "Hello!";
    }

    
    @Autowired
    RedissonClient redisson;

    @Autowired
    RedisTemplate redisTemplate;

    @ResponseBody
    @GetMapping("/write")
    public String writeValue(){
        RReadWriteLock lock = redisson.getReadWriteLock("rw-lock");
        RLock rLock = lock.writeLock();
        String s = "";
        try {
            s = UUID.randomUUID().toString();
            // 模擬業(yè)務時間    
            Thread.sleep(30000);
        } catch (Exception e){

        }finally {
            rLock.unlock();
        }
        redisTemplate.opsForValue().set("writeValue",s);
        return s;
    }

    @GetMapping(value = "/read")
    @ResponseBody
    public String readValue() {
        String s = "";
        RReadWriteLock readWriteLock = redisson.getReadWriteLock("rw-lock");
        //加讀鎖
        RLock rLock = readWriteLock.readLock();
        try {
            rLock.lock();
            s = (String) redisTemplate.opsForValue().get("writeValue");

            TimeUnit.SECONDS.sleep(10);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            rLock.unlock();
        }
        return s;
    }

    @GetMapping(value = "/park")
    @ResponseBody
    public String park() {
        RSemaphore park = redisson.getSemaphore("park");
        try {
            park.acquire();// 獲取一個信號量（redis中信號量值-1）,如果redis中信號量為0了，則在這里阻塞住，直到信號量大于0，可以拿到信號量，才會繼續(xù)執(zhí)行。
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        return "ok";
    }

    @GetMapping(value = "/go")
    @ResponseBody
    public String go() {
        RSemaphore park = redisson.getSemaphore("park");
        park.release();  //釋放一個信號量（redis中信號量值+1）
        return "ok";
    }

    @GetMapping(value = "/lockDoor")
    @ResponseBody
    public String lockDoor() throws InterruptedException {
        RCountDownLatch lockDoor = redisson.getCountDownLatch("lockDoor");
        lockDoor.trySetCount(5); // 設置計數(shù)為5
        lockDoor.await(); //等待閉鎖完成
        return "放假啦...";
    }

    @GetMapping(value = "/go/{id}")
    public String go(@PathVariable("id") Integer id)  {
        RCountDownLatch lockDoor = redisson.getCountDownLatch("lockDoor");
        lockDoor.countDown(); // 計數(shù)減1
        return id+"班都走光了";
    }