Skip to content

A
amos-boot-biz
Commit 2959bad5 authored by suhuiguang's avatar suhuiguang
Browse files
Options

fix(cm)： es初始请求

1.初始请求401
parent 4b60fe15
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/config/ElasticSearchClientConfig.java
View file @ 2959bad5
...@@ -37,6 +37,7 @@ public class ElasticSearchClientConfig { ...@@ -37,6 +37,7 @@ public class ElasticSearchClientConfig {
try { try {
HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new); HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new);
RestClientBuilder builder = RestClient.builder(httpHosts); RestClientBuilder builder = RestClient.builder(httpHosts);
// 全局HTTP客户端配置
builder.setHttpClientConfigCallback(httpClientBuilder -> { builder.setHttpClientConfigCallback(httpClientBuilder -> {
httpClientBuilder.addInterceptorFirst((HttpRequestInterceptor) (request, context) -> { httpClientBuilder.addInterceptorFirst((HttpRequestInterceptor) (request, context) -> {
String auth = username + ":" + password; String auth = username + ":" + password;
...@@ -47,7 +48,7 @@ public class ElasticSearchClientConfig { ...@@ -47,7 +48,7 @@ public class ElasticSearchClientConfig {
.setMaxConnTotal(200) .setMaxConnTotal(200)
.setMaxConnPerRoute(60); .setMaxConnPerRoute(60);
}); });
// 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。 // 请求级参数配置
builder.setRequestConfigCallback(requestConfigBuilder -> { builder.setRequestConfigCallback(requestConfigBuilder -> {
// 连接超时（默认为1秒） // 连接超时（默认为1秒）
return requestConfigBuilder.setConnectTimeout(5000 * 1000) return requestConfigBuilder.setConnectTimeout(5000 * 1000)
......
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