{"id":38011,"date":"2025-05-19T14:13:31","date_gmt":"2025-05-19T06:13:31","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/38011.html"},"modified":"2025-05-19T14:13:31","modified_gmt":"2025-05-19T06:13:31","slug":"%e8%81%8a%e8%81%8ajetcache%e7%9a%84%e7%bc%93%e5%ad%98%e6%9e%84%e5%bb%ba","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/38011.html","title":{"rendered":"\u804a\u804aJetCache\u7684\u7f13\u5b58\u6784\u5efa"},"content":{"rendered":"

\u5e8f<\/h2>\n

\u672c\u6587\u4e3b\u8981\u7814\u7a76\u4e00\u4e0bJetCache\u7684\u7f13\u5b58\u6784\u5efa<\/p>\n

invokeWithCached<\/h2>\n

com\/alicp\/jetcache\/anno\/method\/CacheHandler.java<\/p>\n

private static Object invokeWithCached(CacheInvokeContext context)
\n throws Throwable {
\n CacheInvokeConfig cic = context.getCacheInvokeConfig();
\n CachedAnnoConfig cac = cic.getCachedAnnoConfig();
\n Cache cache = context.getCacheFunction().apply(context, cac);
\n if (cache == null) {
\n logger.error("no cache with name: " + context.getMethod());
\n return invokeOrigin(context);
\n }<\/p>\n

Object key = ExpressionUtil.evalKey(context, cic.getCachedAnnoConfig());
\n if (key == null) {
\n return loadAndCount(context, cache, key);
\n }<\/p>\n

if (!ExpressionUtil.evalCondition(context, cic.getCachedAnnoConfig())) {
\n return loadAndCount(context, cache, key);
\n }<\/p>\n

try {
\n CacheLoader loader = new CacheLoader() {
\n @Override
\n public Object load(Object k) throws Throwable {
\n Object result = invokeOrigin(context);
\n context.setResult(result);
\n return result;
\n }<\/p>\n

@Override
\n public boolean vetoCacheUpdate() {
\n return !ExpressionUtil.evalPostCondition(context, cic.getCachedAnnoConfig());
\n }
\n };
\n Object result = cache.computeIfAbsent(key, loader);
\n return result;
\n } catch (CacheInvokeException e) {
\n throw e.getCause();
\n }
\n }<\/p>\n

invokeWithCached\u5148\u901a\u8fc7context.getCacheFunction().apply(context, cac)\u53bb\u83b7\u53d6\u7f13\u5b58<\/p>\n

setCacheFunction<\/h2>\n

com\/alicp\/jetcache\/anno\/support\/CacheContext.java<\/p>\n

public CacheInvokeContext createCacheInvokeContext(ConfigMap configMap) {
\n CacheInvokeContext c = newCacheInvokeContext();
\n c.setCacheFunction((invokeContext, cacheAnnoConfig) -> {
\n Cache cache = cacheAnnoConfig.getCache();
\n if (cache == null) {
\n if (cacheAnnoConfig instanceof CachedAnnoConfig) {
\n cache = createCacheByCachedConfig((CachedAnnoConfig) cacheAnnoConfig, invokeContext);
\n } else if ((cacheAnnoConfig instanceof CacheInvalidateAnnoConfig) || (cacheAnnoConfig instanceof CacheUpdateAnnoConfig)) {
\n CacheInvokeConfig cacheDefineConfig = configMap.getByCacheName(cacheAnnoConfig.getArea(), cacheAnnoConfig.getName());
\n if (cacheDefineConfig == null) {
\n String message = "can't find @Cached definition with area=" + cacheAnnoConfig.getArea()
\n + " name=" + cacheAnnoConfig.getName() +
\n ", specified in " + cacheAnnoConfig.getDefineMethod();
\n CacheConfigException e = new CacheConfigException(message);
\n logger.error("Cache operation aborted because can't find @Cached definition", e);
\n return null;
\n }
\n cache = createCacheByCachedConfig(cacheDefineConfig.getCachedAnnoConfig(), invokeContext);
\n }
\n cacheAnnoConfig.setCache(cache);
\n }
\n return cache;
\n });
\n return c;
\n }<\/p>\n

createCacheInvokeContext\u8bbe\u7f6e\u4e86cacheFunction，\u4f7f\u7528\u4e86\u53cc\u91cd\u68c0\u9501\u53bb\u6784\u5efacache，\u5bf9\u4e8eCachedAnnoConfig\u662f\u8d70\u4e86createCacheByCachedConfig<\/p>\n

createCacheByCachedConfig<\/h2>\n

com\/alicp\/jetcache\/anno\/support\/CacheContext.java<\/p>\n

private Cache createCacheByCachedConfig(CachedAnnoConfig ac, CacheInvokeContext invokeContext) {
\n String area = ac.getArea();
\n String cacheName = ac.getName();
\n if (CacheConsts.isUndefined(cacheName)) {<\/p>\n

cacheName = configProvider.createCacheNameGenerator(invokeContext.getHiddenPackages())
\n .generateCacheName(invokeContext.getMethod(), invokeContext.getTargetObject());
\n }
\n Cache cache = __createOrGetCache(ac, area, cacheName);
\n return cache;
\n }<\/p>\n

public Cache __createOrGetCache(CachedAnnoConfig cachedAnnoConfig, String area, String cacheName) {
\n String fullCacheName = area + "_" + cacheName;
\n Cache cache = cacheManager.getCacheWithoutCreate(area, cacheName);
\n if (cache == null) {
\n synchronized (this) {
\n cache = cacheManager.getCacheWithoutCreate(area, cacheName);
\n if (cache == null) {
\n if (globalCacheConfig.isAreaInCacheName()) {
\n \/\/ for compatible reason, if we use default configuration, the prefix should same to that version <=2.4.3
\n cache = buildCache(cachedAnnoConfig, area, fullCacheName);
\n } else {
\n cache = buildCache(cachedAnnoConfig, area, cacheName);
\n }
\n cacheManager.putCache(area, cacheName, cache);
\n }
\n }
\n }
\n return cache;
\n } <\/p>\n

__createOrGetCache\u518d\u6b21\u4f7f\u7528\u53cc\u91cd\u68c0\u9501\u901a\u8fc7buildCache\u53bb\u6784\u5efaCache，\u9ed8\u8ba4globalCacheConfig.isAreaInCacheName()\u4e3afalse，\u6784\u5efa\u5b8c\u653e\u5165cacheManager<\/p>\n

buildCache<\/h2>\n

com\/alicp\/jetcache\/anno\/support\/CacheContext.java<\/p>\n

protected Cache buildCache(CachedAnnoConfig cachedAnnoConfig, String area, String cacheName) {
\n Cache cache;
\n if (cachedAnnoConfig.getCacheType() == CacheType.LOCAL) {
\n cache = buildLocal(cachedAnnoConfig, area);
\n } else if (cachedAnnoConfig.getCacheType() == CacheType.REMOTE) {
\n cache = buildRemote(cachedAnnoConfig, area, cacheName);
\n } else {
\n Cache local = buildLocal(cachedAnnoConfig, area);
\n Cache remote = buildRemote(cachedAnnoConfig, area, cacheName);<\/p>\n

boolean useExpireOfSubCache = cachedAnnoConfig.getLocalExpire() > 0;
\n cache = MultiLevelCacheBuilder.createMultiLevelCacheBuilder()
\n .expireAfterWrite(remote.config().getExpireAfterWriteInMillis(), TimeUnit.MILLISECONDS)
\n .addCache(local, remote)
\n .useExpireOfSubCache(useExpireOfSubCache)
\n .cacheNullValue(cachedAnnoConfig.isCacheNullValue())
\n .buildCache();
\n }
\n cache.config().setRefreshPolicy(cachedAnnoConfig.getRefreshPolicy());
\n cache = new CacheHandler.CacheHandlerRefreshCache(cache);<\/p>\n

cache.config().setCachePenetrationProtect(globalCacheConfig.isPenetrationProtect());
\n PenetrationProtectConfig protectConfig = cachedAnnoConfig.getPenetrationProtectConfig();
\n if (protectConfig != null) {
\n cache.config().setCachePenetrationProtect(protectConfig.isPenetrationProtect());
\n cache.config().setPenetrationProtectTimeout(protectConfig.getPenetrationProtectTimeout());
\n }<\/p>\n

if (configProvider.getCacheMonitorManager() != null) {
\n configProvider.getCacheMonitorManager().addMonitors(area, cacheName, cache);
\n }
\n return cache;
\n }<\/p>\n

buildCache\u6839\u636eCacheType\u53bb\u6784\u5efa，\u5bf9\u4e8eREMOTE\u662f\u6267\u884cbuildRemote<\/p>\n

buildRemote<\/h2>\n

protected Cache buildRemote(CachedAnnoConfig cachedAnnoConfig, String area, String cacheName) {
\n ExternalCacheBuilder cacheBuilder = (ExternalCacheBuilder) globalCacheConfig.getRemoteCacheBuilders().get(area);
\n if (cacheBuilder == null) {
\n throw new CacheConfigException("no remote cache builder: " + area);
\n }
\n cacheBuilder = (ExternalCacheBuilder) cacheBuilder.clone();<\/p>\n

if (cachedAnnoConfig.getExpire() > 0 ) {
\n cacheBuilder.expireAfterWrite(cachedAnnoConfig.getExpire(), cachedAnnoConfig.getTimeUnit());
\n }<\/p>\n

if (cacheBuilder.getConfig().getKeyPrefix() != null) {
\n cacheBuilder.setKeyPrefix(cacheBuilder.getConfig().getKeyPrefix() + cacheName);
\n } else {
\n cacheBuilder.setKeyPrefix(cacheName);
\n }<\/p>\n

if (!CacheConsts.isUndefined(cachedAnnoConfig.getKeyConvertor())) {
\n cacheBuilder.setKeyConvertor(configProvider.parseKeyConvertor(cachedAnnoConfig.getKeyConvertor()));
\n }
\n if (!CacheConsts.isUndefined(cachedAnnoConfig.getSerialPolicy())) {
\n cacheBuilder.setValueEncoder(configProvider.parseValueEncoder(cachedAnnoConfig.getSerialPolicy()));
\n cacheBuilder.setValueDecoder(configProvider.parseValueDecoder(cachedAnnoConfig.getSerialPolicy()));
\n }
\n cacheBuilder.setCacheNullValue(cachedAnnoConfig.isCacheNullValue());
\n return cacheBuilder.buildCache();
\n }<\/p>\n

\u8fd9\u91cc\u83b7\u53d6remote\u7684cacheBuilder，\u8fdb\u884cclone，\u7136\u540e\u6839\u636ecachedAnnoConfig\u8fdb\u884c\u5c5e\u6027\u8986\u76d6，\u7136\u540e\u6267\u884ccacheBuilder.buildCache()\u6784\u5efa；\u8fd9\u91cckeyPrefix\u9ed8\u8ba4\u4e3anull，\u6240\u4ee5\u8fd9\u91cc\u7684keyPrefix\u4e3a\u4e0d\u5e26aera\u7684cacheName；ExternalCacheBuilder\u6709MockRemoteCacheBuilder\u3001RedisLettuceCacheBuilder\u4e24\u4e2a\u5b50\u7c7b\u3002<\/p>\n

\u5c0f\u7ed3<\/h2>\n

JetCache\u5ef6\u8fdf\u6784\u5efaCache，\u901a\u8fc7CacheContext.buildCache\u6839\u636ecacheType\u8fdb\u884c\u6784\u5efa\u3002<\/p>\n

doc<\/h2>\n