缓存失效问题和Redis分布式锁

        <dependency>
            <groupId>org.redissongroupId>
            <artifactId>redissonartifactId>
            <version>3.12.0version>
        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;
import java.io.IOException;
 
@Configuration
public class MyRedissonConfig {
    //所有redisson操作都是通过RedissonClient对象操作的
    @Bean(destroyMethod = "shutdown")
    public RedissonClient redisson() throws IOException {
        Config config = new Config();
        //单节点模式
        //可以用"rediss://"来启用 SSL 连接
        config.useSingleServer().setAddress("redis://192.168.56.10:6379");
        return Redisson.create(config);
    }
}

编写测试方法：

    @Autowired
    private RedissonClient redisson;
 
    @ResponseBody
    @GetMapping("/hello")
    public String hello() {
        //1获取一把锁，只要锁名一样就是同一把锁
        RLock lock = redisson.getLock("anyLock");
        //2加锁
        //阻塞式等待，默认加锁30s
        //如果业务超长，锁自动续期30s,而业务一旦完成，就不会继续续期，哪怕不手动解锁，锁也会在默认30s后自动释放，所以不会有死锁问题
        //lock.lock();
        // 加锁以后 10 秒钟自动解锁，但要注意自动解锁时间一定要大于业务执行时间
        // 指定了解锁时间后就不会再自动续期了，未指定的情况下会有一个定时任务，只要当前任务还在占锁，就会一直重新给锁设置过期时间
        // 无需调用 unlock 方法手动解锁
        //lock.lock(10, TimeUnit.SECONDS);
        try{
            // 尝试加锁，最多等待 100 秒，没有则放弃加锁。上锁以后 10 秒自动解锁
            boolean res = lock.tryLock(100, 10, TimeUnit.SECONDS);
            if (res) {
                    System.out.println("加锁成功，执行业务"+Thread.currentThread().getId());
                    Thread.sleep(3000);
            }
        }catch (Exception e){
        }
        finally {
            System.out.println("释放锁"+Thread.currentThread().getId());
            lock.unlock();
        }
 
        return "hello";
    }

读写锁:

    @Autowired
    private RedisTemplate redisTemplate;
 
    @GetMapping("write")
    @ResponseBody
    public String write(){
        RReadWriteLock rwLock = redisson.getReadWriteLock("rw-lock");
        String s = null;
        RLock lock = rwLock.writeLock();
        try{
            //1改数据加写锁，读数据加读锁
            lock.lock();
            s = UUID.randomUUID().toString();
            Thread.sleep(5000);
            redisTemplate.opsForValue().set("writeValue",s);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
        return s;
    }
 
    //保证一定读到最新数据，修改期间写锁是排他锁，读锁是共享锁
    //写锁不释放，读锁就会一直等待写锁解除
    //读+读 相当于无锁，并发读，同时加锁成功
    //写+读 等待写锁释放
    //写+写 阻塞方式
    //读+写 有读锁，写需要等待
    //只要有写，则必然会有等待出现
    @ResponseBody
    @GetMapping("read")
    public String read(){
        RReadWriteLock rwLock = redisson.getReadWriteLock("rw-lock");
        String writeValue = "";
        //加读锁
        RLock lock = rwLock.readLock();
        lock.lock();
        try {
            writeValue = (String) redisTemplate.opsForValue().get("writeValue");
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
        return writeValue;
    }

信号量:

    //信号量可用于分布式限流
    //事先在redis里存park，值为3，每次访问park的值减1，减到0后就会一直等待park的值大于0
    @GetMapping("park")
    @ResponseBody
    public String park(){
        RSemaphore park = redisson.getSemaphore("park");
        boolean b = false;
        try {
            //park.acquire();//获取一个信号量，阻塞式等待
            b = park.tryAcquire();//尝试获取一个信号量
            if(b){
                //执行业务
            }else {
                return "error";
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "ok==>"+b;
    }
 
    @GetMapping("go")
    @ResponseBody
    public String go(){
        RSemaphore park = redisson.getSemaphore("park");
        try {
            park.release();//释放一个信号量
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "ok";
    }

闭锁：

    /**
     * 放假锁门
     * 人走完了才锁
     */
    @GetMapping("lockDoor")
    @ResponseBody
    public String lockDoor() throws InterruptedException {
        RCountDownLatch downLatch = redisson.getCountDownLatch("door");
        downLatch.trySetCount(5);//5个班的人都走了才行，每次访问下面的run/id就会减1，到0时本方法执行成功，返回“放假了”
        downLatch.await();
        return "放假了";
    }
 
    @GetMapping("run/{id}")
    @ResponseBody
    public String run(@PathVariable Long id){
        RCountDownLatch downLatch  = redisson.getCountDownLatch("door");
        downLatch.countDown();//计数减1
        return id+"班的人都走了";
    }