Elasticsearch也可以实现商品智能搜索实战

╰半橙微兮° 2023-01-09 12:35 206阅读 0赞

Elasticsearch也可以实现商品智能搜索

本文主要讲解整合Elasticsearch的过程，以实现商品信息在Elasticsearch中的导入、查询、修改、删除为例。

项目使用框架介绍

Elasticsearch
Elasticsearch 是一个分布式、可扩展、实时的搜索与数据分析引擎。 它能从项目一开始就赋予你的数据以搜索、分析和探索的能力，可用于实现全文搜索和实时数据统计。

  1. package com.macro.mall.search.domain;
  3. import org.springframework.data.annotation.Id;
  4. import org.springframework.data.elasticsearch.annotations.Document;
  5. import org.springframework.data.elasticsearch.annotations.Field;
  6. import org.springframework.data.elasticsearch.annotations.FieldType;
  8. import java.io.Serializable;
  9. import java.math.BigDecimal;
  10. import java.util.List;
  12. @Document(indexName = "pms", type = "product",shards = 1,replicas = 0)
  13. public class EsProduct implements Serializable { 
  14.     private static final long serialVersionUID = -1L;
  15.     @Id
  16.     private Long id;
  17.     @Field(type = FieldType.Keyword)
  18.     private String productSn;
  19.     private Long brandId;
  20.     @Field(type = FieldType.Keyword)
  21.     private String brandName;
  22.     private Long productCategoryId;
  23.     @Field(type = FieldType.Keyword)
  24.     private String productCategoryName;
  25.     private String pic;
  26.     @Field(analyzer = "ik_max_word",type = FieldType.Text)
  27.     private String name;
  28.     @Field(analyzer = "ik_max_word",type = FieldType.Text)
  29.     private String subTitle;
  30.     @Field(analyzer = "ik_max_word",type = FieldType.Text)
  31.     private String keywords;
  32.     private BigDecimal price;
  33.     private Integer sale;
  34.     private Integer newStatus;
  35.     private Integer recommandStatus;
  36.     private Integer stock;
  37.     private Integer promotionType;
  38.     private Integer sort;
  39.     @Field(type =FieldType.Nested)
  40.     private List<EsProductAttributeValue> attrValueList;
  42.     public Long getId() { 
  43.         return id;
  44.     }
  46.     public void setId(Long id) { 
  47.         this.id = id;
  48.     }
  50.     public String getProductSn() { 
  51.         return productSn;
  52.     }
  54.     public void setProductSn(String productSn) { 
  55.         this.productSn = productSn;
  56.     }
  58.     public Long getBrandId() { 
  59.         return brandId;
  60.     }
  62.     public void setBrandId(Long brandId) { 
  63.         this.brandId = brandId;
  64.     }
  66.     public String getBrandName() { 
  67.         return brandName;
  68.     }
  70.     public void setBrandName(String brandName) { 
  71.         this.brandName = brandName;
  72.     }
  74.     public Long getProductCategoryId() { 
  75.         return productCategoryId;
  76.     }
  78.     public void setProductCategoryId(Long productCategoryId) { 
  79.         this.productCategoryId = productCategoryId;
  80.     }
  82.     public String getProductCategoryName() { 
  83.         return productCategoryName;
  84.     }
  86.     public void setProductCategoryName(String productCategoryName) { 
  87.         this.productCategoryName = productCategoryName;
  88.     }
  90.     public String getPic() { 
  91.         return pic;
  92.     }
  94.     public void setPic(String pic) { 
  95.         this.pic = pic;
  96.     }
  98.     public String getName() { 
  99.         return name;
  100.     }
  102.     public void setName(String name) { 
  103.         this.name = name;
  104.     }
  106.     public String getSubTitle() { 
  107.         return subTitle;
  108.     }
  110.     public void setSubTitle(String subTitle) { 
  111.         this.subTitle = subTitle;
  112.     }
  114.     public BigDecimal getPrice() { 
  115.         return price;
  116.     }
  118.     public void setPrice(BigDecimal price) { 
  119.         this.price = price;
  120.     }
  122.     public Integer getSale() { 
  123.         return sale;
  124.     }
  126.     public void setSale(Integer sale) { 
  127.         this.sale = sale;
  128.     }
  130.     public Integer getNewStatus() { 
  131.         return newStatus;
  132.     }
  134.     public void setNewStatus(Integer newStatus) { 
  135.         this.newStatus = newStatus;
  136.     }
  138.     public Integer getRecommandStatus() { 
  139.         return recommandStatus;
  140.     }
  142.     public void setRecommandStatus(Integer recommandStatus) { 
  143.         this.recommandStatus = recommandStatus;
  144.     }
  146.     public Integer getStock() { 
  147.         return stock;
  148.     }
  150.     public void setStock(Integer stock) { 
  151.         this.stock = stock;
  152.     }
  154.     public Integer getPromotionType() { 
  155.         return promotionType;
  156.     }
  158.     public void setPromotionType(Integer promotionType) { 
  159.         this.promotionType = promotionType;
  160.     }
  162.     public Integer getSort() { 
  163.         return sort;
  164.     }
  166.     public void setSort(Integer sort) { 
  167.         this.sort = sort;
  168.     }
  170.     public List<EsProductAttributeValue> getAttrValueList() { 
  171.         return attrValueList;
  172.     }
  174.     public void setAttrValueList(List<EsProductAttributeValue> attrValueList) { 
  175.         this.attrValueList = attrValueList;
  176.     }
  178.     public String getKeywords() { 
  179.         return keywords;
  180.     }
  182.     public void setKeywords(String keywords) { 
  183.         this.keywords = keywords;
  184.     }
  185. }

