Zuul的性能优化-过滤器链缓存

public class CustomFilter extends ZuulFilter {

    private CacheManager cacheManager;

    public CustomFilter(CacheManager cacheManager) {
        this.cacheManager = cacheManager;
    }

    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 0;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        String key = request.getRequestURI();
        Cache cache = cacheManager.getCache("filterChainCache");
        ValueWrapper wrapper = cache.get(key);
        if (wrapper != null) {
            ctx.set("filterChainCacheResult", wrapper.get());
            return null;
        }
        return doFilter(ctx, key, cache);
    }

    private Object doFilter(RequestContext ctx, String key, Cache cache) {
        FilterLoader filterLoader = FilterLoader.getInstance();
        List<ZuulFilter> preFilters = filterLoader.getFiltersByType("pre");
        List<ZuulFilter> routeFilters = filterLoader.getFiltersByType("route");
        List<ZuulFilter> postFilters = filterLoader.getFiltersByType("post");
        List<ZuulFilter> errorFilters = filterLoader.getFiltersByType("error");
        List<ZuulFilter> filters = new ArrayList<>();
        filters.addAll(preFilters);
        filters.addAll(routeFilters);
        filters.addAll(postFilters);
        filters.addAll(errorFilters);
        List<FilterProcessor.FilterType> filterTypes = new ArrayList<>();
        filterTypes.add(FilterProcessor.FilterType.PRE);
        filterTypes.add(FilterProcessor.FilterType.ROUTE);
        filterTypes.add(FilterProcessor.FilterType.POST);
        filterTypes.add(FilterProcessor.FilterType.ERROR);
        FilterProcessor filterProcessor = FilterProcessor.getInstance();
        FilterChainResult result = filterProcessor.runFilters(filterTypes, filters);
        if (result.getStatus() == FilterChainResultStatus.FAILED) {
            ctx.setSendZuulResponse(false);
            ctx.setResponseStatusCode(result.getException().getStatusCode());
            ctx.setResponseBody(result.getException().getMessage());
            ctx.getResponse().setContentType("application/json;charset=UTF-8");
            return null;
        }
        cache.putIfAbsent(key, result.getResponseDataStream());
        ctx.setResponseBody(result.getResponseDataStream());
        return null;
    }
}