ES在SpringBoot集成利用

1. 在Docker中安装Elasticsearch

这里不了解docker甚至还没安装假造机的小伙伴可以去黑马的视频下找到资源，去下一个假造机

这里就不对ES进行过多介绍了，具体的效果去b站看看叭，这里直接速成利用

• 安装ES并启动
  

1. docker pull elasticsearch <ES版本>
2. eg：docker pull elasticsearch 7.7.0

复制代码

1. docker run --name elasticsearch //启动容器并命名
2. -d -e ES_JAVA_OPTS="-Xms512m -Xmx512m" 设置初始堆和最大堆内存
3. -e "discovery.type=single-node" //配置ES以单节点模式运行,不集群
4. -p 9200:9200 //-p 用于端口映射，格式为<宿主机端口>:<容器端口>
5. -p 9300:9300 elasticsearch:7.7.0

复制代码

也可以考虑用docker-compose一步到位进行安装
docker-compose 安装部署ElasticSearch 和 Kibana - 06 - 博客园 (cnblogs.com)
Kibana是ES的一个图形化操作工具，也可以利用es-head，这里我本人利用的是es-head，因此我讲的也是es-head安装
docker run后，浏览器访问ip:9200，假如显示以下内容即表示安装成功

然后安装ES-head

1. #拉取镜像
2. docker pull mobz/elasticsearch-head:5
4. #创建容器
5. docker create --name elasticsearch-head -p 9100:9100 mobz/elasticsearch-head:5
7. #启动容器
8. docker start elasticsearch-head
9. or
10. docker start 容器id （docker ps -a 查看容器id ）
11. //-a可以查看到未启动的容器

复制代码

安装后启动，浏览器打开ip:9100

这里直接输入ES地址是无法毗连的，需要进行跨域设置，因为是前后端分离的

• 修改docker中elasticsearch的elasticsearch.yml文件
  

1. docker exec -it elasticsearch /bin/bash （进不去使用容器id进入）
3. vi config/elasticsearch.yml

复制代码

在最下面参加两行

1. http.cors.enabled: true
2. http.cors.allow-origin: "*"

复制代码

按i进入插入模式，就可以编辑了，编辑完按ESC退出编辑模式，输入:,进入底行模式，再输入wq强制保存并退出，这些下令不懂的话去学下liunx基础
好了之后退出并重启服务就可以运行了

然后就可以了，至于分词器的话，根据业务需求来叭，也不是必须安装
Docker上安装部署Elasticsearch(ES)具体教程_docker安装es-CSDN博客想安装Kibana和ik的也可以看这篇文章
2. 在SpringBoot中利用ES

2.1. Spring Data Elasticsearch方式

• 导入依靠
  

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

复制代码

• 在设置文件中参加
  

1. server:
2.   port: 8000 //可以改端口
3. spring:
4.   elasticsearch:
5.     rest:
6.       uris:
7.         - http://localhost:9200 //es容器的地址，ip要换成虚拟机ip

复制代码

• 在java中编写实体对象，和ES进行映射
  

1. @Data //lombok的注解，要导入lombok
2. //定义索引，7以上的版本去掉了type属性
3. @Document(indexName = "goodsorder", shards = 1, replicas = 1)
4. @AllArgsConstructor
5. @NoArgsConstructor
6. public class OrderDoc implements Serializable {
7.    
8.    
9.     @Id
10.     @Field(type = FieldType.Keyword)
11.     private String id;
13.     @Field(type = FieldType.Long)
14.     private Long orderNo;
16.     @Field(type = FieldType.Text, analyzer = "ik_smart", searchAnalyzer = "ik_max_word")
17.     private String title;
19.     //用来封装高亮的结果
20.     private Map<String, List<String>> highlights;
22.     public OrderDoc(String id, Long orderNo ,String title){
23.    
24.    
25.         this.id = id;
26.         this.orderNo = orderNo;
27.         this.title =title;
28.     }
29. }

复制代码

• 编写Repository接口
  

1. @Repository
2. //泛型是Doc对象和ID的类型
3. public interface OrderRepository extends ElasticsearchRepository<OrderDoc, String> {
4.    
5.    
7. }

复制代码

• 编写Service实现CRUD基本操作
  

