private Cache<String,String> redisLocalCache = CacheBuilder
.newBuilder()
// 只有一個線程能夠寫入
.concurrencyLevel(1)
// 本地緩存 緩存未被調用1分鐘過時
.expireAfterWrite(60, TimeUnit.SECONDS)
.build();
String redisKey = "testKey";
String redisValue = null;
try {
redisValue = redisLocalCache.get(redisKey ,()-> { String confStr = redisService.get(redisKey); return confStr; });
} catch (Exception e) {
log.debug(e);
}
複製代碼