Registry.java 文件源码

public void init() {
    m_execService = Executors.newCachedThreadPool();
    m_scheduledService = Executors.newScheduledThreadPool(1);

    RequestKeyGenerator keyGenerator = new RequestKeyGenerator(
            m_appConfig);

    /*
     * m_policyManager and keyGenerator are used in the initialization of
     * NettyRequestProxyFilter, NettyResponseProxyFilter, please make sure
     * init this two first
     */
    m_policyManager = new DefaultPolicyManager(m_appConfig, keyGenerator,
            m_scheduledService);

    m_cacheManager = m_policyManager.getCacheManager();

    m_debugManager = new DebugManager(m_appConfig, m_policyManager);

    List<IHttpRequestProxyFilter<HttpObject, ChannelHandlerContext>> requestFilters = new ArrayList<>();
    requestFilters.add(new NettyRequestProxyFilter(m_policyManager,
            m_appConfig));
    List<IHttpResponseProxyFilter<HttpObject, ChannelHandlerContext>> responseFilters = new ArrayList<>();
    responseFilters.add(new NettyResponseProxyFilter(m_policyManager,
            m_execService));

    m_filterManager = new FilterManager<>(requestFilters, responseFilters);

}