1.前言

以下所有整合，都是基于ElasticSearch8.0进行开发，老版本会有很多不兼容的情况，请自行斟酌

2.Springboot与ElasticSearch版本对照表

参考地址：https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#repositories
image.png

3.引入

官方推荐使用RestClient，而RestClient需要我们自行配置。因此无需划分单数据源还是多数据源，初始化的引入模式就是多数据源模式了，嗨嗨嗨！！！！！

项目Github地址

https://github.com/GuardFTC/elasticsearch-test.git

引入依赖

  1. <!--ElasticSearch依赖-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  5. </dependency>
  7. <!--ElasticSearch客户端依赖-->
  8. <dependency>
  9.   <groupId>co.elastic.clients</groupId>
  10.   <artifactId>elasticsearch-java</artifactId>
  11.   <version>8.0.0</version>
  12. </dependency>
  13. <dependency>
  14.   <groupId>com.fasterxml.jackson.core</groupId>
  15.   <artifactId>jackson-databind</artifactId>
  16.   <version>2.13.0</version>
  17. </dependency>
  18. <dependency>
  19.   <groupId>jakarta.json</groupId>
  20.   <artifactId>jakarta.json-api</artifactId>
  21.   <version>2.1.0</version>
  22. </dependency>
  24. <!--lombok依赖-->
  25. <dependency>
  26.   <groupId>org.projectlombok</groupId>
  27.   <artifactId>lombok</artifactId>
  28.   <optional>true</optional>
  29. </dependency>
  31. <!--Hutool依赖-->
  32. <dependency>
  33.   <groupId>cn.hutool</groupId>
  34.   <artifactId>hutool-all</artifactId>
  35.   <version>5.8.4</version>
  36. </dependency>

编写配置文件

还有很多配置项，并没有一一写入。可以在后续结合项目，用到哪里再做补充

  1. #elasticsearch配置
  2. elasticsearch:
  3.   primary:
  4.     host: 120.48.107.224
  5.     port: 9201
  6.     username: username
  7.     password: password
  8.     connect-timeout: 6000
  9.     socket-timeout: 6000
  10.     connection-request-timeout: 2000
  11.   secondary:
  12.     host: 120.48.107.224
  13.     port: 9202
  14.     connect-timeout: 6000
  15.     socket-timeout: 6000
  16.     connection-request-timeout: 2000

编写配置属性类

  1. import lombok.Data;
  3. /**
  4.  * @author: 冯铁城 [17615007230@163.com]
  5.  * @date: 2022-08-18 11:33:32
  6.  * @describe: ElasticSearch数据源配置属性
  7.  */
  8. @Data
  9. public class ElasticSearchProperties {
  11.     /**
  12.      * 主机
  13.      */
  14.     private String host;
  16.     /**
  17.      * 端口
  18.      */
  19.     private Integer port;
  21.     /**
  22.      * 用户名
  23.      */
  24.     private String username;
  26.     /**
  27.      * 密码
  28.      */
  29.     private String password;
  31.     /**
  32.      * 链接超时时间
  33.      */
  34.     private Integer connectTimeout;
  36.     /**
  37.      * socket链接超时时间
  38.      */
  39.     private Integer socketTimeout;
  41.     /**
  42.      * 请求链接超时时间
  43.      */
  44.     private Integer connectionRequestTimeout;
  45. }

编写配置类

  1. import org.springframework.boot.context.properties.ConfigurationProperties;
  2. import org.springframework.context.annotation.Bean;
  3. import org.springframework.context.annotation.Configuration;
  4. import org.springframework.context.annotation.Primary;
  6. /**
  7.  * @author: 冯铁城 [17615007230@163.com]
  8.  * @date: 2022-08-18 16:57:15
  9.  * @describe: ElasticSearch配置类
  10.  */
  11. @Configuration
  12. public class ElasticSearchConfig {
  14.     @Primary
  15.     @Bean(name = "primaryProperties")
  16.     @ConfigurationProperties(prefix = "elasticsearch.primary")
  17.     public ElasticSearchProperties primaryProperties() {
  18.         return new ElasticSearchProperties();
  19.     }
  21.     @Primary
  22.     @Bean(name = "secondaryProperties")
  23.     @ConfigurationProperties(prefix = "elasticsearch.secondary")
  24.     public ElasticSearchProperties secondaryProperties() {
  25.         return new ElasticSearchProperties();
  26.     }
  27. }

