0
0

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地址是无法连接的，需要进行跨域配置，因为是前后端分离的

  1. 修改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. 导入依赖
  1. <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  4.         </dependency>
  1. 在配置文件中加入
  1. server:
  2.   port: 8000 //可以改端口
  3. spring:
  4.   elasticsearch:
  5.     rest:
  6.       uris:
  7.         - http://localhost:9200 //es容器的地址，ip要换成虚拟机ip
  1. 在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. }
  1. 编写Repository接口
  1. @Repository
  2. //泛型是Doc对象和ID的类型
  3. public interface OrderRepository extends ElasticsearchRepository<OrderDoc, String> {
  4.    
  5.    
  7. }
  1. 编写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. 实现类代码
  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. 结果响应对象
  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.     }
  23.     @Test
  24.     public void findById() {
  25.    
  26.    
  27.         System.out.println(orderDocService.findById("1"));
  28.     }
  30.     @Test
  31.     public void deleteById() {
  32.    
  33.    
  34.         orderDocService.deleteById("1");
  35.     }
  37.     @Test
  38.     public void updateById() {
  39.    
  40.    
  41.         OrderDoc orderDoc = orderDocService.findById("1");
  42.         orderDoc.setTitle("华为电脑");
  43.         orderDocService.updateById(orderDoc);
  44.     }
  46.     @Test
  47.     public void findList() {
  48.    
  49.    
  50.         OrderDoc orderDoc = new OrderDoc(null, 100l, "电脑");
  51.         PageResponse<OrderDoc> response = orderDocService.findList(orderDoc, 0, 10);
  52.         System.out.println(response.getTotal());
  53.         response.getList().forEach(System.out::println);
  55.     }
  57.     @Test
  58.     public void findAll() {
  59.    
  60.    
  61.         PageResponse<OrderDoc> response = orderDocService.findAll( 0, 10);
  62.         System.out.println(response.getTotal());
  63.         response.getList().forEach(System.out::println);
  64.     }
  66.     @Test
  67.     public void findHighlight() {
  68.    
  69.    
  70.         OrderDoc orderDoc = new OrderDoc(null, 100l, "电脑",null);
  71.         PageResponse<OrderDoc> response = orderDocService.findHighlight( orderDoc,0, 10);
  72.         System.out.println(response.getTotal());
  73.         response.getList().forEach(System.out::println);
  74.     }
  75. }

其中的高亮显示是在ES7.9.x版本才有的好像，我在ES7.7版本显示报错，有一个方法不支持了。

因此我上网找了一篇支持高亮显示的文章进行参考，最终实现高亮显示的效果

elasticsearch与springboot整合之高亮显示处理方法_springboot 对接es7.17的高亮不通过注解-CSDN博客

总结：目前SpringBoot集成ES主要有两种方式

  1. 通过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. 在配置文件中配置连接
  1. elasticsearch:  
  2.   host: 127.0.0.1  
  3.   port: 9200  
  4.   scheme: http
  1. 编写配置类进行客户端连接配置
  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，如果有需要的话就上网查下怎么用吧

标签： elasticsearch spring boot jenkins
本文转载自: https://blog.csdn.net/wxhlhxpy/article/details/143059670
版权归原作者 技术小泽 所有， 如有侵权，请联系我们删除。
登录后发布评论

“ES在SpringBoot集成使用”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？