基础环境

jdk版本：17
springboot 版本：3.0.0
springcloud版本：2022.0.0
elasticserch版本：8.5.1

Maven 配置

     <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.0.0</version><relativePath/></parent><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>${sping-cloud-alibaba.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId></dependency><dependency><groupId>co.elastic.clients</groupId><artifactId>elasticsearch-java</artifactId></dependency>

业务常规开发

多条件&排序搜索文档数据

    public List<ProductResp> queryProductDoc(ProductReq req) {List<ProductResp> productList = Lists.newArrayList();List<Query> queries = getQueryConditions(req);SearchResponse<ProductResp> search  = elasticsearchClient.search(s -> s.index("product").query(q->q.bool(b->b.must(queries)))//分页查询，从第0页开始查询size个document.from(req.getPageNum()-1).size(req.getPageSize())//按createTime降序、状态升序排序.sort(f->f.field(o->o.field("createTime").order(SortOrder.Desc))).sort(f->f.field(o->o.field("status").order(SortOrder.Asc))),ProductResp.class);for (Hit<ProductResp> hit : search.hits().hits()) {ProductResp resp = hit.source();productList.add(resp);}return productList;}/*** 组装查询的条件* @param req* @return*/private List<Query> getQueryConditions(ProductReq req){List<Query> queries = new ArrayList<>();if(CollectionUtils.isNotEmpty(req.getBrandIds())){List<FieldValue> values = new ArrayList<>();for (String id : req.getBrandIds()) {values.add(FieldValue.of(id));}//brandId字段精确查询Query brandQuery = TermsQuery.of(t -> t.field("brandId").terms(new TermsQueryField.Builder().value(values).build()))._toQuery();queries.add(brandQuery);}if(!Objects.isNull(req.getCategoryCodes())&&req.getCategoryCodes()!=0){List<FieldValue> values = new ArrayList<>();values.add(FieldValue.of(req.getCategoryCodes()));//categoryCodes精确匹配多个枚举值（类似sql in查询： where categoryCodes in (values)）Query mallL5CategoriesQuery = TermsQuery.of(t->t.field("categoryCodes").terms(new TermsQueryField.Builder().value(values).build()))._toQuery();queries.add(mallL5CategoriesQuery);}if(!Objects.isNull(req.getIsHaveStock())){if(req.getIsHaveStock()==1){JsonData stockFlag = JsonData.of(0);//availableStock范围查询（类似sql：where availableStock>xxx）Query hasStockQuery = RangeQuery.of(t->t.field("availableStock").gt(stockFlag))._toQuery();queries.add(hasStockQuery);}else{JsonData stockFlag = JsonData.of(0);Query hasStockQuery = RangeQuery.of(t->t.field("availableStock").lte(stockFlag))._toQuery();queries.add(hasStockQuery);}}if(StringUtils.isNotBlank(req.getKeyWord())){String keyword = req.getKeyWord();if (req.getKeyWord().contains("|")) {keyword = keyword.replace("|", "");} else {keyword = req.getKeyWord();}final String finalKeyWord = keyword;//前端传一个关键字匹配多字段，类似sql语句(where name like '%keyword%' or code like '%keyword%' or desc like '%keyword%' )Query nameQuery= MatchQuery.of(m->m.field("name").query(req.getKeyWord()))._toQuery();Query codeQuery= MatchQuery.of(m->m.field("code").query(finalKeyWord))._toQuery();Query descQuery= MatchQuery.of(m->m.field("desc").query(finalKeyWord))._toQuery();List<Query> newQuery = Arrays.asList(nameQuery, codeQuery, descQuery);Query query = BoolQuery.of(m -> m.should(newQuery))._toQuery();//skuCode //productSizequeries.add(query);}return queries;}