编写客户端配置类

  1. import cn.hutool.core.util.StrUtil;
  2. import co.elastic.clients.elasticsearch.ElasticsearchClient;
  3. import co.elastic.clients.json.jackson.JacksonJsonpMapper;
  4. import co.elastic.clients.transport.ElasticsearchTransport;
  5. import co.elastic.clients.transport.rest_client.RestClientTransport;
  6. import lombok.RequiredArgsConstructor;
  7. import org.apache.http.HttpHost;
  8. import org.apache.http.auth.AuthScope;
  9. import org.apache.http.auth.UsernamePasswordCredentials;
  10. import org.apache.http.client.CredentialsProvider;
  11. import org.apache.http.impl.client.BasicCredentialsProvider;
  12. import org.elasticsearch.client.RestClient;
  13. import org.elasticsearch.client.RestClientBuilder;
  14. import org.springframework.context.annotation.Bean;
  15. import org.springframework.context.annotation.Configuration;
  16. import org.springframework.context.annotation.Primary;
  18. /**
  19.  * @author: 冯铁城 [17615007230@163.com]
  20.  * @date: 2022-08-18 11:15:40
  21.  * @describe: ElasticSearch客户端链接配置
  22.  */
  23. @Configuration
  24. @RequiredArgsConstructor
  25. public class ElasticSearchClientConfig {
  27.     private final ElasticSearchConfig elasticSearchConfig;
  29.     @Primary
  30.     @Bean("primaryElasticsearchClient")
  31.     public ElasticsearchClient getPrimaryRestClient() {
  33.         //1.获取配置
  34.         ElasticSearchProperties primaryProperties = elasticSearchConfig.primaryProperties();
  36.         //2.生成客户端返回
  37.         return getElasticsearchClient(primaryProperties);
  38.     }
  40.     @Bean("secondaryElasticsearchClient")
  41.     public ElasticsearchClient getSecondaryRestClient() {
  43.         //1.获取配置
  44.         ElasticSearchProperties secondaryProperties = elasticSearchConfig.secondaryProperties();
  46.         //2.生成客户端返回
  47.         return getElasticsearchClient(secondaryProperties);
  48.     }
  50.     /**
  51.      * 创建ElasticSearch客户端
  52.      *
  53.      * @param properties ElasticSearch配置
  54.      * @return ElasticSearch客户端
  55.      */
  56.     private ElasticsearchClient getElasticsearchClient(ElasticSearchProperties properties) {
  58.         //1.获取主机和端口以及超时配置
  59.         String host = properties.getHost();
  60.         Integer port = properties.getPort();
  61.         Integer connectTimeout = properties.getConnectTimeout();
  62.         Integer socketTimeout = properties.getSocketTimeout();
  63.         Integer connectionRequestTimeout = properties.getConnectionRequestTimeout();
  65.         //2.设置客户端IP端口
  66.         RestClientBuilder builder = RestClient.builder(new HttpHost(host, port));
  68.         //3.设置链接相关参数
  69.         RestClientBuilder.RequestConfigCallback requestConfigCallback = requestConfigBuilder -> {
  70.             requestConfigBuilder.setConnectTimeout(connectTimeout);
  71.             requestConfigBuilder.setSocketTimeout(socketTimeout);
  72.             requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeout);
  73.             return requestConfigBuilder;
  74.         };
  76.         //4.设置客户端链接参数
  77.         builder.setRequestConfigCallback(requestConfigCallback);
  79.         //5.获取用户名密码
  80.         String username = properties.getUsername();
  81.         String password = properties.getPassword();
  83.         //6.用户名密码判空，判定是否需要创建登录凭证
  84.         if (StrUtil.isNotBlank(username) && StrUtil.isNotBlank(password)) {
  85.             final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
  87.             //7.设置用户名密码
  88.             UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(username, password);
  89.             credentialsProvider.setCredentials(AuthScope.ANY, credentials);
  91.             //8.封装鉴权参数
  92.             builder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
  93.         }
  95.         //9.创建Rest客户端
  96.         RestClient restClient = builder.build();
  98.         //10.生成Elasticsearch客户端链接
  99.         ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
  101.         //11.生成Elasticsearch客户端并返回
  102.         return new ElasticsearchClient(transport);
  103.     }
  104. }

编写单元测试使用

  1. import co.elastic.clients.elasticsearch.ElasticsearchClient;
  2. import org.junit.jupiter.api.Test;
  3. import org.springframework.beans.factory.annotation.Qualifier;
  4. import org.springframework.boot.test.context.SpringBootTest;
  6. import javax.annotation.Resource;
  7. import java.io.IOException;
  9. @SpringBootTest
  10. class ElasticSearchClientConfigTest {
  12.     @Resource
  13.     @Qualifier("primaryElasticsearchClient")
  14.     private ElasticsearchClient primaryClient;
  16.     @Resource
  17.     @Qualifier("secondaryElasticsearchClient")
  18.     private ElasticsearchClient secondaryClient;
  20.     @Test
  21.     void testCreateIndex() throws IOException {
  22.         primaryClient.indices().create(c -> c.index("test_java_primary"));
  23.         secondaryClient.indices().create(c -> c.index("test_java_secondary"));
  24.     }
  25. }

测试结果

image.png
如图，单元测试运行成功
image.png
如图，两个索引都创建成功