提交mongo线程池配置

liquidnet-bus-config/liquidnet-config/liquidnet-service-adam.yml

@@ -75,9 +75,29 @@ spring:
     password: ${liquidnet.rabbitmq.password}
   data:
     mongodb:
-      uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}:${liquidnet.mongodb.port}/?authSource=admin
+        uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}:${liquidnet.mongodb.port}/?authSource=admin&waitQueueMultiple=100
         sslEnabled: false
         database: ${spring.data.mongodb.database}
+#        address: ${liquidnet.mongodb.host}:${liquidnet.mongodb.port}
+#        username: ${liquidnet.mongodb.user}
+#        password: ${liquidnet.mongodb.pwd}
+#        authenticationDatabase: admin #[设置你的认证数据库，如果有的话]
+#        # 连接池配置
+#        clientName: ${spring.application.name} # 客户端的标识，用于定位请求来源等
+#        connectionTimeoutMs: 10000     # TCP连接超时，毫秒
+#        readTimeoutMs: 15000       # TCP读取超时，毫秒
+#        poolMaxWaitTimeMs: 3000        #当连接池无可用连接时客户端阻塞等待的时长，单位毫秒
+#        connectionMaxIdleTimeMs: 60000   #TCP连接闲置时间，单位毫秒
+#        connectionMaxLifeTimeMs: 120000    #TCP连接最多可以使用多久，单位毫秒
+#        heartbeatFrequencyMs: 20000      #心跳检测发送频率，单位毫秒
+#        minHeartbeatFrequencyMs: 8000    #最小的心跳检测发送频率，单位毫秒
+#        heartbeatConnectionTimeoutMs: 10000  #心跳检测TCP连接超时，单位毫秒
+#        heartbeatReadTimeoutMs: 15000    #心跳检测TCP连接读取超时，单位毫秒
+#        connectionsPerHost: 20       # 每个host的TCP连接数
+#        minConnectionsPerHost: 8     #每个host的最小TCP连接数
+#        #计算允许多少个线程阻塞等待可用TCP连接时的乘数，算法：threadsAllowedToBlockForConnectionMultiplier*connectionsPerHost，当前配置允许10*20个线程阻塞
+#        threadsAllowedToBlockForConnectionMultiplier: 10
+
   datasource:
     name: ${liquidnet.mysql.database-name}
     url: jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=UTC&characterEncoding=utf-8&useSSL=false

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/ServiceAdamApplication.java

@@ -2,28 +2,13 @@ package com.liquidnet.service;
 
 import lombok.extern.slf4j.Slf4j;
 import org.mybatis.spring.annotation.MapperScan;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
-import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
-import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
-import org.springframework.context.annotation.EnableAspectJAutoProxy;
 import org.springframework.core.env.Environment;
-import org.springframework.jdbc.datasource.DataSourceTransactionManager;
-import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.annotation.EnableScheduling;
-import org.springframework.transaction.PlatformTransactionManager;
-import org.springframework.transaction.annotation.EnableTransactionManagement;
-import org.springframework.transaction.annotation.TransactionManagementConfigurer;
 
-import javax.sql.DataSource;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.Arrays;
@@ -31,6 +16,7 @@ import java.util.Arrays;
 @Slf4j
 @EnableFeignClients
 @MapperScan(basePackages = "com.liquidnet.service.adam.mapper")
+//@SpringBootApplication(scanBasePackages = {"com.liquidnet"},exclude = {MongoAutoConfiguration.class,})
 @SpringBootApplication(scanBasePackages = {"com.liquidnet"})
 public class ServiceAdamApplication implements CommandLineRunner {
     @Autowired