引入背景
期望RedissonClient 能定期更新,避免网络不稳定导致 Redis 连接失效,只能重启服务?
使用了Caffeine 缓存,自动 2 小时失效剔除RedissonClient
/*** 本地缓存.*/private static final Cache<String, RedissonClient> CACHE = Caffeine.newBuilder().expireAfterWrite(2, TimeUnit.HOURS).removalListener((key, value, cause) -> {if (LOG.isInfoEnabled()) {LOG.info("RedissonClient移除--" + key);}}).maximumSize(3).build();
Bug 浮现
系统运行一段时间后,Redis 连接耗尽
原因分析
Caffeine 自动剔除后, RedissonClient 连接池资源没有回收!!!
redissonClient.shutdown();
改造后
/*** 本地缓存.*/private static final Cache<String, RedissonClient> CACHE = Caffeine.newBuilder().expireAfterWrite(30, TimeUnit.MINUTES).removalListener((key, value, cause) -> {if (LOG.isInfoEnabled()) {LOG.info("RedissonClient移除--" + key);}try {final RedissonClient client = (RedissonClient) value;client.shutdown();} catch (Exception e) {if (LOG.isErrorEnabled()) {LOG.error("RedissonClient 关闭失败。", e);}}}).maximumSize(3).build();