【Java】SpringBoot快速整合ElasticSearch

什么是ES？

        Elasticsearch（简称为ES）是一个开源的分布式搜刮引擎，用于全文搜刮、实时分析和可视化。它建立在Apache Lucene搜刮引擎库的根本上，提供了RESTful API，支持分布式架构和程度扩展，特别实用于处置惩罚大规模的非结构化或半结构化数据。
Elasticsearch与传统数据库查询的区别：

• 搜刮引擎特性： Elasticsearch是一个搜刮引擎，其重要计划目标是支持高效的全文搜刮和实时分析。它专注于处置惩罚大量文本数据，支持复杂的全文搜刮查询，例如模糊搜刮、词组匹配、范围查询等。传统数据库重要面向结构化数据，更实用于关系型查询。
  
• 分布式和程度扩展： Elasticsearch是分布式的，它可以在多个节点上运行，并可以大概程度扩展以处置惩罚大规模数据。传统数据库通常在单个节点上运行，并且通常需要垂直扩展（增长服务器性能）来处置惩罚更大的负载。
  
• Schema-less（无模式）： Elasticsearch是无模式的，意味着你不需要在索引中预界说数据结构。你可以直接插入数据，Elasticsearch会根据数据主动推断其类型。传统数据库需要在创建表时界说模式。
  
• 实时性： Elasticsearch提供实时索引和搜刮功能，数据险些立即可用于搜刮。传统数据库的实时性大概受到数据复制和索引的影响。
  
• 多语言支持： Elasticsearch支持多种查询语言，例如查询字符串、DSL（Domain Specific Language）等，使其更易于使用和集成。传统数据库通常使用SQL。
  

        要在Spring Boot项目中集成Elasticsearch，首先需要添加相应的依靠，然后配置Elasticsearch的连接信息，末了通过Spring Data Elasticsearch或者Elasticsearch的Java REST客户端来与Elasticsearch举行交互。
SpringBoot整合ElasticSearch的步调：

0.代码层级结构

1. 添加依靠

在pom.xml中添加Spring Data Elasticsearch依靠：

1. <dependency>
2.       <groupId>org.springframework.boot</groupId>
3.       <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
4. </dependency>

复制代码

2. 配置Elasticsearch连接信息

在application.properties或(application.yml)中配置Elasticsearch连接信息，如下：

1. spring.elasticsearch.uris=http://localhost:9200

复制代码

1. spring:
2.   elasticsearch:
3.     uris: http://localhost:9200

复制代码

如果Elasticsearch没有设置用户名和暗码，这大概就足够了。如果需要认证，可以使用以下配置：

1. spring.elasticsearch.username=your_username
2. spring.elasticsearch.password=your_password

复制代码

1. spring:
2.   elasticsearch:
3.     uris: http://localhost:9200
5.     username:your_username    password:your_password

复制代码

3. 创建实体类

创建一个简朴的实体类，使用@Document注解指定索引和类型：

1. import lombok.Data;
2. import org.springframework.data.annotation.Id;
3. import org.springframework.data.elasticsearch.annotations.Document;
5. /**
6. * @Document(indexName = "user-demo") 索引名称为user-demo
7. * */
8. @Data
9. @Document(indexName = "user-demo")
10. public class User {
11.     @Id
12.     private String id;
13.     private String username;
14.     private String address;
15.     private Integer age;
16.     private String gender;
17. }

复制代码

4. 使用Spring Data Elasticsearch举行操作

创建一个UserMapper接口，继承自ElasticsearchRepository：

2. import com.example.demoes.entity.User;
3. import org.springframework.data.domain.Page;
4. import org.springframework.data.domain.Pageable;
5. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
6. import org.springframework.stereotype.Repository;
8. import java.util.List;
9. /**
10. * 这些方法的名称遵循一种命名约定，这种约定将方法名中的关键词（如 findBy、Like、IgnoreCase 等）与实体类（User）的属性名相关联。
11. * 这样，Spring Data Elasticsearch 可以根据方法名自动生成相应的查询。
12. *
13. * 在Spring Data Elasticsearch中，查询方法的命名约定依赖于一些关键词和命名规范，这些关键词用于描述要执行的查询操作。以下是一些常见的关键词和它们的含义：
14. *
15. *     findBy：指定查询的条件的前缀，后面通常跟随实体类的属性名。例如，findByUsername 表示要根据用户名进行查询。
16. *
17. *     Like：用于模糊查询，通常与属性名一起使用。例如，findByUsernameLike 表示要进行用户名的模糊查询。
18. *
19. *     IgnoreCase：用于不区分大小写的查询，通常与属性名一起使用。例如，findByUsernameIgnoreCase 表示不区分大小写地查询用户名。
20. *
21. *     Containing：用于包含查询，通常与属性名一起使用。例如，findByUsernameContaining 表示包含指定内容的查询。
22. *
23. *     And 和 Or：用于构建复合查询条件。例如，findByUsernameAndAge 表示根据用户名和年龄进行查询。
24. *
25. *     OrderBy：用于指定结果的排序方式。例如，findByAgeOrderByUsernameDesc 表示根据年龄查询并按用户名降序排序。
26. *
27. *     Page 和 Iterable：用于指定查询结果的返回类型。例如，Page<User> 表示返回分页结果，Iterable<User> 表示返回一个列表。
28. *
29. *     其他属性名：您可以根据实体类的属性名来定义查询条件。例如，如果实体类有一个属性为 email，您可以编写 findByEmail 方法来根据邮箱进行查询。
30. * */
31. @Repository
32. public interface UserMapper extends ElasticsearchRepository<User,String> {
34.     /**
35.      *自定义查询
36.      * */
37.     List<User> findByAddressLikeIgnoreCaseOrderByAgeDesc(String address);
39.     Page<User> findByUsernameContaining(String username, Pageable page);
41.     User findByAge(Integer age);
43.     List<User> findByGender(String gender);
45.     long count();
47.     Boolean existsById();
49. }

