✨ spring-boot-demo-elasticsearch-rest-high-level-client 完成

Author: xkcoding

spring-boot-demo-elasticsearch-rest-high-level-client/README.md

@@ -1,8 +1,8 @@
 # spring-boot-demo-elasticsearch-rest-high-level-client
 
-> 此 demo 主要演示了 Spring Boot 如何集成 `elasticsearch-rest-high-level-client` 完成对 ElasticSearch 的基本CURD 操作 
+> 此 demo 主要演示了 Spring Boot 如何集成 `elasticsearch-rest-high-level-client` 完成对 `ElasticSearch 7.x` 版本的基本 CURD 操作 
 
-## elasticsearch 升级
+## Elasticsearch 升级
 
 先升级到 6.8，索引创建，设置 mapping 等操作加参数：include_type_name=true，然后滚动升级到 7，旧索引可以用 type 访问。具体可以参考：
 
@@ -12,17 +12,18 @@ https://www.elastic.co/guide/en/elasticsearch/reference/7.0/removal-of-types.htm
 
 ## 注意
 
-作者编写本demo时，ElasticSearch版本为 `7.3.0`，使用 docker 运行，下面是所有步骤：
+作者编写本 demo 时，ElasticSearch 版本为 `7.3.0`，使用 docker 运行，下面是所有步骤：
 
-1. 下载镜像：`docker pull elasticsearch:7.3.0`
+1.下载镜像：`docker pull elasticsearch:7.3.0`
 
-2. 下载安装 `docker-compose`
-```
+2.下载安装 `docker-compose`，参考文档： https://docs.docker.com/compose/install/
+
+```bash
 sudo curl -L "https://github.com/docker/compose/releases/download/1.24.1/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
-参考文档： https://docs.docker.com/compose/install/
 ```
 
-2. 编写docker-compose 文件
+3.编写docker-compose 文件
+
 ```yaml
 version: "3"
 
@@ -47,8 +48,7 @@ services:
         max-size: "50m"
 
 ```
-3. 启动: `docker-compose -f elasticsearch.yaml up -d`
-
+4.启动: `docker-compose -f elasticsearch.yaml up -d`
 
 ## pom.xml
 
@@ -108,7 +108,6 @@ services:
     <dependency>
       <groupId>cn.hutool</groupId>
       <artifactId>hutool-all</artifactId>
-      <version>4.6.6</version>
     </dependency>
 
     <!-- elasticsearch -->
@@ -151,8 +150,17 @@ services:
 
   </dependencies>
 
-</project>
+  <build>
+    <finalName>spring-boot-demo-elasticsearch-rest-high-level-client</finalName>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+      </plugin>
+    </plugins>
+  </build>
 
+</project>
 ```
 
 ## Person.java
@@ -217,7 +225,6 @@ public class Person implements Serializable {
     private String remark;
 
 }
-
 ```
 
 ## PersonService.java
@@ -291,7 +298,6 @@ public interface PersonService {
     List<Person> searchList(String index);
 
 }
-
 ```
 
 ## PersonServiceImpl.java
@@ -303,7 +309,7 @@ package com.xkcoding.elasticsearch.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import com.xkcoding.elasticsearch.model.Person;
-import com.xkcoding.elasticsearch.service.BaseElasticsearchService;
+import com.xkcoding.elasticsearch.service.base.BaseElasticsearchService;
 import com.xkcoding.elasticsearch.service.PersonService;
 import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.search.SearchResponse;
@@ -327,7 +333,6 @@ import java.util.Map;
 @Service
 public class PersonServiceImpl extends BaseElasticsearchService implements PersonService {
 
-
     @Override
     public void createIndex(String index) {
         createIndexRequest(index);
@@ -390,7 +395,6 @@ public class PersonServiceImpl extends BaseElasticsearchService implements Perso
         return personList;
     }
 }
-
 ```
 
 
@@ -406,10 +410,10 @@ import com.xkcoding.elasticsearch.model.Person;
 import com.xkcoding.elasticsearch.service.PersonService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
-import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -418,22 +422,30 @@ import java.util.List;
 @SpringBootTest
 public class ElasticsearchApplicationTests {
 
-    @Resource
+    @Autowired
     private PersonService personService;
 
+    /**
+     * 测试删除索引
+     */
     @Test
     public void deleteIndexTest() {
         personService.deleteIndex(ElasticsearchConstant.INDEX_NAME);
     }
 
+    /**
+     * 测试创建索引
+     */
     @Test
     public void createIndexTest() {
         personService.createIndex(ElasticsearchConstant.INDEX_NAME);
     }
 
+    /**
+     * 测试新增
+     */
     @Test
     public void insertTest() {
-
         List<Person> list = new ArrayList<>();
         list.add(Person.builder().age(11).birthday(new Date()).country("CN").id(1L).name("哈哈").remark("test1").build());
         list.add(Person.builder().age(22).birthday(new Date()).country("US").id(2L).name("hiahia").remark("test2").build());
@@ -442,6 +454,9 @@ public class ElasticsearchApplicationTests {
         personService.insert(ElasticsearchConstant.INDEX_NAME, list);
     }
 
+    /**
+     * 测试更新
+     */
     @Test
     public void updateTest() {
         Person person = Person.builder().age(33).birthday(new Date()).country("ID_update").id(3L).name("呵呵update").remark("test3_update").build();
@@ -450,24 +465,29 @@ public class ElasticsearchApplicationTests {
         personService.update(ElasticsearchConstant.INDEX_NAME, list);
     }
 
+    /**
+     * 测试删除
+     */
     @Test
     public void deleteTest() {
         personService.delete(ElasticsearchConstant.INDEX_NAME, Person.builder().id(1L).build());
     }
 
+    /**
+     * 测试查询
+     */
     @Test
     public void searchListTest() {
         List<Person> personList = personService.searchList(ElasticsearchConstant.INDEX_NAME);
         System.out.println(personList);
     }
 
-
 }
-
 ```
 
 ## 参考
 