搜索中的商品属性信息

  1. package com.macro.mall.search.domain;
  3. import org.springframework.data.elasticsearch.annotations.Field;
  4. import org.springframework.data.elasticsearch.annotations.FieldType;
  6. import java.io.Serializable;
  8. public class EsProductAttributeValue implements Serializable { 
  9.     private static final long serialVersionUID = 1L;
  10.     private Long id;
  11.     private Long productAttributeId;
  12.     //属性值
  13.     @Field(type = FieldType.Keyword)
  14.     private String value;
  15.     //属性参数：0->规格；1->参数
  16.     private Integer type;
  17.     //属性名称
  18.     @Field(type=FieldType.Keyword)
  19.     private String name;
  20.     public Long getId() { 
  21.         return id;
  22.     }
  24.     public void setId(Long id) { 
  25.         this.id = id;
  26.     }
  28.     public Long getProductAttributeId() { 
  29.         return productAttributeId;
  30.     }
  32.     public void setProductAttributeId(Long productAttributeId) { 
  33.         this.productAttributeId = productAttributeId;
  34.     }
  36.     public String getValue() { 
  37.         return value;
  38.     }
  40.     public void setValue(String value) { 
  41.         this.value = value;
  42.     }
  44.     public Integer getType() { 
  45.         return type;
  46.     }
  48.     public void setType(Integer type) { 
  49.         this.type = type;
  50.     }
  52.     public String getName() { 
  53.         return name;
  54.     }
  56.     public void setName(String name) { 
  57.         this.name = name;
  58.     }
  59. }