复制代码

5.测试

        在测试中使用Spring Boot的@SpringBootTest注解，来验证Elasticsearch是否正常工作。

1. import com.example.demoes.entity.User;
2. import com.example.demoes.mapper.UserMapper;
3. import org.junit.jupiter.api.Test;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.boot.test.context.SpringBootTest;
6. import org.springframework.data.domain.Page;
7. import org.springframework.data.domain.PageRequest;
8. import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
11. import java.util.*;
14. @SpringBootTest
15. class DemoEsApplicationTests {
17.     //    @Resource
18.     @Autowired
19.     private UserMapper userMapper;
22.     @Autowired
23.     private ElasticsearchRestTemplate elasticsearchRestTemplate;
26.     @Test
27.     void add() {
28.         for (int i = 2; i < 11; i++) {
29.             User user = new User();
30.             user.setId(i + "");
31.             user.setUsername("zhangsan" + i);
32.             user.setGender("男");
33.             user.setAge(i + i);
34.             user.setAddress("河北省" + i);
35.             //直接将数据保存到es中，索引名称为user-demo，在user对象中设置的
36.             //通过kibana进行查询GET /user-demo/_search
37.             User save = userMapper.save(user);
38.             System.out.println("save = " + save);
39.         }
40.     }
43.     @Test
44.     void delete() {
45.         String id = "9";
46.         userMapper.deleteById(id);
47.     }
49.     @Test
50.     void update() {
52.         User updateUser = new User();
53.         updateUser.setId("9");
54.         updateUser.setUsername("Lisi");
55.         updateUser.setGender("女");
56.         updateUser.setAddress("北京市");
57.         updateUser.setAge(39);
59.         User save = userMapper.save(updateUser);
60.         System.out.println("save = " + save);
61.     }
63.     @Test
64.     void find() {
65.         //模糊查询。精确查询
66.         Iterable<User> all = userMapper.findAll();
67.         List<User> list = new ArrayList<>();
68.         for (User user : all) {
69.             list.add(user);
70.         }
71.         // 使用Collections.sort方法按照用户的ID进行排序
72. //        Collections.sort(list, Comparator.comparing(User::getId));
74.         // 使用自定义比较器按照用户的ID进行排序
75.         Collections.sort(list, new Comparator<User>() {
76.             @Override
77.             public int compare(User user1, User user2) {
78.                 // 假设ID是字符串类型
79.                 return user1.getUsername().compareTo(user2.getUsername());
80.             }
81.         });
83.         // 使用流（Stream）按照用户的ID进行排序
84.         /*List<User> sortedList = list.stream()
85.                 .sorted(Comparator.comparing(User::getId))
86.                 .collect(Collectors.toList());*/
87.         // 现在list中的用户已按照ID升序排列
88.         for (User user : list) {
89.             System.out.println("user = " + user);
90.         }
92.     }
94.     @Test
95.     void findById() {
96.         //注意这里的id是字符串类型，然后userMapper中继承的id也必须是String类型
97.         Optional<User> byId = userMapper.findById("4");
98.         System.out.println("byId = " + byId);
99.     }
101.     @Test
102.     void findCount() {
103.         long count = userMapper.count();
104.         System.out.println("count 数 " + count);
105.     }
107.     @Test
108.     void existsById() {
109.         System.out.println("id是否存在： " + userMapper.existsById("1"));
110.     }
112.     @Test
113.     void findByIdAll() {
115.         ArrayList<String> ids = new ArrayList<>();
116.         ids.add("3");
117.         ids.add("5");
118.         ids.add("4");
119.         ids.add("66");
121.         //通过ids（集合）进行查询对应的user集合对象
122.         Iterable<User> allById = userMapper.findAllById(ids);
123.         for (User user : allById) {
124.             System.out.println("user = " + user);
125.         }
126.     }
129.     /**
130.      * 自定义查询
131.      */
132.     @Test
133.     void findByUsernameLike() {
134.         //模糊查询，会通过命名规范进行一个查询
135.         List<User> addr = userMapper.findByAddressLikeIgnoreCaseOrderByAgeDesc("河北");
136.         System.out.println("addr = " + addr);
138.         Page<User> page = userMapper.findByUsernameContaining("4", PageRequest.of(0, 100));
139.         System.out.println("page = " + page.getContent());
141.         User zhangList = userMapper.findByAge(16);
142.         System.out.println("user = " + zhangList);
144.         List<User> gender = userMapper.findByGender("女");
145.         System.out.println("gender = " + gender);
147.     }

复制代码

        以上步调是一个简朴的Spring Boot集成Elasticsearch的示例。你可以根据你的实际需求举行更复杂的配置和操作。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。