|
@@ -56,6 +56,7 @@ public class ObjectRedisCacheProcessor {
|
|
/**
|
|
/**
|
|
* 取缓存对象(不存在时远程或本地加载)<br>
|
|
* 取缓存对象(不存在时远程或本地加载)<br>
|
|
* 缓存失效时,只允许一个线程加载缓存,防止缓存击穿<br>
|
|
* 缓存失效时,只允许一个线程加载缓存,防止缓存击穿<br>
|
|
|
|
+ * 缓存加载时长不得超过10秒,否则所有等待线程无等待抛出异常,只到缓存被正确加载<br>
|
|
*
|
|
*
|
|
*
|
|
*
|
|
* @author WANGWEI
|
|
* @author WANGWEI
|
|
@@ -91,7 +92,7 @@ public class ObjectRedisCacheProcessor {
|
|
getRedisClient().delete(cacheException);
|
|
getRedisClient().delete(cacheException);
|
|
break;
|
|
break;
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
- getRedisClient().set(cacheException, true, 10);
|
|
|
|
|
|
+ getRedisClient().set(cacheException, true, 60);
|
|
throw e;
|
|
throw e;
|
|
} finally {
|
|
} finally {
|
|
getRedisClient().delete(cacheLock);
|
|
getRedisClient().delete(cacheLock);
|