搜索相关商品品牌名称，分类名称及属性

  1. package com.macro.mall.search.domain;
  3. import java.util.List;
  6. public class EsProductRelatedInfo { 
  7.     private List<String> brandNames;
  8.     private List<String> productCategoryNames;
  9.     private List<ProductAttr>   productAttrs;
  11.     public List<String> getBrandNames() { 
  12.         return brandNames;
  13.     }
  15.     public void setBrandNames(List<String> brandNames) { 
  16.         this.brandNames = brandNames;
  17.     }
  19.     public List<String> getProductCategoryNames() { 
  20.         return productCategoryNames;
  21.     }
  23.     public void setProductCategoryNames(List<String> productCategoryNames) { 
  24.         this.productCategoryNames = productCategoryNames;
  25.     }
  27.     public List<ProductAttr> getProductAttrs() { 
  28.         return productAttrs;
  29.     }
  31.     public void setProductAttrs(List<ProductAttr> productAttrs) { 
  32.         this.productAttrs = productAttrs;
  33.     }
  35.     public static class ProductAttr{ 
  36.         private Long attrId;
  37.         private String attrName;
  38.         private List<String> attrValues;
  40.         public Long getAttrId() { 
  41.             return attrId;
  42.         }
  44.         public void setAttrId(Long attrId) { 
  45.             this.attrId = attrId;
  46.         }
  48.         public List<String> getAttrValues() { 
  49.             return attrValues;
  50.         }
  52.         public void setAttrValues(List<String> attrValues) { 
  53.             this.attrValues = attrValues;
  54.         }
  56.         public String getAttrName() { 
  57.             return attrName;
  58.         }
  60.         public void setAttrName(String attrName) { 
  61.             this.attrName = attrName;
  62.         }
  63.     }
  64. }

接口类

  1. package com.macro.mall.search.repository;
  3. import com.macro.mall.search.domain.EsProduct;
  4. import org.springframework.data.domain.Page;
  5. import org.springframework.data.domain.Pageable;
  6. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
  9. public interface EsProductRepository extends ElasticsearchRepository<EsProduct, Long> { 
  10.     /** * 搜索查询 * * @param name 商品名称 * @param subTitle 商品标题 * @param keywords 商品关键字 * @param page 分页信息 * @return */
  11.     Page<EsProduct> findByNameOrSubTitleOrKeywords(String name, String subTitle, String keywords,Pageable page);
  13. }

