经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » Elasticsearch » 查看文章
SpringBoot3集成ElasticSearch
来源：cnblogs　　作者：知了一笑　　时间：2023/8/16 9:14:07　　对本文有异议

目录

标签：ElasticSearch8.Kibana8；

一、简介

Elasticsearch是一个分布式、RESTful风格的搜索和数据分析引擎，适用于各种数据类型，数字、文本、地理位置、结构化数据、非结构化数据；

在实际的工作中，历经过Elasticsearch从6.0到7.0的版本升级，而这次SpringBoot3和ES8.0的集成，虽然脚本的语法变化很小，但是Java客户端的API语法变化很大；

二、环境搭建

1、下载安装包

需要注意的是，这些安装包的版本要选择对应的，不然容易出问题；

  1. 软件包：elasticsearch-8.8.2-darwin-x86_64.tar.gz
  2. 分词器工具：elasticsearch-analysis-ik-8.8.2.zip
  3. 可视化工具：kibana-8.8.2-darwin-x86_64.tar.gz

2、服务启动

不论是ES还是Kibana，在首次启动后，会初始化很多配置文件，可以根据自己的需要做相关的配置调整，比如常见的端口调整，资源占用，安全校验等；

  1. 1、启动ES
  2. elasticsearch-8.8.2/bin/elasticsearch
  4. 本地访问：localhost:9200
  6. 2、启动Kibana
  7. kibana-8.8.2/bin/kibana
  9. 本地访问：http://localhost:5601
  11. # 3、查看安装的插件
  12. http://localhost:9200/_cat/plugins  ->  analysis-ik 8.8.2

三、工程搭建

1、工程结构

2、依赖管理

在starter-elasticsearch组件中，实际上依赖的是elasticsearch-java组件的8.7.1版本；

  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  4.     <version>${spring-boot.version}</version>
  5. </dependency>

3、配置文件

在上面环境搭建的过程中，已经禁用了用户和密码的登录验证，配置ES服务地址即可；

  1. spring:
  2.   # ElasticSearch配置
  3.   elasticsearch:
  4.     uris: localhost:9200

四、基础用法

1、实体类

通过Document和Field注解描述ES索引结构的实体类，注意这里JsonIgnoreProperties注解，解决索引中字段和实体类非一一对应的而引起的JSON解析问题；

  1. @JsonIgnoreProperties(ignoreUnknown = true)
  2. @Document(indexName = "contents_index", createIndex = false)
  3. public class ContentsIndex implements Serializable {
  5.     private static final long serialVersionUID=1L;
  7.     @Field(type= FieldType.Integer)
  8.     private Integer id;
  10.     @Field(type= FieldType.Keyword)
  11.     private String title;
  13.     @Field(type= FieldType.Keyword)
  14.     private String intro;
  16.     @Field(type= FieldType.Text)
  17.     private String content;
  19.     @Field(type= FieldType.Integer)
  20.     private Integer createId;
  22.     @Field(type= FieldType.Keyword)
  23.     private String createName;
  25.     @Field(type= FieldType.Date,format = DateFormat.date_hour_minute_second)
  26.     private Date createTime;
  27. }

2、初始化索引

基于ElasticsearchTemplate类和上述实体类，实现索引结构的初始化，并且将tb_contents表中的数据同步到索引中，最后通过ID查询一条测试数据；

  1. @Service
  2. public class ContentsIndexService {
  3.     private static final Logger log = LoggerFactory.getLogger(ContentsIndexService.class);
  5.     @Resource
  6.     private ContentsService contentsService ;
  7.     @Resource
  8.     private ElasticsearchTemplate template ;
  10.     /**
  11.      * 初始化索引结构和数据
  12.      */
  13.     public void initIndex (){
  14.         // 处理索引结构
  15.         IndexOperations indexOps = template.indexOps(ContentsIndex.class);
  16.         if (indexOps.exists()){
  17.             boolean delFlag = indexOps.delete();
  18.             log.info("contents_index exists，delete:{}",delFlag);
  19.             indexOps.createMapping(ContentsIndex.class);
  20.         } else {
  21.             log.info("contents_index not exists");
  22.             indexOps.createMapping(ContentsIndex.class);
  23.         }
  24.         // 同步数据库表记录
  25.         List<Contents> contentsList = contentsService.queryAll();
  26.         if (contentsList.size() > 0){
  27.             List<ContentsIndex> contentsIndexList = new ArrayList<>() ;
  28.             contentsList.forEach(contents -> {
  29.                 ContentsIndex contentsIndex = new ContentsIndex() ;
  30.                 BeanUtils.copyProperties(contents,contentsIndex);
  31.                 contentsIndexList.add(contentsIndex);
  32.             });
  33.             template.save(contentsIndexList);
  34.         }
  35.         // ID查询
  36.         ContentsIndex contentsIndex = template.get("10",ContentsIndex.class);
  37.         log.info("contents-index-10:{}",contentsIndex);
  38.     }
  39. }

