自己网站做搜索引擎优化,营销助手app,东莞规划局,全景网站建设文章目录 一、简介二、集成redissionpom文件redission 配置文件application.yml文件启动类 三、JAVA 操作案例字符串操作哈希操作列表操作集合操作有序集合操作布隆过滤器操作分布式锁操作 四、源码解析 一、简介
Redisson 是一个在 Redis 的基础上实现的 Java 驻内存数据网格… 文章目录 一、简介二、集成redissionpom文件redission 配置文件application.yml文件启动类 三、JAVA 操作案例字符串操作哈希操作列表操作集合操作有序集合操作布隆过滤器操作分布式锁操作 四、源码解析 一、简介
Redisson 是一个在 Redis 的基础上实现的 Java 驻内存数据网格客户端In-Memory Data Grid。它不仅提供了一系列的 redis 常用数据结构命令服务还提供了许多分布式服务例如分布式锁、分布式对象、分布式集合、分布式远程服务、分布式调度任务服务等等。 本文会介绍如何将redission集成到springboot和如何使用 Redisson 操作 Redis 中的字符串、哈希、列表、集合、有序集合以及布隆过滤器和分布式锁等功能并解析源码中其最大亮点的看门狗机制。
二、集成redission
本章内容使用的springboot版本为2.6.3redission-starter版本为3.17.7
pom文件
引入redission相关依赖 dependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-core/artifactIdversion2.12.3/version
/dependencydependencygroupIdcom.fasterxml.jackson.dataformat/groupIdartifactIdjackson-dataformat-yaml/artifactIdversion2.12.3/version
/dependencydependencygroupIdorg.redisson/groupIdartifactIdredisson-spring-boot-starter/artifactIdversion3.17.7/version
/dependency
redission 配置文件
将redission相关的配置抽到单独的一个redission文件放在application.yml的同级目录
# 单节点配置
singleServerConfig:# 连接空闲超时单位毫秒idleConnectionTimeout: 10000# 连接超时单位毫秒connectTimeout: 10000# 命令等待超时单位毫秒timeout: 3000# 命令失败重试次数,如果尝试达到 retryAttempts命令失败重试次数 仍然不能将命令发送至某个指定的节点时将抛出错误。# 如果尝试在此限制之内发送成功则开始启用 timeout命令等待超时 计时。retryAttempts: 3# 命令重试发送时间间隔单位毫秒retryInterval: 1500# 密码没有设置密码时需要注释掉否则会报错# password: redis.shbeta# 单个连接最大订阅数量subscriptionsPerConnection: 5# 客户端名称clientName: axin# 节点地址address: redis://192.168.102.111:6379password: Cidneueopx# 发布和订阅连接的最小空闲连接数subscriptionConnectionMinimumIdleSize: 1# 发布和订阅连接池大小subscriptionConnectionPoolSize: 50# 最小空闲连接数connectionMinimumIdleSize: 32# 连接池大小connectionPoolSize: 64# 数据库编号database: 1# DNS监测时间间隔单位毫秒dnsMonitoringInterval: 5000
# 线程池数量,默认值: 当前处理核数量 * 2
threads: 0
# Netty线程池数量,默认值: 当前处理核数量 * 2
nettyThreads: 0
# 编码
codec: !org.redisson.codec.JsonJacksonCodec {}
# 传输模式
transportMode : NIO# 配置看门狗的默认超时时间为30s这里改为 10s
lockWatchdogTimeout: 10000application.yml文件
在该配置文件将redission配置文件引入
spring:redis:redisson:file: classpath:redisson.yml启动类
启动类需要加上注解ImportAutoConfiguration如下所示
SpringBootApplication
ImportAutoConfiguration(RedissonAutoConfiguration.class)
public class EasyUserApplication {public static void main(String[] args) {SpringApplication.run(EasyUserApplication.class, args);}
}三、JAVA 操作案例
字符串操作
Redisson 支持通过RBucket对象来操作字符串或对象对象需要实现序列化Serializable数据结构同时支持设置数据和有效期例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opString)
public void opString() {RBucketString strKey redissonClient.getBucket(strKey);strKey.set(china);//表示10分钟后删除该键strKey.expire(Duration.ofMinutes(10));System.out.println(strKey.get());
}哈希操作
通过获取一个RMap 对象来进行哈希数据结构的操作例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opMap)
public void opMap() {//获取一个map对象RMapString, String rMap redissonClient.getMap(mapKey);rMap.put(wawa, 1212);//表示10分钟后删除该键rMap.expire(Duration.ofMinutes(10));System.out.println(rMap.get(wawa));
}列表操作
redission支持通过RList对象来操作列表数据结构例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opList)
public void opList() {RListInteger rList redissonClient.getList(listKey);rList.add(100);rList.add(200);rList.add(300);//表示10分钟后删除该键rList.expire(Duration.ofMinutes(10));//读取列表全部数据不删除System.out.println(rList.readAll());
}集合操作
Redisson支持通过RSet对象来操作集合例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opSet)
public void opSet() {RSetInteger rSet redissonClient.getSet(setKey);rSet.add(100);rSet.add(200);rSet.add(300);//表示10分钟后删除该键rSet.expire(Duration.ofMinutes(10));System.out.println(rSet.readAll());log.info(testSkyworking);
}有序集合操作
Redisson 支持通过RSortedSet对象来操作有序集合数据结构如果使用存储对象则实体对象必须先实现Comparable接口并重写比较逻辑否则会报错例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opSortSet)
public void opSortSet() {RSortedSetInteger rSortSet redissonClient.getSortedSet(sortsetKey);rSortSet.add(300);rSortSet.add(200);rSortSet.add(100);System.out.println(rSortSet.readAll());
}布隆过滤器操作
Redisson支持通过RBloomFilter对象来操作布隆过滤器布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都比一般的算法要好的多缺点是有一定的误识别率和删除困难例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opBloomFilter)
public void opBloomFilter() {RBloomFilter rBloomFilter redissonClient.getBloomFilter(BloomFilterKey);// 初始化预期插入的数据量为50000和期望误差率为0.01rBloomFilter.tryInit(50000, 0.01);rBloomFilter.add(300);rBloomFilter.add(200);rBloomFilter.add(100);//表示100分钟后删除该键rBloomFilter.expire(Duration.ofMinutes(100));// 判断是否存在System.out.println(rBloomFilter.contains(300));System.out.println(rBloomFilter.contains(700));
}分布式锁操作
其实很多时候我们引入redission最想使用的功能场景就是其分布式锁因为我们不需要去设置最大释放锁的时间redission内部有一个看门狗机制会主动去续期。 Redisson通过RLock对象来操作分布式锁例子如下
Autowired
RedissonClient redissonClient;GetMapping(/opLock)
public void opLock() {//获取锁对象实例final String lockKey mylock;RLock rLock redissonClient.getLock(lockKey);try {//尝试5秒内获取锁 不设置释放锁的时间boolean res rLock.tryLock(5L, TimeUnit.SECONDS);System.out.println(获取锁成功);if (res) {for (int i 0; i 10; i) {System.out.println(i);Thread.sleep(1000L);}//成功获得锁在这里处理业务System.out.println(处理业务);}} catch (Exception e) {System.out.println(获取锁失败失败原因 e.getMessage());} finally {//无论如何, 最后都要解锁rLock.unlock();}
}四、源码解析
分布式锁的看门狗机制大致如下列流程图所示 调用链路 org.redisson.RedissonLock#tryLock》org.redisson.RedissonLock#tryLockAsync》org.redisson.RedissonLock#tryAcquireAsync
我们来仔细看看org.redisson.RedissonLock#tryAcquireAsync
private T RFutureLong tryAcquireAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId) {RFuture ttlRemainingFuture;//判断锁的持有时间是否由用户自定义if (leaseTime 0L) {ttlRemainingFuture this.tryLockInnerAsync(waitTime, leaseTime, unit, threadId, RedisCommands.EVAL_LONG);} else {//当用户没有自定义锁占有时间时默认传入 internalLockLeaseTime //private long lockWatchdogTimeout 30 * 1000; 默认30秒ttlRemainingFuture this.tryLockInnerAsync(waitTime, this.internalLockLeaseTime, TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_LONG);}CompletionStageLong f ttlRemainingFuture.thenApply((ttlRemaining) - {if (ttlRemaining null) {if (leaseTime 0L) {//如果用户传入占用时间直接转换把默认值internalLockLeaseTime 更新为用户自定义的占有时间this.internalLockLeaseTime unit.toMillis(leaseTime);} else {//这里就是触发看门狗机制的方法只有当 leaseTime -1时才会触发看门狗机制this.scheduleExpirationRenewal(threadId);}}return ttlRemaining;});return new CompletableFutureWrapper(f);
}接着进行scheduleExpirationRenewal
protected void scheduleExpirationRenewal(long threadId) {RedissonBaseLock.ExpirationEntry entry new RedissonBaseLock.ExpirationEntry();//EXPIRATION_RENEWAL_MAP 是一个全局的静态常量MapRedissonBaseLock.ExpirationEntry oldEntry (RedissonBaseLock.ExpirationEntry)EXPIRATION_RENEWAL_MAP.putIfAbsent(this.getEntryName(), entry);if (oldEntry ! null) {//oldEntry ! null 表示该线程不是第一次触发oldEntry.addThreadId(threadId);} else {//oldEntry null 表示该线程是第一次触发entry.addThreadId(threadId);try {//更新过期时间this.renewExpiration();} finally {if (Thread.currentThread().isInterrupted()) {this.cancelExpirationRenewal(threadId);}}}}org.redisson.RedissonBaseLock#renewExpiration中主要是更新时间的详细逻辑
private void renewExpiration() {//获取当前线程的更新对象RedissonBaseLock.ExpirationEntry ee (RedissonBaseLock.ExpirationEntry)EXPIRATION_RENEWAL_MAP.get(this.getEntryName());if (ee ! null) {//创建了一个定时任务Timeout task this.getServiceManager().newTimeout(new TimerTask() {public void run(Timeout timeout) throws Exception {RedissonBaseLock.ExpirationEntry ent (RedissonBaseLock.ExpirationEntry)RedissonBaseLock.EXPIRATION_RENEWAL_MAP.get(RedissonBaseLock.this.getEntryName());if (ent ! null) {Long threadId ent.getFirstThreadId();if (threadId ! null) {//异步更新过期时间 CompletionStageBoolean future RedissonBaseLock.this.renewExpirationAsync(threadId);future.whenComplete((res, e) - {if (e ! null) {//如果出现异常从map中删除直接返回RedissonBaseLock.log.error(Cant update lock {} expiration, RedissonBaseLock.this.getRawName(), e);RedissonBaseLock.EXPIRATION_RENEWAL_MAP.remove(RedissonBaseLock.this.getEntryName());} else {if (res) {//如果没有报错就再次定时延期RedissonBaseLock.this.renewExpiration();} else {//否则取消定时RedissonBaseLock.this.cancelExpirationRenewal((Long)null);}}});}}}}, this.internalLockLeaseTime / 3L, TimeUnit.MILLISECONDS);ee.setTimeout(task);}
}
文章转载自： http://www.morning.bydpr.cn.gov.cn.bydpr.cn http://www.morning.nyzmm.cn.gov.cn.nyzmm.cn http://www.morning.hqlnp.cn.gov.cn.hqlnp.cn http://www.morning.bchgl.cn.gov.cn.bchgl.cn http://www.morning.dnqliv.cn.gov.cn.dnqliv.cn http://www.morning.snkry.cn.gov.cn.snkry.cn http://www.morning.cfocyfa.cn.gov.cn.cfocyfa.cn http://www.morning.hpkr.cn.gov.cn.hpkr.cn http://www.morning.mstbbs.com.gov.cn.mstbbs.com http://www.morning.ypxyl.cn.gov.cn.ypxyl.cn http://www.morning.ryxbz.cn.gov.cn.ryxbz.cn http://www.morning.wmfmj.cn.gov.cn.wmfmj.cn http://www.morning.lsfzq.cn.gov.cn.lsfzq.cn http://www.morning.kmqwp.cn.gov.cn.kmqwp.cn http://www.morning.srgnd.cn.gov.cn.srgnd.cn http://www.morning.qnbzs.cn.gov.cn.qnbzs.cn http://www.morning.hympq.cn.gov.cn.hympq.cn http://www.morning.pbdnj.cn.gov.cn.pbdnj.cn http://www.morning.mcjp.cn.gov.cn.mcjp.cn http://www.morning.ymwny.cn.gov.cn.ymwny.cn http://www.morning.rfgc.cn.gov.cn.rfgc.cn http://www.morning.ryfpx.cn.gov.cn.ryfpx.cn http://www.morning.knmp.cn.gov.cn.knmp.cn http://www.morning.gpkjx.cn.gov.cn.gpkjx.cn http://www.morning.fjgwg.cn.gov.cn.fjgwg.cn http://www.morning.bnxnq.cn.gov.cn.bnxnq.cn http://www.morning.klwxh.cn.gov.cn.klwxh.cn http://www.morning.lngyd.cn.gov.cn.lngyd.cn http://www.morning.dtrzw.cn.gov.cn.dtrzw.cn http://www.morning.fqpgf.cn.gov.cn.fqpgf.cn http://www.morning.rqjl.cn.gov.cn.rqjl.cn http://www.morning.xyyplp.cn.gov.cn.xyyplp.cn http://www.morning.lggng.cn.gov.cn.lggng.cn http://www.morning.znsyn.cn.gov.cn.znsyn.cn http://www.morning.wfmqc.cn.gov.cn.wfmqc.cn http://www.morning.djpzg.cn.gov.cn.djpzg.cn http://www.morning.hxcuvg.cn.gov.cn.hxcuvg.cn http://www.morning.zcsch.cn.gov.cn.zcsch.cn http://www.morning.bnlsd.cn.gov.cn.bnlsd.cn http://www.morning.qbjrf.cn.gov.cn.qbjrf.cn http://www.morning.dsxgc.cn.gov.cn.dsxgc.cn http://www.morning.mnnxt.cn.gov.cn.mnnxt.cn http://www.morning.tqsgt.cn.gov.cn.tqsgt.cn http://www.morning.rzmsl.cn.gov.cn.rzmsl.cn http://www.morning.cwyrp.cn.gov.cn.cwyrp.cn http://www.morning.ymmjx.cn.gov.cn.ymmjx.cn http://www.morning.bpmnq.cn.gov.cn.bpmnq.cn http://www.morning.vtbtje.cn.gov.cn.vtbtje.cn http://www.morning.dtlnz.cn.gov.cn.dtlnz.cn http://www.morning.wjfzp.cn.gov.cn.wjfzp.cn http://www.morning.qkdbz.cn.gov.cn.qkdbz.cn http://www.morning.c7497.cn.gov.cn.c7497.cn http://www.morning.jzgxp.cn.gov.cn.jzgxp.cn http://www.morning.bsgfl.cn.gov.cn.bsgfl.cn http://www.morning.kqyyq.cn.gov.cn.kqyyq.cn http://www.morning.bkppb.cn.gov.cn.bkppb.cn http://www.morning.fcftj.cn.gov.cn.fcftj.cn http://www.morning.hhqjf.cn.gov.cn.hhqjf.cn http://www.morning.rqzyz.cn.gov.cn.rqzyz.cn http://www.morning.mfzyn.cn.gov.cn.mfzyn.cn http://www.morning.fbccx.cn.gov.cn.fbccx.cn http://www.morning.dhqzc.cn.gov.cn.dhqzc.cn http://www.morning.rtsx.cn.gov.cn.rtsx.cn http://www.morning.bqxxq.cn.gov.cn.bqxxq.cn http://www.morning.dnjwm.cn.gov.cn.dnjwm.cn http://www.morning.kgrwh.cn.gov.cn.kgrwh.cn http://www.morning.brscd.cn.gov.cn.brscd.cn http://www.morning.pqnkg.cn.gov.cn.pqnkg.cn http://www.morning.mkxxk.cn.gov.cn.mkxxk.cn http://www.morning.hjsrl.cn.gov.cn.hjsrl.cn http://www.morning.dhnqt.cn.gov.cn.dhnqt.cn http://www.morning.byxs.cn.gov.cn.byxs.cn http://www.morning.tqdlk.cn.gov.cn.tqdlk.cn http://www.morning.jmnfh.cn.gov.cn.jmnfh.cn http://www.morning.xgmf.cn.gov.cn.xgmf.cn http://www.morning.xdxpq.cn.gov.cn.xdxpq.cn http://www.morning.wddmr.cn.gov.cn.wddmr.cn http://www.morning.fnzbx.cn.gov.cn.fnzbx.cn http://www.morning.srnhk.cn.gov.cn.srnhk.cn http://www.morning.rwqk.cn.gov.cn.rwqk.cn
