Commit 4e746b65 authored by 李健华's avatar 李健华

修改commons-parent版本,监控增加连接池

parent 522ecc86
...@@ -6,7 +6,7 @@ ...@@ -6,7 +6,7 @@
<parent> <parent>
<groupId>cn.quantgroup</groupId> <groupId>cn.quantgroup</groupId>
<artifactId>commons-parent</artifactId> <artifactId>commons-parent</artifactId>
<version>0.5.0</version> <version>0.5.4</version>
</parent> </parent>
<artifactId>xyqb-user2</artifactId> <artifactId>xyqb-user2</artifactId>
......
package cn.quantgroup.xyqb.config.event; package cn.quantgroup.xyqb.config.event;
import java.util.concurrent.Executor; import cn.quantgroup.tool.monitor.metric.api.ExecutorUtils;
import java.util.concurrent.RejectedExecutionHandler; import com.rabbitmq.client.impl.VariableLinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.ApplicationEventMulticaster; import org.springframework.context.event.ApplicationEventMulticaster;
import org.springframework.context.event.SimpleApplicationEventMulticaster; import org.springframework.context.event.SimpleApplicationEventMulticaster;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.scheduling.support.TaskUtils; import org.springframework.scheduling.support.TaskUtils;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
@Slf4j @Slf4j
@Configuration @Configuration
public class EventConfig { public class EventConfig {
...@@ -26,15 +29,7 @@ public class EventConfig { ...@@ -26,15 +29,7 @@ public class EventConfig {
@Bean @Bean
public Executor taskExecutor() { public Executor taskExecutor() {
ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor(); return ExecutorUtils.newExecutor(10, 50, 60, TimeUnit.SECONDS, new VariableLinkedBlockingQueue(1024), "Spring-UserLogin-Event");
poolTaskExecutor.setCorePoolSize(10);
poolTaskExecutor.setMaxPoolSize(50);
poolTaskExecutor.setQueueCapacity(100);
poolTaskExecutor.setThreadNamePrefix("Spring-UserLogin-Event-");
poolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);
poolTaskExecutor.setRejectedExecutionHandler(new RejectedHandler());
poolTaskExecutor.initialize();
return poolTaskExecutor;
} }
public static class RejectedHandler implements RejectedExecutionHandler { public static class RejectedHandler implements RejectedExecutionHandler {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment