From c007f0ca1785db093d48f4846cda82fe8e955765 Mon Sep 17 00:00:00 2001 From: kimi <kimi42345@gmail.com> Date: 星期三, 27 五月 2020 09:59:29 +0800 Subject: [PATCH] merage --- src/main/java/com/highdatas/mdm/util/OriginConfig.java | 44 ++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 42 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/highdatas/mdm/util/OriginConfig.java b/src/main/java/com/highdatas/mdm/util/OriginConfig.java index e8c424a..4b50f50 100644 --- a/src/main/java/com/highdatas/mdm/util/OriginConfig.java +++ b/src/main/java/com/highdatas/mdm/util/OriginConfig.java @@ -1,11 +1,17 @@ package com.highdatas.mdm.util; +import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.scheduling.annotation.AsyncConfigurer; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.web.servlet.config.annotation.CorsRegistry; import org.springframework.web.servlet.config.annotation.InterceptorRegistration; import org.springframework.web.servlet.config.annotation.InterceptorRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; + +import java.util.concurrent.Executor; /** * @author kimi @@ -14,7 +20,7 @@ */ @Configuration -public class OriginConfig implements WebMvcConfigurer { +public class OriginConfig implements WebMvcConfigurer, AsyncConfigurer { @Autowired CommonInterceptor commonInterceptor; @@ -30,7 +36,41 @@ @Override public void addInterceptors(InterceptorRegistry registry) { InterceptorRegistration interceptorRegistration = registry.addInterceptor(commonInterceptor); - interceptorRegistration.excludePathPatterns("/designer/**","/upload/**", "/process/**", "/processes/**", "/swagger-ui.html", "/webjars/**", "/swagger-resources/**", "/v2/api-docs"); + interceptorRegistration.excludePathPatterns("", "/sysView/download/**","/designer/**","/upload/**", "/process/**", "/processes/**", "/swagger-ui.html", "/webjars/**", "/swagger-resources/**", "/v2/api-docs", + "/subscribe/api/**", + "/subscribe/login/**", + "/subscribe/refreshList/**", + "/subscribe/add/**", + "/subscribe/delete/**", + "/subscribe/authors/**", + "subscribe/dispense/api/**", + "/"); + } + + @Override + @Bean + public Executor getAsyncExecutor() { + ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor(); + //璁剧疆鏍稿績绾跨▼鏁� + threadPool.setCorePoolSize(10); + //璁剧疆鏈�澶х嚎绋嬫暟 + threadPool.setMaxPoolSize(100); + //绾跨▼姹犳墍浣跨敤鐨勭紦鍐查槦鍒� + threadPool.setQueueCapacity(10); + //绛夊緟浠诲姟鍦ㄥ叧鏈烘椂瀹屾垚--琛ㄦ槑绛夊緟鎵�鏈夌嚎绋嬫墽琛屽畬 + threadPool.setWaitForTasksToCompleteOnShutdown(true); + // 绛夊緟鏃堕棿 锛堥粯璁や负0锛屾鏃剁珛鍗冲仠姝級锛屽苟娌$瓑寰厁x绉掑悗寮哄埗鍋滄 + threadPool.setAwaitTerminationSeconds(60); + // 绾跨▼鍚嶇О鍓嶇紑 + threadPool.setThreadNamePrefix("MDM-Async-"); + // 鍒濆鍖栫嚎绋� + threadPool.initialize(); + return threadPool; + } + + @Override + public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { + return null; } } -- Gitblit v1.8.0