From 6c6fdb4db59a2a2343e43ffd73a07f17b057c4fa Mon Sep 17 00:00:00 2001
From: kimi42345 <kimi42345@outlook.com>
Date: 星期二, 17 三月 2020 22:37:43 +0800
Subject: [PATCH] 3/17 添加 请求log
---
src/main/java/com/highdatas/mdm/util/OriginConfig.java | 34 +++++++++++++++++++++++++++++++++-
1 files changed, 33 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/util/OriginConfig.java b/src/main/java/com/highdatas/mdm/util/OriginConfig.java
index fe066ca..b00197a 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;
@@ -33,4 +39,30 @@
interceptorRegistration.excludePathPatterns("/designer/**","/upload/**", "/process/**", "/processes/**", "/swagger-ui.html", "/webjars/**", "/swagger-resources/**", "/v2/api-docs", "/");
}
+ @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