1. public interface OrderDocService {
2.    
3.    
5.     void saveAll(List<OrderDoc> orderDocs);
7.     OrderDoc findById(String id);
9.     void deleteById(String id);
11.     void updateById(OrderDoc orderDoc);
13.     PageResponse<OrderDoc> findList(OrderDoc orderDoc, Integer pageIndex, Integer pageSize);
15.     PageResponse<OrderDoc> findAll(Integer pageIndex, Integer pageSize);
17.     PageResponse<OrderDoc> findHighlight(OrderDoc orderDoc, Integer pageIndex, Integer pageSize);
18. }

复制代码

• 实现类代码
  

1. @Service
2. public class OrderDocServiceImpl implements OrderDocService {
3.    
4.    
6.     @Autowired
7.     private OrderRepository orderRepository;
8.     @Autowired
9.     private ElasticsearchRestTemplate template;
11.     @Override
12.     public void saveAll(List<OrderDoc> orderDocs) {
13.    
14.    
15.         orderRepository.saveAll(orderDocs);
16.     }
18.     @Override
19.     public OrderDoc findById(String id) {
20.    
21.    
22.         return orderRepository.findById(id).orElse(null);
23.     }
25.     @Override
26.     public void deleteById(String id) {
27.    
28.    
29.         orderRepository.deleteById(id);
30.     }
32.     @Override
33.     public void updateById(OrderDoc orderDoc) {
34.    
35.    
36.         orderRepository.save(orderDoc);
37.     }
39.     @Override
40.     public PageResponse<OrderDoc> findList(OrderDoc orderDoc, Integer pageIndex, Integer pageSize) {
41.    
42.    
43.         CriteriaQuery criteriaQuery = new CriteriaQuery(
44.                 new Criteria().and("title").contains(orderDoc.getTitle()),PageRequest.of(pageIndex,pageSize));
46.         SearchHits<OrderDoc> searchHits = template.search(criteriaQuery, OrderDoc.class);
48.         List<OrderDoc> orderDocList = searchHits.getSearchHits().stream()
49.                 .map(orderDocSearchHit -> orderDocSearchHit.getContent()).collect(Collectors.toList());
51.         return new PageResponse<OrderDoc>(searchHits.getTotalHits() ,orderDocList);
52.     }
54.     @Override
55.     public PageResponse<OrderDoc> findAll(Integer pageIndex, Integer pageSize) {
56.    
57.    
58.         Page<OrderDoc> page = orderRepository.findAll(PageRequest.of(pageIndex, pageSize));
59.         return new PageResponse<OrderDoc>(page.getTotalElements(),page.getContent());
60.     }
62.     @Override
63.     public PageResponse<OrderDoc> findHighlight(OrderDoc orderDoc, Integer pageIndex, Integer pageSize) {
64.    
65.    
66.         //查询条件
67.         CriteriaQuery criteriaQuery = new CriteriaQuery(
68.                 new Criteria().and("title").contains(orderDoc.getTitle()),
69.                 PageRequest.of(pageIndex,pageSize));
70.         //高亮字段
71.         HighlightBuilder highlightBuilder = new HighlightBuilder();
72.         highlightBuilder.field("title").preTags("<font style='color:red'>").postTags("</font>");
73.         criteriaQuery.setHighlightQuery(new HighlightQuery(highlightBuilder));
74.         //搜索结果
75.         SearchHits<OrderDoc> searchHits = template.search(criteriaQuery, OrderDoc.class);
77.         List<OrderDoc> orderDocList = searchHits.get().map(searchHit -> {
78.    
79.    
80.             //把高亮结果添加到doc中中
81.             OrderDoc doc = searchHit.getContent();
82.             //获取高亮
83.             doc.setHighlights(searchHit.getHighlightFields());
84.             return doc;
85.         }).collect(Collectors.toList());
87.         //处理结果
88.         return new PageResponse<>(searchHits.getTotalHits() , orderDocList);
89.     }
90. }

复制代码

• 结果响应对象
  

1. @Data
2. @AllArgsConstructor
3. @NoArgsConstructor
4. public class PageResponse<T> {
5.    
6.    
7.     private Long total;
8.     private List<T> list;
9. }

复制代码

8.编写测试类进行测试

