springboot进行elasticsearch的开发

目录

第一步：进行es的相关依赖的处理

第二步：定义全局的变量，用于在开发环境或者说uat环境动态变更处理

第三步：定义springboot的es的配置类

第一步：进行es的相关依赖的处理

es依赖包的版本设置

<elasticsearch.version>6.4.3</elasticsearch.version>

<spring.data.elasticsearch.version>3.2.1.RELEASE</spring.data.elasticsearch.version>

<!-- elasticsearch -->

<dependency>

<groupId>org.elasticsearch</groupId>

<artifactId>elasticsearch</artifactId>

<version>${elasticsearch.version}</version>

<exclusions>

<exclusion>

<groupId>org.apache.logging.log4j</groupId>

<artifactId>log4j-api</artifactId>

</exclusion>

</exclusions>

</dependency>

<dependency>

<groupId>org.apache.logging.log4j</groupId>

<artifactId>log4j-api</artifactId>

<version>2.17.2</version>

</dependency>

<dependency>

<groupId>org.elasticsearch.client</groupId>

<artifactId>transport</artifactId>

<version>${elasticsearch.version}</version>

</dependency>

<dependency>

<groupId>org.elasticsearch.client</groupId>

<artifactId>elasticsearch-rest-client</artifactId>

<version>${elasticsearch.version}</version>

</dependency>

<dependency>

<groupId>org.elasticsearch.client</groupId>

<artifactId>elasticsearch-rest-high-level-client</artifactId>

<version>${elasticsearch.version}</version>

</dependency>

<dependency>

<groupId>org.elasticsearch.plugin</groupId>

<artifactId>transport-netty4-client</artifactId>

<version>${elasticsearch.version}</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-elasticsearch</artifactId>

</dependency>

第二步：定义全局的变量，用于在开发环境或者说uat环境动态变更处理

编辑

第三步：定义springboot的es的配置类

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.lang.StringUtils;

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.impl.client.BasicCredentialsProvider;

import org.elasticsearch.client.RestClient;

import org.elasticsearch.client.RestClientBuilder;

import org.elasticsearch.client.RestHighLevelClient;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class SpringBootElasticsearchConfig {

private Logger LOGGER = LoggerFactory.getLogger(SpringBootElasticsearchConfig.class);

@Value("${system.elasticsearch.schema:http}")

private String schema;

@Value("${system.elasticsearch.address:#{null}}")

private String address;

@Value("${system.elasticsearch.userName:#{null}}")

private String userName;

@Value("${system.elasticsearch.password:#{null}}")

private String password;

@Value("${system.elasticsearch.connectTimeout:10000}")

private int connectTimeout;

@Value("${system.elasticsearch.socketTimeout:60000}")

private int socketTimeout;

@Value("${system.elasticsearch.connectionRequestTimeout:10000}")

private int connectionRequestTimeout;

@Value("${system.elasticsearch.maxConnectTotal:1000}")

private int maxConnectTotal;

@Value("${system.elasticsearch.maxConnectPerRoute:500}")

private int maxConnectPerRoute;

@Value("${system.elasticsearch.keepAliveTime:3600000}")

private long keepAliveTime;

public SpringBootElasticsearchConfig() {

}

@Bean(

name = {"restHighLevelClient"},

destroyMethod = "close"

)

public RestHighLevelClient restHighLevelClient() {

if (!StringUtils.isNotBlank(this.address)) {

return null;

} else {

this.LOGGER.info("start init elasticsearch address:" this.address);

List<HttpHost> hostLists = new ArrayList();

String[] hostList = this.address.split(",");

String[] var3 = hostList;

int var4 = hostList.length;

for(int var5 = 0; var5 < var4; var5) {

String addr = var3[var5];

String host = addr.trim().split(":")[0];

String port = addr.trim().split(":")[1];

hostLists.add(new HttpHost(host, Integer.parseInt(port), this.schema));

}

HttpHost[] httpHost = (HttpHost[])hostLists.toArray(new HttpHost[0]);

RestClientBuilder builder = RestClient.builder(httpHost);

builder.setRequestConfigCallback((requestConfigBuilder) -> {

requestConfigBuilder.setConnectTimeout(this.connectTimeout);

requestConfigBuilder.setSocketTimeout(this.socketTimeout);

requestConfigBuilder.setConnectionRequestTimeout(this.connectionRequestTimeout);

return requestConfigBuilder;

});

builder.setHttpClientConfigCallback((httpClientBuilder) -> {

httpClientBuilder.setMaxConnTotal(this.maxConnectTotal);

httpClientBuilder.setMaxConnPerRoute(this.maxConnectPerRoute);

httpClientBuilder.setKeepAliveStrategy((response, context) -> {

return this.keepAliveTime;

});

if (StringUtils.isNotBlank(this.userName)) {

this.LOGGER.info("start setting username and password of elasticsearch");

CredentialsProvider credentialsProvider = new BasicCredentialsProvider();

credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(this.userName, this.password));

httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);

}

return httpClientBuilder;

});

return new RestHighLevelClient(builder);

}

}

}