基于Springboot2.0構(gòu)建ES的多客戶端
更新時(shí)間：2019年04月24日 10:26:46 作者：CarolLXW
這篇文章主要為大家詳細(xì)介紹了基于Springboot2.0構(gòu)建ES的多客戶端，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
有時(shí)候我們操作es的時(shí)候會(huì)有一些特殊的需求，例如需要操作的index使用了不同的es服務(wù)器、用戶名、密碼、參數(shù)等，這個(gè)時(shí)候我們需要使用不同的es的客戶端進(jìn)行操作，但是我們又不希望拆分成多個(gè)項(xiàng)目進(jìn)行使用，這個(gè)時(shí)候我們就需要在我們的配置中自己構(gòu)建一套ES的多客戶端了。
文章目錄
pom.xml
ElasticsearchConfig.java
ElasticsearchRestClient.java
最終
pom.xml
首先是我們的pom.xml：
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> <version>2.0.5.RELEASE</version> </dependency> <!--es for transport--> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>5.6.11</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-client</artifactId> <version>5.6.11</version> </dependency> <!--es sniffer--> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-client-sniffer</artifactId> <version>5.6.3</version> <scope>compile</scope> </dependency> <!--es for rest-high-level-client--> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>5.6.11</version> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.4</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.39</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.9.1</version> </dependency> <!-- SpringBoot 熱啟動(dòng) --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> <version>2.4.2</version> </dependency> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-client-sniffer</artifactId> <version>5.6.0</version> </dependency> <dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.6</version> </dependency> </dependencies>
ElasticsearchConfig.java
然后是我們的配置文件，我這里使用的是application.properties的配置文件，因?yàn)槲覀兪褂貌煌男畔?，所以這里我就不寫了，可以根據(jù)需求自行獲取。
ElasticsearchRestClient.java
import cnkj.site.config.ElasticsearchConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.sniff.SniffOnFailureListener;
import org.elasticsearch.client.sniff.Sniffer;
import org.elasticsearch.client.sniff.SnifferBuilder;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/*
* @version 1.0 created by LXW on 2018/11/22 9:43
*/
@Slf4j
@Configuration
public class ElasticsearchClient {
@Bean(name = "HighESClient")
public RestClient restTomcatClient(ElasticsearchConfig elasticsearchConfig) {
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,
//es賬號(hào)密碼
new UsernamePasswordCredentials(elasticsearchConfig.getUsername(), elasticsearchConfig.getPassword()));
//自動(dòng)掃描網(wǎng)段
//監(jiān)聽同網(wǎng)段服務(wù)
//Low Level Client init
RestClientBuilder builder = RestClient.builder(
new HttpHost(
elasticsearchConfig.getHost(),
Integer.valueOf(elasticsearchConfig.getPort()),
elasticsearchConfig.getSchema()
)
).setHttpClientConfigCallback(
httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider)
).setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
@Override
public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder builder) {
builder.setConnectTimeout(elasticsearchConfig.getConnectTimeout());
builder.setSocketTimeout(elasticsearchConfig.getSocketTimeout());
return builder;
}
})
.setMaxRetryTimeoutMillis(elasticsearchConfig.getMaxRetryTimeoutMillis());
builder.setMaxRetryTimeoutMillis(elasticsearchConfig.getMaxRetryTimeoutMillis());
SniffOnFailureListener sniffOnFailureListener = new SniffOnFailureListener();
builder.setFailureListener(sniffOnFailureListener);
RestClient lowLevelRestClient = builder.build();
SnifferBuilder snifferBuilder = Sniffer.builder(lowLevelRestClient).setSniffIntervalMillis(elasticsearchConfig.getSnifferinterval());
if (elasticsearchConfig.getFailuredelay() > 0) {
snifferBuilder.setSniffAfterFailureDelayMillis(elasticsearchConfig.getFailuredelay());
}
sniffOnFailureListener.setSniffer(snifferBuilder.build());
return lowLevelRestClient;
}
@Bean(name = "HighLevelESClient")
public RestHighLevelClient restHighLevelClient(@Qualifier("HighESClient") RestClient restClient) {
return new RestHighLevelClient(restClient);
}
}
最終
在需要使用的地方直接通過注入的方式使用不同的客戶端
@Resource(name = "HighLevelESClient") private RestHighLevelClient client;
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot啟動(dòng)嵌入式Tomcat的實(shí)現(xiàn)步驟
本文主要介紹了淺談SpringBoot如何啟動(dòng)嵌入式Tomcat，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-08-08
本篇文章主要介紹了Springboot整合RocketMQ使用心得，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-01-01
SpringBoot學(xué)習(xí)之Json數(shù)據(jù)交互的方法
這篇文章主要介紹了SpringBoot學(xué)習(xí)之Json數(shù)據(jù)交互的方法，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-12-12
這篇文章主要介紹了java8新特性之日期時(shí)間API,文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java的小伙伴們有非常好的幫助,需要的朋友可以參考下2021-04-04
詳解SpringBoot修改啟動(dòng)端口server.port的四種方式
這篇文章主要介紹了詳解SpringBoot修改啟動(dòng)端口server.port的四種方式，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
使用spring動(dòng)態(tài)獲取接口的不同實(shí)現(xiàn)類
這篇文章主要介紹了使用spring動(dòng)態(tài)獲取接口的不同實(shí)現(xiàn)類，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-02-02
Java?BigDecimal類的一般使用、BigDecimal轉(zhuǎn)double方式
這篇文章主要介紹了Java?BigDecimal類的一般使用、BigDecimal轉(zhuǎn)double方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-01-01
這篇文章主要為大家詳細(xì)介紹了Java中常見的三個(gè)排序算法：選擇排序，冒泡排序和插入排序，文中的示例代碼講解詳細(xì)，感興趣的可以了解一下2022-08-08
java保留小數(shù)的四種實(shí)現(xiàn)方法
這篇文章主要為大家詳細(xì)介紹了java保留小數(shù)的四種實(shí)現(xiàn)方法,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-11-11
java安全?ysoserial?CommonsCollections1示例解析
這篇文章主要介紹了java安全?ysoserial?CommonsCollections1示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-10-10