商品搜索管理Service实现类

  1. package com.macro.mall.search.service.impl;
  3. import com.macro.mall.search.dao.EsProductDao;
  4. import com.macro.mall.search.domain.EsProduct;
  5. import com.macro.mall.search.domain.EsProductRelatedInfo;
  6. import com.macro.mall.search.repository.EsProductRepository;
  7. import com.macro.mall.search.service.EsProductService;
  8. import org.elasticsearch.action.search.SearchResponse;
  9. import org.elasticsearch.common.lucene.search.function.FunctionScoreQuery;
  10. import org.elasticsearch.index.query.BoolQueryBuilder;
  11. import org.elasticsearch.index.query.QueryBuilders;
  12. import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
  13. import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
  14. import org.elasticsearch.search.aggregations.AbstractAggregationBuilder;
  15. import org.elasticsearch.search.aggregations.Aggregation;
  16. import org.elasticsearch.search.aggregations.AggregationBuilders;
  17. import org.elasticsearch.search.aggregations.bucket.filter.InternalFilter;
  18. import org.elasticsearch.search.aggregations.bucket.nested.InternalNested;
  19. import org.elasticsearch.search.aggregations.bucket.terms.LongTerms;
  20. import org.elasticsearch.search.aggregations.bucket.terms.StringTerms;
  21. import org.elasticsearch.search.aggregations.bucket.terms.Terms;
  22. import org.elasticsearch.search.sort.SortBuilders;
  23. import org.elasticsearch.search.sort.SortOrder;
  24. import org.slf4j.Logger;
  25. import org.slf4j.LoggerFactory;
  26. import org.springframework.beans.factory.annotation.Autowired;
  27. import org.springframework.data.domain.Page;
  28. import org.springframework.data.domain.PageImpl;
  29. import org.springframework.data.domain.PageRequest;
  30. import org.springframework.data.domain.Pageable;
  31. import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
  32. import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
  33. import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
  34. import org.springframework.stereotype.Service;
  35. import org.springframework.util.CollectionUtils;
  36. import org.springframework.util.StringUtils;
  38. import java.util.ArrayList;
  39. import java.util.Iterator;
  40. import java.util.List;
  41. import java.util.Map;
  43. @Service
  44. public class EsProductServiceImpl implements EsProductService { 
  45.     private static final Logger LOGGER = LoggerFactory.getLogger(EsProductServiceImpl.class);
  46.     @Autowired
  47.     private EsProductDao productDao;
  48.     @Autowired
  49.     private EsProductRepository productRepository;
  50.     @Autowired
  51.     private ElasticsearchTemplate elasticsearchTemplate;
  52.     @Override
  53.     public int importAll() { 
  54.         List<EsProduct> esProductList = productDao.getAllEsProductList(null);
  55.         Iterable<EsProduct> esProductIterable = productRepository.saveAll(esProductList);
  56.         Iterator<EsProduct> iterator = esProductIterable.iterator();
  57.         int result = 0;
  58.         while (iterator.hasNext()) { 
  59.             result++;
  60.             iterator.next();
  61.         }
  62.         return result;
  63.     }
  65.     @Override
  66.     public void delete(Long id) { 
  67.         productRepository.deleteById(id);
  68.     }
  70.     @Override
  71.     public EsProduct create(Long id) { 
  72.         EsProduct result = null;
  73.         List<EsProduct> esProductList = productDao.getAllEsProductList(id);
  74.         if (esProductList.size() > 0) { 
  75.             EsProduct esProduct = esProductList.get(0);
  76.             result = productRepository.save(esProduct);
  77.         }
  78.         return result;
  79.     }
  81.     @Override
  82.     public void delete(List<Long> ids) { 
  83.         if (!CollectionUtils.isEmpty(ids)) { 
  84.             List<EsProduct> esProductList = new ArrayList<>();
  85.             for (Long id : ids) { 
  86.                 EsProduct esProduct = new EsProduct();
  87.                 esProduct.setId(id);
  88.                 esProductList.add(esProduct);
  89.             }
  90.             productRepository.deleteAll(esProductList);
  91.         }
  92.     }
  94.     @Override
  95.     public Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize) { 
  96.         Pageable pageable = PageRequest.of(pageNum, pageSize);
  97.         return productRepository.findByNameOrSubTitleOrKeywords(keyword, keyword, keyword, pageable);
  98.     }
  100.     @Override
  101.     public Page<EsProduct> search(String keyword, Long brandId, Long productCategoryId, Integer pageNum, Integer pageSize,Integer sort) { 
  102.         Pageable pageable = PageRequest.of(pageNum, pageSize);
  103.         NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();
  104.         //分页
  105.         nativeSearchQueryBuilder.withPageable(pageable);
  106.         //过滤
  107.         if (brandId != null || productCategoryId != null) { 
  108.             BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  109.             if (brandId != null) { 
  110.                 boolQueryBuilder.must(QueryBuilders.termQuery("brandId", brandId));
  111.             }
  112.             if (productCategoryId != null) { 
  113.                 boolQueryBuilder.must(QueryBuilders.termQuery("productCategoryId", productCategoryId));
  114.             }
  115.             nativeSearchQueryBuilder.withFilter(boolQueryBuilder);
  116.         }
  117.         //搜索
  118.         if (StringUtils.isEmpty(keyword)) { 
  119.             nativeSearchQueryBuilder.withQuery(QueryBuilders.matchAllQuery());
  120.         } else { 
  121.             List<FunctionScoreQueryBuilder.FilterFunctionBuilder> filterFunctionBuilders = new ArrayList<>();
  122.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("name", keyword),
  123.                     ScoreFunctionBuilders.weightFactorFunction(10)));
  124.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("subTitle", keyword),
  125.                     ScoreFunctionBuilders.weightFactorFunction(5)));
  126.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("keywords", keyword),
  127.                     ScoreFunctionBuilders.weightFactorFunction(2)));
  128.             FunctionScoreQueryBuilder.FilterFunctionBuilder[] builders = new FunctionScoreQueryBuilder.FilterFunctionBuilder[filterFunctionBuilders.size()];
  129.             filterFunctionBuilders.toArray(builders);
  130.             FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(builders)
  131.                     .scoreMode(FunctionScoreQuery.ScoreMode.SUM)
  132.                     .setMinScore(2);
  133.             nativeSearchQueryBuilder.withQuery(functionScoreQueryBuilder);
  134.         }
  135.         //排序
  136.         if(sort==1){ 
  137.             //按新品从新到旧
  138.             nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("id").order(SortOrder.DESC));
  139.         }else if(sort==2){ 
  140.             //按销量从高到低
  141.             nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("sale").order(SortOrder.DESC));
  142.         }else if(sort==3){ 
  143.             //按价格从低到高
  144.             nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.ASC));
  145.         }else if(sort==4){ 
  146.             //按价格从高到低
  147.             nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.DESC));
  148.         }else{ 
  149.             //按相关度
  150.             nativeSearchQueryBuilder.withSort(SortBuilders.scoreSort().order(SortOrder.DESC));
  151.         }
  152.         nativeSearchQueryBuilder.withSort(SortBuilders.scoreSort().order(SortOrder.DESC));
  153.         NativeSearchQuery searchQuery = nativeSearchQueryBuilder.build();
  154.         LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
  155.         return productRepository.search(searchQuery);
  156.     }
  158.     @Override
  159.     public Page<EsProduct> recommend(Long id, Integer pageNum, Integer pageSize) { 
  160.         Pageable pageable = PageRequest.of(pageNum, pageSize);
  161.         List<EsProduct> esProductList = productDao.getAllEsProductList(id);
  162.         if (esProductList.size() > 0) { 
  163.             EsProduct esProduct = esProductList.get(0);
  164.             String keyword = esProduct.getName();
  165.             Long brandId = esProduct.getBrandId();
  166.             Long productCategoryId = esProduct.getProductCategoryId();
  167.             //根据商品标题、品牌、分类进行搜索
  168.             List<FunctionScoreQueryBuilder.FilterFunctionBuilder> filterFunctionBuilders = new ArrayList<>();
  169.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("name", keyword),
  170.                     ScoreFunctionBuilders.weightFactorFunction(8)));
  171.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("subTitle", keyword),
  172.                     ScoreFunctionBuilders.weightFactorFunction(2)));
  173.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("keywords", keyword),
  174.                     ScoreFunctionBuilders.weightFactorFunction(2)));
  175.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("brandId", brandId),
  176.                     ScoreFunctionBuilders.weightFactorFunction(10)));
  177.             filterFunctionBuilders.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.matchQuery("productCategoryId", productCategoryId),
  178.                     ScoreFunctionBuilders.weightFactorFunction(6)));
  179.             FunctionScoreQueryBuilder.FilterFunctionBuilder[] builders = new FunctionScoreQueryBuilder.FilterFunctionBuilder[filterFunctionBuilders.size()];
  180.             filterFunctionBuilders.toArray(builders);
  181.             FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(builders)
  182.                     .scoreMode(FunctionScoreQuery.ScoreMode.SUM)
  183.                     .setMinScore(2);
  184.             NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
  185.             builder.withQuery(functionScoreQueryBuilder);
  186.             builder.withPageable(pageable);
  187.             NativeSearchQuery searchQuery = builder.build();
  188.             LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
  189.             return productRepository.search(searchQuery);
  190.         }
  191.         return new PageImpl<>(null);
  192.     }
  194.     @Override
  195.     public EsProductRelatedInfo searchRelatedInfo(String keyword) { 
  196.         NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
  197.         //搜索条件
  198.         if(StringUtils.isEmpty(keyword)){ 
  199.             builder.withQuery(QueryBuilders.matchAllQuery());
  200.         }else{ 
  201.             builder.withQuery(QueryBuilders.multiMatchQuery(keyword,"name","subTitle","keywords"));
  202.         }
  203.         //聚合搜索品牌名称
  204.         builder.addAggregation(AggregationBuilders.terms("brandNames").field("brandName"));
  205.         //集合搜索分类名称
  206.         builder.addAggregation(AggregationBuilders.terms("productCategoryNames").field("productCategoryName"));
  207.         //聚合搜索商品属性，去除type=1的属性
  208.         AbstractAggregationBuilder aggregationBuilder = AggregationBuilders.nested("allAttrValues","attrValueList")
  209.                 .subAggregation(AggregationBuilders.filter("productAttrs",QueryBuilders.termQuery("attrValueList.type",1))
  210.                 .subAggregation(AggregationBuilders.terms("attrIds")
  211.                         .field("attrValueList.productAttributeId")
  212.                         .subAggregation(AggregationBuilders.terms("attrValues")
  213.                                 .field("attrValueList.value"))
  214.                         .subAggregation(AggregationBuilders.terms("attrNames")
  215.                                 .field("attrValueList.name"))));
  216.         builder.addAggregation(aggregationBuilder);
  217.         NativeSearchQuery searchQuery = builder.build();
  218.         return elasticsearchTemplate.query(searchQuery, response -> { 
  219.             LOGGER.info("DSL:{}",searchQuery.getQuery().toString());
  220.             return convertProductRelatedInfo(response);
  221.         });
  222.     }
  224.     /** * 将返回结果转换为对象 */
  225.     private EsProductRelatedInfo convertProductRelatedInfo(SearchResponse response) { 
  226.         EsProductRelatedInfo productRelatedInfo = new EsProductRelatedInfo();
  227.         Map<String, Aggregation> aggregationMap = response.getAggregations().getAsMap();
  228.         //设置品牌
  229.         Aggregation brandNames = aggregationMap.get("brandNames");
  230.         List<String> brandNameList = new ArrayList<>();
  231.         for(int i = 0; i<((Terms) brandNames).getBuckets().size(); i++){ 
  232.             brandNameList.add(((Terms) brandNames).getBuckets().get(i).getKeyAsString());
  233.         }
  234.         productRelatedInfo.setBrandNames(brandNameList);
  235.         //设置分类
  236.         Aggregation productCategoryNames = aggregationMap.get("productCategoryNames");
  237.         List<String> productCategoryNameList = new ArrayList<>();
  238.         for(int i=0;i<((Terms) productCategoryNames).getBuckets().size();i++){ 
  239.             productCategoryNameList.add(((Terms) productCategoryNames).getBuckets().get(i).getKeyAsString());
  240.         }
  241.         productRelatedInfo.setProductCategoryNames(productCategoryNameList);
  242.         //设置参数
  243.         Aggregation productAttrs = aggregationMap.get("allAttrValues");
  244.         List<LongTerms.Bucket> attrIds = ((LongTerms) ((InternalFilter) ((InternalNested) productAttrs).getProperty("productAttrs")).getProperty("attrIds")).getBuckets();
  245.         List<EsProductRelatedInfo.ProductAttr> attrList = new ArrayList<>();
  246.         for (Terms.Bucket attrId : attrIds) { 
  247.             EsProductRelatedInfo.ProductAttr attr = new EsProductRelatedInfo.ProductAttr();
  248.             attr.setAttrId((Long) attrId.getKey());
  249.             List<String> attrValueList = new ArrayList<>();
  250.             List<StringTerms.Bucket> attrValues = ((StringTerms) attrId.getAggregations().get("attrValues")).getBuckets();
  251.             List<StringTerms.Bucket> attrNames = ((StringTerms) attrId.getAggregations().get("attrNames")).getBuckets();
  252.             for (Terms.Bucket attrValue : attrValues) { 
  253.                 attrValueList.add(attrValue.getKeyAsString());
  254.             }
  255.             attr.setAttrValues(attrValueList);
  256.             if(!CollectionUtils.isEmpty(attrNames)){ 
  257.                 String attrName = attrNames.get(0).getKeyAsString();
  258.                 attr.setAttrName(attrName);
  259.             }
  260.             attrList.add(attr);
  261.         }
  262.         productRelatedInfo.setProductAttrs(attrList);
  263.         return productRelatedInfo;
  264.     }
  265. }

进行接口测试

将数据库中数据导入到Elasticsearch

在这里插入图片描述

进行商品搜索

在这里插入图片描述

发表评论

表情：
评论列表 （有 0 条评论，206人围观）

还没有评论，来说两句吧...

相关阅读