liangwen/hb_resource_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Elasticsearch客户端Bean优化,连接参数提取到配置文件

Browse Source
This commit is contained in:
liangwen 2025-09-04 17:46:44 +08:00
parent aed233744b
commit 34b218ee2a
2 changed files with 18 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hb-admin/src/main/resources/application.yml
View File

@ -273,3 +273,8 @@ logo:
image:
imageEmbedded:
url: https://www.onlyoffice.com
elasticsearch:
host: 8.134.76.66
port: 9200
scheme: http

52
hb-file/src/main/java/com/ruoyi/file/config/es/ElasticSearchConfig.java
View File

@ -5,53 +5,27 @@ import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.impl.nio.reactor.IOReactorConfig;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ElasticSearchConfig {
@Value("${elasticsearch.host}")
private String host;
@Value("${elasticsearch.port}")
private int port;
@Value("${elasticsearch.scheme}")
private String scheme;
@Bean
public ElasticsearchClient elasticsearchClient() {
// 创建低级REST客户端
RestClientBuilder restClientBuilder = RestClient.builder(
new HttpHost("8.134.76.66", 9200, "http"));
// 配置请求超时设置
restClientBuilder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
@Override
public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
return requestConfigBuilder
.setConnectTimeout(5000) // 连接超时时间 5秒
.setSocketTimeout(60000) // Socket超时时间 60秒
.setConnectionRequestTimeout(10000); // 获取连接超时时间 10秒
}
});
// 配置HTTP客户端参数
restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
return httpClientBuilder
.setDefaultIOReactorConfig(IOReactorConfig.custom()
.setIoThreadCount(1) // IO线程数
.build());
}
});
RestClient restClient = restClientBuilder.build();
// 创建传输层
ElasticsearchTransport transport = new RestClientTransport(
restClient,
new JacksonJsonpMapper());
// 创建Elasticsearch客户端
public ElasticsearchClient elasticsearchClient(){
RestClient client = RestClient.builder(new HttpHost(host, port, scheme)).build();
ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
return new ElasticsearchClient(transport);
}
}