1. public class OrderDocServiceTest {
2.    
3.    
5.     @Autowired
6.     private OrderDocService orderDocService;
8.     @Test
9.     public void saveAll() {
10.    
11.    
12.         orderDocService.saveAll(Arrays.asList(
13.                 new OrderDoc("1",100000l,"苹果电脑"),
14.                 new OrderDoc("2",100000l,"苹果电脑"),
15.                 new OrderDoc("3",100000l,"苹果电脑"),
16.                 new OrderDoc("4",100000l,"苹果电脑"),
17.                 new OrderDoc("5",100000l,"苹果电脑"),
18.                 new OrderDoc("6",100000l,"苹果电脑"),
19.                 new OrderDoc("7",100000l,"苹果电脑")
20.         ));
21.     }
24.     @Test
25.     public void findById() {
26.    
27.    
28.         System.out.println(orderDocService.findById("1"));
29.     }
31.     @Test
32.     public void deleteById() {
33.    
34.    
35.         orderDocService.deleteById("1");
36.     }
38.     @Test
39.     public void updateById() {
40.    
41.    
42.         OrderDoc orderDoc = orderDocService.findById("1");
43.         orderDoc.setTitle("华为电脑");
44.         orderDocService.updateById(orderDoc);
45.     }
47.     @Test
48.     public void findList() {
49.    
50.    
51.         OrderDoc orderDoc = new OrderDoc(null, 100l, "电脑");
52.         PageResponse<OrderDoc> response = orderDocService.findList(orderDoc, 0, 10);
53.         System.out.println(response.getTotal());
54.         response.getList().forEach(System.out::println);
56.     }
58.     @Test
59.     public void findAll() {
60.    
61.    
62.         PageResponse<OrderDoc> response = orderDocService.findAll( 0, 10);
63.         System.out.println(response.getTotal());
64.         response.getList().forEach(System.out::println);
65.     }
67.     @Test
68.     public void findHighlight() {
69.    
70.    
71.         OrderDoc orderDoc = new OrderDoc(null, 100l, "电脑",null);
72.         PageResponse<OrderDoc> response = orderDocService.findHighlight( orderDoc,0, 10);
73.         System.out.println(response.getTotal());
74.         response.getList().forEach(System.out::println);
75.     }
76. }

复制代码

其中的高亮显示是在ES7.9.x版本才有的似乎，我在ES7.7版本显示报错，有一个方法不支持了。
因此我上网找了一篇支持高亮显示的文章进行参考，最终实现高亮显示的效果
elasticsearch与springboot整合之高亮显示处理方法_springboot 对接es7.17的高亮不通过注解-CSDN博客
总结：目前SpringBoot集成ES主要有两种方式

• 通过Spring Data Elasticsearch，由SpringBoot官方集成好的直接利用即可，方便快捷，不过在一些高级查询上不太灵活
  

2.通过Java REST Client，可以针对行复杂操作或自定义行为的场景条件进行构造查询条件。
2.2. Java REST Client方式

利用步调：
1.导入依靠

1. <dependency>  
2.         <groupId>org.elasticsearch.client</groupId>  
3.         <artifactId>elasticsearch-rest-high-level-client</artifactId>  
4.         <version>7.10.1</version>  
5. </dependency>

复制代码

• 在设置文件中设置毗连
  

1. elasticsearch:  
2.   host: 127.0.0.1  
3.   port: 9200  
4.   scheme: http

复制代码

• 编写设置类进行客户端毗连设置
  

1. @Configuration  
2. public class ElasticsearchConfig {  
4.         @Value("${elasticsearch.host}")  
5.         private String host;  
7.         @Value("${elasticsearch.port}")  
8.         private int port;  
10.         @Value("${elasticsearch.scheme}")  
11.         private String scheme;  
13.         @Bean  
14.         public RestHighLevelClient restHighLevelClient() {  
15.                 RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, scheme));  
16.                 return new RestHighLevelClient(builder);  
17.         }  
18. }

复制代码

4.通过RestHighLevelClient提供的API来操作Elasticsearch数据。可以进行索引的创建、文档的增删改查等操作
注意：RestHighLevelClient在Elasticsearch 8.x版本后已被替换为Elasticsearch Java API Client，假如有需要的话就上网查下怎么用吧

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