日志框架 - 基于spring-boot - 實(shí)現(xiàn)6 - 自動(dòng)裝配

日志框架系列講解文章
日志框架 - 基于spring-boot - 使用入門
日志框架 - 基于spring-boot - 設(shè)計(jì)
日志框架 - 基于spring-boot - 實(shí)現(xiàn)1 - 配置文件
日志框架 - 基于spring-boot - 實(shí)現(xiàn)2 - 消息定義及消息日志打印
日志框架 - 基于spring-boot - 實(shí)現(xiàn)3 - 關(guān)鍵字與三種消息解析器
日志框架 - 基于spring-boot - 實(shí)現(xiàn)4 - HTTP請(qǐng)求攔截
日志框架 - 基于spring-boot - 實(shí)現(xiàn)5 - 線程切換
日志框架 - 基于spring-boot - 實(shí)現(xiàn)6 - 自動(dòng)裝配

上一篇我們講了框架實(shí)現(xiàn)的第五部分:如何在線程切換時(shí)保留上下文信息。
本篇主要講框架實(shí)現(xiàn)的第六部分:自動(dòng)裝配

自動(dòng)裝配(AutoConfiguration)Spring Boot 框架提供的核心功能。本篇中我們主要使用自動(dòng)裝配實(shí)現(xiàn)將之前第一部分到第五部分實(shí)現(xiàn)的功能組裝到一起。實(shí)現(xiàn)對(duì)業(yè)務(wù)代碼編程人員無(wú)感知。具體實(shí)現(xiàn)如下。

/**
 * 日志組件自動(dòng)裝配
 */
@Configuration
@ConditionalOnProperty(
        value = "xpay.framework.logging.enabled",
        havingValue = "true",
        matchIfMissing = true)
@EnableAspectJAutoProxy(proxyTargetClass = true, exposeProxy = true)

public class LoggingAutoConfiguration {
    
    @Value("${xpay.framework.executor.max-pool-size:16}")
    int maxPoolSize;
    
    /**
     * 自定義線程池
     * <p>
     * 用于線程切換時(shí)的MDC延續(xù)
     */
    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(maxPoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setTaskDecorator(new MDCTaskDecorator());
        executor.setThreadNamePrefix("MDCAdaptTaskExcutor-");
        executor.initialize();
        return executor;
    }
    
    @Bean
    public MessageToLogAspect messageToLogAspect() {
        return new MessageToLogAspect();
    }
    
    @Bean
    public DefaultKeywords defaultKeywords() {
        return new DefaultKeywords();
    }
    
    @Bean
    public MDCSpringMvcHandlerInterceptor mdcSpringMvcHandlerInterceptor() {
        return new MDCSpringMvcHandlerInterceptor();
    }
    
    /**
     * Filter與Interceptor裝配
     */
    @Configuration
    protected static class LoggingWebConfiguration extends
            WebMvcConfigurerAdapter {
        
        @Autowired
        MDCSpringMvcHandlerInterceptor mdcSpringMvcHandlerInterceptor;
        
        @Override
        public void addInterceptors(InterceptorRegistry registry) {
            registry.addInterceptor(mdcSpringMvcHandlerInterceptor);
        }
    }
    
    
    /**
     * Keywords裝配
     */
    @Configuration
    @ConditionalOnExpression(
            "'${xpay.framework.logging.keywords}' matches '^([^,]+,)+.*$'")
    protected static class MessageResolveAutoConfiguration {
        
        @Value("${xpay.framework.logging.keywords}")
        String keywordsPropertyString;
        
        @Bean
        public List<Keyword> keywordList() {
            String[] keywordsProStringSplits =
                    keywordsPropertyString.split(",");
            return Stream.of(keywordsProStringSplits)
                         .map(Keyword::new)
                         .collect(Collectors.toList());
        }
        
        @Bean
        @Order(3)
        public JsonMessageResolver jsonMessageResolver(
                List<Keyword> keywordList) {
            return new JsonMessageResolver(keywordList);
        }
        
        @Bean
        @Order(2)
        public XmlMessageResolver xmlMessageResolver(
                List<Keyword> keywordList) {
            return new XmlMessageResolver(keywordList);
        }
        
        @Bean
        @Order(1)
        public KeyValueMessageResolver keyValueMessageResolver(
                List<Keyword> keywordList) {
            return new KeyValueMessageResolver(keywordList);
        }
        
        @Bean
        @Scope(scopeName = SCOPE_PROTOTYPE,
               proxyMode = ScopedProxyMode.TARGET_CLASS)
        public MessageResolverChain messageResolverChain(
                List<MessageResolver> resolvers) {
            return new MessageResolverChainImpl(resolvers);
        }
        
        @Bean
        public RequestReplaceServletFilter requestReplaceServletFilter() {
            return new RequestReplaceServletFilter();
        }
        
        @Bean
        public FilterRegistrationBean requestReplaceFilter
                (RequestReplaceServletFilter requestReplaceFilter) {
            FilterRegistrationBean filterRegistrationBean = new
                    FilterRegistrationBean(requestReplaceFilter);
            filterRegistrationBean.setDispatcherTypes(ASYNC, REQUEST);
//            filterRegistrationBean.setOrder(Ordered.HIGHEST_PRECEDENCE + 5);
            return filterRegistrationBean;
        }
    }
}

至此,日志框架所有實(shí)現(xiàn)都已介紹了。有想法的小伙伴也可以在此基礎(chǔ)上進(jìn)行改進(jìn)。實(shí)現(xiàn)想要的功能。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開(kāi)發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見(jiàn)模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn),斷路器,智...
    卡卡羅2017閱讀 136,569評(píng)論 19 139
  • Spring Boot 參考指南 介紹 轉(zhuǎn)載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 47,275評(píng)論 6 342
  • 1、談?wù)勀銓?duì)Struts的理解。 答: 1.struts是一個(gè)按MVC模式設(shè)計(jì)的Web層框架,其實(shí)它就是一個(gè)大大的...
    慕容小偉閱讀 2,970評(píng)論 0 13
  • spring-boot-admin為我們基于spring-boot的基礎(chǔ)數(shù)據(jù)安全端口提供了基礎(chǔ)的可視化監(jiān)控功能。還...
    Comcen閱讀 10,584評(píng)論 8 22
  • 我喜歡你 一如既往 不去打擾 互不相欠
    BABY1998閱讀 132評(píng)論 0 0

友情鏈接更多精彩內(nèi)容