3、仓储接口

继承ElasticsearchRepository接口，可以对ES这种特定类型的存储库进行通用增删改查操作；在测试类中对该接口的方法进行测试；

  1. // 1、接口定义
  2. public interface ContentsIndexRepository extends ElasticsearchRepository<ContentsIndex,Long> {
  3. }
  5. // 2、接口测试
  6. public class ContentsIndexRepositoryTest {
  7.     @Autowired
  8.     private ContentsIndexRepository contentsIndexRepository;
  10.     @Test
  11.     public void testAdd (){
  12.         // 单个新增
  13.         contentsIndexRepository.save(buildOne());
  14.         // 批量新增
  15.         contentsIndexRepository.saveAll(buildList()) ;
  16.     }
  18.     @Test
  19.     public void testUpdate (){
  20.         // 根据ID查询后再更新
  21.         Optional<ContentsIndex> contentsOpt = contentsIndexRepository.findById(14L);
  22.         if (contentsOpt.isPresent()){
  23.             ContentsIndex contentsId = contentsOpt.get();
  24.             System.out.println("id=14:"+contentsId);
  25.             contentsId.setContent("update-content");
  26.             contentsId.setCreateTime(new Date());
  27.             contentsIndexRepository.save(contentsId);
  28.         }
  29.     }
  31.     @Test
  32.     public void testQuery (){
  33.         // 单个ID查询
  34.         Optional<ContentsIndex> contentsOpt = contentsIndexRepository.findById(1L);
  35.         if (contentsOpt.isPresent()){
  36.             ContentsIndex contentsId1 = contentsOpt.get();
  37.             System.out.println("id=1:"+contentsId1);
  38.         }
  39.         // 批量ID查询
  40.         Iterator<ContentsIndex> contentsIterator = contentsIndexRepository
  41.                                         .findAllById(Arrays.asList(10L,12L)).iterator();
  42.         while (contentsIterator.hasNext()){
  43.             ContentsIndex contentsIndex = contentsIterator.next();
  44.             System.out.println("id="+contentsIndex.getId()+":"+contentsIndex);
  45.         }
  46.     }
  48.     @Test
  49.     public void testDelete (){
  50.         contentsIndexRepository.deleteById(15L);
  51.         contentsIndexRepository.deleteById(16L);
  52.     }
  53. }

4、查询语法

无论是ElasticsearchTemplate类还是ElasticsearchRepository接口，都是对ES常用的简单功能进行封装，在实际使用时，复杂的查询语法还是依赖ElasticsearchClient和原生的API封装；

