当前位置：首页 > article >正文

springboot整合Elasticsearch介绍

article 2025/3/1 21:21:59

上一篇博客介绍了elasticsearch及其安装部署（https://chengpei.top/archives/elasticsearch-jieshao），这次就介绍了一下如何将ES和我们的springboot项目整合使用

连接工具

整合之前我们先介绍一款工具用于连接elasticsearch查询工具，我这里使用的是chrome游览器的一款插件Elasticsearch Head

输入es的地址点击连接即可，可以看到连接上了并且看到集群信息状态

索引
我们看到的列idx_wide_table_es_doc，代表的是索引，对应的mysql里就相当于表，一个索引就是一张表，这里展示的是有一张表
分区
我们看到的每一行代表集群的每一个节点，除了第一行的Unassigned，这行这个代表的未分配到节点的分区，图上的小方块0代表的就是分区，一个索引可以配置有由个分区组成，我这里测试的索引idx_wide_table_es_doc只配置了一个分区，所有分区号都是0
副本
这里索引idx_wide_table_es_doc下面有两个方块0，代表这个索引只有一个分区，有两个副本，但是第二个副本在Unassigned里呈现灰色，代表这个副本没有分配到节点，是无效的，所以整个集群健康状态才会是黄色的，正常的话就会是绿色的

使用的话可以到这个基本查询里选择索引以及查询条件

第一个选项must、must not、should，相当于mysql的and条件、条件取反、or条件
第二个选项时选择索引的列
第三个match代表分词查询，term是精确查询，wildcard是通配符查询类似mysql里的like，prefix是前缀匹配，fuzzy是纠错模糊查询，range是范围查询
具体的复杂查询需要学习一下ElasticSearch DSL 语句的使用

整合springboot

因为我这里环境用的是JDK8，Springboot版本是2.3.12.RELEASE，对应的ES只能用7.6.2，所以以下都是基于这个版本的，这里用到的是spring官方提供的一个依赖spring-boot-starter-data-elasticsearch，并且配置spring.elasticsearch.rest下的几个参数，比如：

spring:
  elasticsearch:
    rest:
      uris: http://192.168.0.35:9200
      username: xxxx
      password: xxx

将会自动装配ElasticsearchRestClientAutoConfiguration、ElasticsearchDataAutoConfiguration，这时就有几种用法去操作ES

ElasticsearchRepository

通过继承ElasticsearchRepository这个类，可以获得一些查询索引的方法，具体参考官方文档（https://docs.spring.io/spring-data/elasticsearch/reference/elasticsearch/repositories/elasticsearch-repositories.html），我用的少

RestHighLevelClient

这个类很多用过es的应该比较熟悉，是elasticsearch官方提供的一个高级客户端，这个是脱离了springboot也可以用

ElasticsearchRestTemplate

我这里习惯使用的是ElasticsearchRestTemplate，就像习惯使用RedisTemplate、RabbitTemplate等一样，Spring总会提供一些好用的Template类，通用性也会好一点，据说高版本的ES已经淘汰了RestHighLevelClient，当然我现在用的7.6.2版本还是都可以用的，不过跟着spring走一般都没错，这里给个简单的调用例子：

private SearchHits<HallItemSearchResult> search(String searchValue) {
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    queryBuilder.withQuery(QueryBuilders.matchQuery("name", searchValue));
    queryBuilder.withPageable(PageRequest.of(0, 500));
    return elasticsearchRestTemplate.search(queryBuilder.build(),
            HallItemSearchResult.class, IndexCoordinates.of("item_info"));
}

这段代码就是再item_info索引上根据name字段分词匹配的逻辑，具体的一些用法最好还是熟悉一下ElasticSearch DSL 语句，以及参考一下ElasticsearchRestTemplate里的一些方法定义

查看全文

http://www.kler.cn/a/452606.html