Guava controller 에서 캐 시 cache 사용 하기

3520 단어 GuavaCache
더 읽 기
앞서 소 개 했 던 Guava 라 는 공구 꾸러미 에는 편리 한 용법 이 많 습 니 다.다음은 봉 인 된 Cache 를 사용 하여 기능 을 실현 해 야 합 니 다.
예시:
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.List;
import java.util.concurrent.TimeUnit;

@RestController
@RequestMapping("/hello")
public class HelloController {
	
	private static Logger logger = LoggerFactory.getLogger(HelloController .class);

	public static LoadingCache cacheBuilder;

	@Autowired
	private OverviewService overviewService;

	static OverviewParameter op ;
	
	@RequestMapping(value="/hh",method=RequestMethod.GET)
	public Result> sayHello(OverviewParameter overviewParameter){
		Result> result = null;
		setOviewParameter(overviewParameter);
		ObjectResultEx resObj  = (ObjectResultEx) getDataInCache("summary", overviewParameter);
		...	
		return result;
	}

	/**
	 *             
	 */
	private Object getDataInCache(final String key, OverviewParameter overviewParameter){
		logger.info("before refresh cache, key:{}, param:{}",key, JSONObject.toJSONString(overviewParameter));
		op = overviewParameter;
		try {
			if ((cacheBuilder != null) && ((ObjectResultEx) cacheBuilder.get(key)).isSuccess()){
				return cacheBuilder.get(key);
                        }else {
				return commonCache(new CacheLoader() {
					@Override
					public Object load(String key) throws Exception {
						logger.info("refresh cache, key:{}, param:{}",key, JSONObject.toJSONString(op));
						switch (key){
							case "summary":
								return overviewService.overviewSummary(op);
							case "grantNums":
								return overviewService.overviewGrantNums(op);
							case "creditNums":
								return overviewService.overviewCreditNums(op);
							case "riskNums":
								return overviewService.overviewRiskNums(op);
							default:
								return new ObjectResultEx<>().makeFailedResult();
						}
					}
				}).get(key);
			}
		} catch (Exception e) {
			logger.error("          ", e);
		}
		return new ObjectResultEx<>().makeFailedResult();
	}

	/**
	 *      loader
	 */
	private LoadingCache commonCache(CacheLoader loader) {
		synchronized (logger){
			cacheBuilder =  CacheBuilder
					.newBuilder()
					.refreshAfterWrite(1, TimeUnit.MINUTES)
					.build(loader);
		}
		return cacheBuilder;
	}
}

좋은 웹페이지 즐겨찾기