redisson概述

1.Redisson是一个在Redis的基础上实现的Java驻内存数据网格In-Memory

Data

Grid2.redisson介绍官方文档地址3.Redisson它不仅提供了一系列的分布式的Java常用对象还提供了许多分布式服务

包括(BitSet,

service)Redisson提供了使用Redis的最简单和最便捷的方法。

Redisson的宗旨是促进使用者对Redis的关注分离Separation

Concern从而让使用者能够将精力更集中地放在处理业务逻辑上。

b.各分布式锁介绍

Java对象实现了java.util.concurrent.locks.Lock接口。

2.如果负责储存这个分布式锁的Redisson节点宕机以后而且这个锁正好处于锁住的状态时这个锁会出现锁死的状态。

为了避免这种情况的发生Redisson内部提供了一个监控锁的看门狗它的作用是在Redisson实例被关闭前不断的延长锁的有效期。

3.默认情况下看门狗检查锁的超时时间是30秒钟也可以通过修改Config.lockWatchdogTimeout来另行指定。

4.RLock对象完全符合Java的Lock规范。

也就是说只有拥有锁的进程才能解锁其他进程解锁则会抛出IllegalMonitorStateException错误。

5.另外Redisson还通过加锁的方法提供了leaseTime的参数来指定加锁的时间。

超过这个时间后锁便自动解开了。

RLock

dependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion3.11.2/version

/dependency2.添加配置

可以用rediss://来启用SSL连接config.useSingleServer().setAddress(redis://172.16.116.100:6379);return

}3.代码中使用

this.redissonClient.getLock(lock);lock.lock();//

stock

this.stockMapper.selectById(1L);//

再减库存if

0){stock.setCount(stock.getCount()

1);this.stockMapper.updateById(stock);}//

释放锁lock.unlock();

1.基于Redis的Redisson分布式可重入公平锁也是实现了java.util.concurrent.locks.Lock接口的一种RLock对象。

2.同时还提供了异步Async、反射式Reactive和RxJava2标准的接口。

3.它保证了当多个Redisson客户端线程同时请求加锁时优先分配给先发出请求的线程。

4.所有请求线程会在一个队列中排队当某个线程出现宕机时Redisson会等待5秒后继续下一个线程也就是说如果前面有5个线程都处于等待状态那么后面的线程会等待至少25秒。

RLock

1.基于Redis的Redisson分布式联锁RedissonMultiLock对象可以将多个RLock对象关联为一个联锁每个RLock对象实例可以来自于不同的Redisson实例。

RLock

redissonInstance1.getLock(lock1);

RLock

redissonInstance2.getLock(lock2);

RLock

redissonInstance3.getLock(lock3);RedissonMultiLock

lock

1.基于Redis的Redisson红锁RedissonRedLock对象实现了Redlock介绍的加锁算法。

2.该对象也可以用来将多个RLock对象关联为一个红锁每个RLock对象实例可以来自于不同的Redisson实例。

RLock

redissonInstance1.getLock(lock1);

RLock

redissonInstance2.getLock(lock2);

RLock

redissonInstance3.getLock(lock3);

RedissonRedLock

1.基于Redis的Redisson分布式可重入读写锁RReadWriteLock

Java对象实现了java.util.concurrent.locks.ReadWriteLock接口。

2.其中读锁和写锁都继承了RLock接口。

3.分布式可重入读写锁允许同时有多个读锁和一个写锁处于加锁状态。

b5-2.编码实现

redisson.getReadWriteLock(anyRWLock);

无需调用unlock方法手动解锁

rwlock.writeLock().tryLock(100,

10,

lock.unlock();添加StockController方法

public

stockService.testWrite();return

测试写;

this.redissonClient.getReadWriteLock(rwLock);rwLock.readLock().lock(10,

TimeUnit.SECONDS);System.out.println(测试读锁。

。

。

。

);//

rwLock.readLock().unlock();return

null;

this.redissonClient.getReadWriteLock(rwLock);rwLock.writeLock().lock(10,

TimeUnit.SECONDS);System.out.println(测试写锁。

。

。

。

);//

rwLock.writeLock().unlock();return

null;

同时访问写一个写完之后等待一会儿约10s另一个写开始同时访问读不用等待先写后读读要等待约10s写完成先读后写写要等待约10s读完成

b6.

1.基于Redis的Redisson的分布式信号量SemaphoreJava对象RSemaphore采用了与java.util.concurrent.Semaphore相似的接口和用法。

2.同时还提供了异步Async、反射式Reactive和RxJava2标准的接口。

RSemaphore

redisson.getSemaphore(semaphore);

semaphore.acquire();

semaphore.release();3.在StockController添加方法

public

testSemaphore(){this.stockService.testSemaphore();return

测试信号量;

this.redissonClient.getSemaphore(semaphore);semaphore.trySetPermits(3);try

{semaphore.acquire();TimeUnit.SECONDS.sleep(5);System.out.println(System.currentTimeMillis());semaphore.release();}

catch

1606960795秒有3次请求进来控制台2有1次控制台3有2次

1606960800秒有3次请求进来控制台1有2次控制台2有1次

b7.

1.基于Redisson的Redisson分布式闭锁CountDownLatchJava对象RCountDownLatch采用了与java.util.concurrent.CountDownLatch相似的接口和用法。

RCountDownLatch

redisson.getCountDownLatch(anyCountDownLatch);

latch.await();//

redisson.getCountDownLatch(anyCountDownLatch);

一个等待一个计数countDown给StockController添加测试方法

public

testLatch(){this.stockService.testLatch();return

public

testCountDown(){this.stockService.testCountDown();return

public

this.redissonClient.getCountDownLatch(latch);latch.trySetCount(6);try

{latch.await();}

this.redissonClient.getCountDownLatch(latch);latch.trySetCount(6);latch.countDown();

}重启测试打开两个页面当第二个请求执行6次之后第一个请求才会执行。