RedissonClient 缓存Bug

引入背景

        期望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();


版权声明:本文为gqltt原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。