这里主要演示七个查询方法，主要涉及：ID查询，字段匹配，组合与范围查询，分页与排序，分组统计，最大值查询和模糊匹配；更多的查询API还是要多看文档中的案例才行；

  1. public class ElasticsearchClientTest {
  3.     @Autowired
  4.     private ElasticsearchClient client ;
  6.     @Test
  7.     public void testSearch1 () throws IOException {
  8.         // ID查询
  9.         GetResponse<ContentsIndex> resp = client.get(
  10.                 getReq ->getReq.index("contents_index").id("7"), ContentsIndex.class);
  11.         if (resp.found()){
  12.             ContentsIndex contentsIndex = resp.source() ;
  13.             System.out.println("contentsIndex-7："+contentsIndex);
  14.         }
  15.     }
  17.     @Test
  18.     public void testSearch2 () throws IOException {
  19.         // 指定字段匹配
  20.         SearchResponse<ContentsIndex> resp = client.search(searchReq -> searchReq.index("contents_index")
  21.                         .query(query -> query.match(field -> field
  22.                         .field("createName").query("张三"))),ContentsIndex.class);
  23.         printResp(resp);
  24.     }
  26.     @Test
  27.     public void testSearch3 () throws IOException {
  28.         // 组合查询：姓名和时间范围
  29.         Query byName = MatchQuery.of(field -> field.field("createName").query("王五"))._toQuery();
  30.         Query byTime = RangeQuery.of(field -> field.field("createTime")
  31.                         .gte(JsonData.of("2023-07-10T00:00:00"))
  32.                         .lte(JsonData.of("2023-07-12T00:00:00")))._toQuery();
  33.         SearchResponse<ContentsIndex> resp = client.search(searchReq -> searchReq.index("contents_index")
  34.                         .query(query -> query.bool(boolQuery -> boolQuery.must(byName).must(byTime))),ContentsIndex.class);
  35.         printResp(resp);
  36.     }
  38.     @Test
  39.     public void testSearch4 () throws IOException {
  40.         // 排序和分页，在14条数据中，根据ID倒序排列，从第5条往后取4条数据
  41.         SearchResponse<ContentsIndex> resp = client.search(searchReq -> searchReq.index("contents_index")
  42.                 .from(5).size(4)
  43.                 .sort(sort -> sort.field(sortField -> sortField.field("id").order(SortOrder.Desc))),ContentsIndex.class);
  44.         printResp(resp);
  45.     }
  47.     @Test
  48.     public void testSearch5 () throws IOException {
  49.         // 根据createId分组统计
  50.         SearchResponse<ContentsIndex> resp = client.search(searchReq -> searchReq.index("contents_index")
  51.                 .aggregations("createIdGroup",agg -> agg.terms(term -> term.field("createId"))),ContentsIndex.class);
  52.         Aggregate aggregate = resp.aggregations().get("createIdGroup");
  53.         LongTermsAggregate termsAggregate = aggregate.lterms();
  54.         Buckets<LongTermsBucket> buckets = termsAggregate.buckets();
  55.         for (LongTermsBucket termsBucket : buckets.array()) {
  56.             System.out.println(termsBucket.key() + " : " + termsBucket.docCount());
  57.         }
  58.     }
  60.     @Test
  61.     public void testSearch6 () throws IOException {
  62.         // 查询最大的ID
  63.         SearchResponse<ContentsIndex> resp = client.search(searchReq -> searchReq.index("contents_index")
  64.                 .aggregations("maxId",agg -> agg.max(field -> field.field("id"))),ContentsIndex.class);
  65.         for (Map.Entry<String, Aggregate> entry : resp.aggregations().entrySet()){
  66.             System.out.println(entry.getKey()+":"+entry.getValue().max().value());
  67.         }
  68.     }
  70.     @Test
  71.     public void testSearch7 () throws IOException {
  72.         // 模糊查询title字段，允许1个误差
  73.         Query byContent = FuzzyQuery.of(field -> field.field("title").value("设计").fuzziness("1"))._toQuery();
  74.         SearchResponse<ContentsIndex> resp = client.search(
  75.                 searchReq -> searchReq.index("contents_index").query(byContent),ContentsIndex.class);
  76.         printResp(resp);
  77.     }
  79.     private void printResp (SearchResponse<ContentsIndex> resp){
  80.         TotalHits total = resp.hits().total();
  81.         System.out.println("total："+total);
  82.         List<Hit<ContentsIndex>> hits = resp.hits().hits();
  83.         for (Hit<ContentsIndex> hit: hits) {
  84.             ContentsIndex contentsIndex = hit.source();
  85.             System.out.println(hit.id()+"："+contentsIndex);
  86.         }
  87.     }
  88. }

五、参考源码

  1. 文档仓库：
  2. https://gitee.com/cicadasmile/butte-java-note
  4. 源码仓库：
  5. https://gitee.com/cicadasmile/butte-spring-parent

原文链接：https://www.cnblogs.com/cicada-smile/p/17632955.html

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Elasticsearch热门文章

  • ES 14 - (底层原理) Elasticsearch内部如何处理不同type的数据
  • ES 15 - Elasticsearch中的数据类型 (text、keyword、date、geo等)
  • java中elasticsearch7.x关于nested类型的api使用，新增+更新
  • Elasticsearch 映射参数详解 fields
  • [Elasticsearch] ES聚合场景下部分结果数据未返回问题分析
  • ES 22 - Elasticsearch中如何进行日期(数值)范围查询
  • Elasticsearch查询之Term?Query示例解析
  • ElasticSearch 实现分词全文检索 - SpringBoot 完整实现 Demo 附源码【完结篇】
  • ElasticStack学习（十）：深入ElasticSearch搜索之QueryFiltering、多/单字符串的多字段查询
  • ElasticSearch7 设置外网访问

    • Elasticsearch推荐文章

  • 利用Elasticsearch实现地理位置、城市搜索服务
  • 日志采集/分析
  • ELKF（elasticsearch、logstash、kibana、filebeat）搭建及收集nginx日志特昂糖-
  • ElasticSearch性能原理拆解
  • Elasticsearch使用实战以及代码详解
  • 使用 Docker Compose V2 快速搭建日志分析平台 ELK (Elasticsearch、Logstash 和 Kibana)
  • 【解决方案】MySQL5.7 百万数据迁移到 ElasticSearch7.x 的思考
  • K8s部署轻量级日志收集系统EFK（elasticsearch + filebeat + kibana）
  • Docker下elasticsearch8部署、扩容、基本操作实战(含kibana)
  • Elasticsearch 保姆级入门篇

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号