-1. ElasticSearch 官方文档：https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html
-2. Java High Level REST Client：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.3/java-rest-high.html
+- ElasticSearch 官方文档：https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html
+
+- Java High Level REST Client：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.3/java-rest-high.html
 

spring-boot-demo-elasticsearch-rest-high-level-client/pom.xml

@@ -53,7 +53,6 @@
     <dependency>
       <groupId>cn.hutool</groupId>
       <artifactId>hutool-all</artifactId>
-      <version>4.6.6</version>
     </dependency>
 
     <!-- elasticsearch -->
@@ -96,4 +95,14 @@
 
   </dependencies>
 
+  <build>
+    <finalName>spring-boot-demo-elasticsearch-rest-high-level-client</finalName>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+      </plugin>
+    </plugins>
+  </build>
+
 </project>

spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/model/Result.java renamed to spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/common/Result.java

@@ -1,4 +1,4 @@
-package com.xkcoding.elasticsearch.model;
+package com.xkcoding.elasticsearch.common;
 
 import lombok.Data;
 import org.springframework.lang.Nullable;

spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/model/ResultCode.java renamed to spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/common/ResultCode.java

@@ -1,4 +1,4 @@
-package com.xkcoding.elasticsearch.model;
+package com.xkcoding.elasticsearch.common;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/autoconfigure/ElasticsearchAutoConfiguration.java renamed to spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/config/ElasticsearchAutoConfiguration.java

@@ -1,5 +1,6 @@
-package com.xkcoding.elasticsearch.autoconfigure;
+package com.xkcoding.elasticsearch.config;
 
+import lombok.RequiredArgsConstructor;
 import org.apache.http.HttpHost;
 import org.apache.http.auth.AuthScope;
 import org.apache.http.auth.UsernamePasswordCredentials;
@@ -8,14 +9,14 @@
 import org.elasticsearch.client.RestClient;
 import org.elasticsearch.client.RestClientBuilder;
 import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.util.Assert;
 import org.springframework.util.StringUtils;
 
-import javax.annotation.Resource;
-import javax.validation.constraints.NotNull;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -26,13 +27,12 @@
  * @version v1.0
  * @since 2019/9/15 22:59
  */
+@Configuration
+@RequiredArgsConstructor(onConstructor_ = @Autowired)
 @EnableConfigurationProperties(ElasticsearchProperties.class)
 public class ElasticsearchAutoConfiguration {
 
-    @SuppressWarnings("NullableProblems")
-    @NotNull
-    @Resource
-    private ElasticsearchProperties elasticsearchProperties;
+    private final ElasticsearchProperties elasticsearchProperties;
 
     private List<HttpHost> httpHosts = new ArrayList<>();
 
@@ -48,8 +48,7 @@ public RestHighLevelClient restHighLevelClient() {
                 Assert.state(parts.length == 2, "Must be defined as 'host:port'");
                 httpHosts.add(new HttpHost(parts[0], Integer.parseInt(parts[1]), elasticsearchProperties.getSchema()));
             } catch (Exception e) {
-                throw new IllegalStateException(
-                    "Invalid ES nodes " + "property '" + node + "'", e);
+                throw new IllegalStateException("Invalid ES nodes " + "property '" + node + "'", e);
             }
         });
         RestClientBuilder builder = RestClient.builder(httpHosts.toArray(new HttpHost[0]));
@@ -61,10 +60,10 @@ public RestHighLevelClient restHighLevelClient() {
     /**
      * get restHistLevelClient
      *
-     * @author fxbin
-     * @param builder RestClientBuilder
+     * @param builder                 RestClientBuilder
      * @param elasticsearchProperties elasticsearch default properties
      * @return {@link org.elasticsearch.client.RestHighLevelClient}
+     * @author fxbin
      */
     private static RestHighLevelClient getRestHighLevelClient(RestClientBuilder builder, ElasticsearchProperties elasticsearchProperties) {
 
@@ -88,11 +87,9 @@ private static RestHighLevelClient getRestHighLevelClient(RestClientBuilder buil
         if (!StringUtils.isEmpty(account.getUsername()) && !StringUtils.isEmpty(account.getUsername())) {
             final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
 
-            credentialsProvider.setCredentials(AuthScope.ANY,
-                new UsernamePasswordCredentials(account.getUsername(), account.getPassword()));
+            credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(account.getUsername(), account.getPassword()));
         }
         return new RestHighLevelClient(builder);
     }
 
-
 }

spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/autoconfigure/ElasticsearchProperties.java renamed to spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/config/ElasticsearchProperties.java

@@ -1,4 +1,4 @@
-package com.xkcoding.elasticsearch.autoconfigure;
+package com.xkcoding.elasticsearch.config;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -77,6 +77,9 @@ public class ElasticsearchProperties {
      */
     private Account account = new Account();
 
+    /**
+     * 索引配置信息
+     */
     @Data
     public static class Index {
 
@@ -92,6 +95,9 @@ public static class Index {
 
     }
 
+    /**
+     * 认证账户
+     */
     @Data
     public static class Account {
 

spring-boot-demo-elasticsearch-rest-high-level-client/src/main/java/com/xkcoding/elasticsearch/exception/ElasticsearchException.java

@@ -1,6 +1,6 @@
 package com.xkcoding.elasticsearch.exception;
 
-import com.xkcoding.elasticsearch.model.ResultCode;
+import com.xkcoding.elasticsearch.common.ResultCode;
 import lombok.Getter;
 
 /**