1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
package com.yiboshi.science;
import com.yiboshi.science.utils.HtmlBuilder;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.util.ResourceUtils;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import org.springframework.web.servlet.view.freemarker.FreeMarkerConfigurer;
@EnableTransactionManagement
@MapperScan("com.yiboshi.science.dao")
@SpringBootApplication(scanBasePackages = "com.yiboshi")
public class ScienceAdminApplication {
@Bean
public HtmlBuilder htmlBuilder(FreeMarkerConfigurer freeMarkerConfigurer){
return new HtmlBuilder(freeMarkerConfigurer);
}
public static void main(String[] args) {
ConfigurableApplicationContext run = SpringApplication.run(ScienceAdminApplication.class, args);
}
@Bean
public WebMvcConfigurer corsConfigurer() {
return new WebMvcConfigurer() {
@Override
public void addCorsMappings(CorsRegistry registry) {
registry.addMapping("/**").allowedOrigins("*").allowedMethods("*").allowCredentials(true);
}
};
}
// @Bean
// public SpringContextHolder springContextContainer() {
// return new SpringContextHolder();
// }
private static void openLocalApiDocs(ConfigurableEnvironment environment) {
try {
if ("local".equals(environment.getActiveProfiles()[0])) {
// 注意：不要使用IE作为默认浏览器
String command = String.format("cmd /c start http://localhost:%s/docs.html", environment.getProperty("server.port"));
System.out.println(command);
Runtime.getRuntime().exec(command);
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
@Bean
public MybatisPaginationInterceptor paginationInterceptor() {
return new MybatisPaginationInterceptor();
}
//
// @Bean
// public RestTemplate restTemplate() {
// return new RestTemplate(httpRequestFactory());
// }
//
// @Bean
// public ClientHttpRequestFactory httpRequestFactory() {
// return new HttpComponentsClientHttpRequestFactory(httpClient());
// }
@Bean
public HttpClient httpClient() {
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.getSocketFactory())
.register("https", SSLConnectionSocketFactory.getSocketFactory())
.build();
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(registry);
// 设置每个路由基础的连接
cm.setDefaultMaxPerRoute(800);
//设置最大连接数
cm.setMaxTotal(1000);
RequestConfig requestConfig = RequestConfig.custom()
//服务器返回数据(response)的时间，超过该时间抛出read timeout
.setSocketTimeout(10000)
//连接上服务器(握手成功)的时间，超出该时间抛出connect timeout
.setConnectTimeout(5000)
//从连接池中获取连接的超时时间，超过该时间未拿到可用连接，会抛出org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection from pool
.setConnectionRequestTimeout(1000)
.build();
return HttpClientBuilder.create()
.setDefaultRequestConfig(requestConfig)
.setConnectionManager(cm)
.build();
}
}