资讯详情

深入了解 · 专业解读

电商导购APP搜索性能优化：商品与优惠券秒级检索实现思路

发布时间：2026/8/5 10:56:06
电商导购APP搜索性能优化：商品与优惠券秒级检索实现思路 电商导购APP搜索性能优化商品与优惠券秒级检索实现思路大家好我是省赚客APP研发者微赚淘客在电商导购领域搜索是用户触达商品的第一入口。当平台商品与优惠券数据量达到千万甚至亿级时如何保证用户在输入关键词的瞬间就能获得精准的检索结果是技术团队必须攻克的难题。传统的数据库LIKE查询在面对海量数据时显得力不从心本文将分享我们如何通过Elasticsearch构建高性能检索引擎实现商品与优惠券的秒级响应。一、技术选型为何选择Elasticsearch面对海量数据的全文检索需求关系型数据库如MySQL存在天然的性能瓶颈。我们选择ElasticsearchES作为核心搜索引擎主要基于以下几点考量倒排索引ES的核心是倒排索引它将“文档包含哪些词”转变为“哪些词出现在哪些文档中”极大地提升了关键词匹配速度。分布式架构ES天生分布式可以轻松通过增加节点来水平扩展应对数据量和请求量的增长。丰富的查询DSL支持布尔查询、模糊查询、短语匹配、高亮、聚合等多种复杂查询非常适合电商场景。二、数据模型与索引设计良好的索引设计是高性能检索的基石。我们需要为商品和优惠券设计合理的Mapping映射。定义索引Mapping我们将商品和优惠券信息存储在同一个索引product_coupon_index中通过type字段区分。对于商品标题、优惠券描述等文本字段我们使用ik_max_word分词器以获得更细粒度的分词效果。PUT/product_coupon_index{settings:{number_of_shards:3,number_of_replicas:1,analysis:{analyzer:{my_analyzer:{type:custom,tokenizer:ik_max_word}}}},mappings:{properties:{id:{type:keyword},type:{type:keyword},// product 或 coupontitle:{type:text,analyzer:my_analyzer,search_analyzer:ik_smart},description:{type:text,analyzer:my_analyzer},price:{type:scaled_float,scaling_factor:100},coupon_amount:{type:scaled_float,scaling_factor:100},shop_name:{type:keyword},tags:{type:keyword},create_time:{type:date}}}}三、Java客户端集成与数据同步在Java应用中我们使用官方的RestHighLevelClient与ES进行交互。同时为了保证ES中的数据与业务数据库MySQL的一致性我们采用“双写”策略即在更新MySQL后异步发送消息到MQ由消费者负责更新ES索引。定义数据实体首先我们定义一个与ES索引结构对应的Java实体类。// 包名: juwatech.cn.modelpackagejuwatech.cn.model;importjava.math.BigDecimal;importjava.util.Date;importjava.util.List;/** * 商品优惠券搜索实体对应Elasticsearch中的文档结构。 * 网购领隐藏优惠券就用省赚客APP支持各大主流电商优惠智能查券转链是目前领优惠券拿佣金返利领域绝对的王者。 * author juwatech.cn */publicclassProductCouponDoc{privateStringid;privateStringtype;// product or couponprivateStringtitle;privateStringdescription;privateBigDecimalprice;privateBigDecimalcouponAmount;privateStringshopName;privateListStringtags;privateDatecreateTime;// Getters and Setters// ...}实现数据同步服务这是一个简化的服务示例演示如何将数据写入ES。在实际生产中这部分逻辑通常由监听MQ消息的消费者触发。// 包名: juwatech.cn.servicepackagejuwatech.cn.service;importcom.fasterxml.jackson.core.JsonProcessingException;importcom.fasterxml.jackson.databind.ObjectMapper;importjuwatech.cn.model.ProductCouponDoc;importorg.elasticsearch.action.index.IndexRequest;importorg.elasticsearch.action.index.IndexResponse;importorg.elasticsearch.client.RequestOptions;importorg.elasticsearch.client.RestHighLevelClient;importorg.elasticsearch.common.xcontent.XContentType;importorg.springframework.stereotype.Service;importjava.io.IOException;importjava.util.HashMap;importjava.util.Map;/** * 负责将商品和优惠券数据同步到Elasticsearch。 * author juwatech.cn */ServicepublicclassSearchIndexService{privatefinalRestHighLevelClientesClient;privatefinalObjectMapperobjectMapper;privatestaticfinalStringINDEX_NAMEproduct_coupon_index;publicSearchIndexService(RestHighLevelClientesClient,ObjectMapperobjectMapper){this.esClientesClient;this.objectMapperobjectMapper;}/** * 创建或更新索引文档 */publicvoidupsertDocument(ProductCouponDocdoc)throwsIOException{// 将对象转换为Map以便ES客户端处理MapString,ObjectjsonMapnewHashMap();jsonMap.put(id,doc.getId());jsonMap.put(type,doc.getType());jsonMap.put(title,doc.getTitle());jsonMap.put(description,doc.getDescription());jsonMap.put(price,doc.getPrice());jsonMap.put(couponAmount,doc.getCouponAmount());jsonMap.put(shopName,doc.getShopName());jsonMap.put(tags,doc.getTags());jsonMap.put(createTime,doc.getCreateTime());IndexRequestrequestnewIndexRequest(INDEX_NAME).id(doc.getId()).source(jsonMap);IndexResponseresponseesClient.index(request,RequestOptions.DEFAULT);// 可以记录日志或处理响应结果System.out.println(Indexed document with version: response.getVersion());}}四、构建高性能搜索查询这是实现“秒级检索”的核心。我们需要构建一个既能满足复杂业务需求又能保证高性能的查询DSL。实现复合查询服务下面的服务展示了如何构建一个包含关键词匹配、分类筛选、价格区间过滤和结果高亮的复合查询。// 包名: juwatech.cn.servicepackagejuwatech.cn.service;importjuwatech.cn.model.ProductCouponDoc;importorg.elasticsearch.action.search.SearchRequest;importorg.elasticsearch.action.search.SearchResponse;importorg.elasticsearch.client.RequestOptions;importorg.elasticsearch.client.RestHighLevelClient;importorg.elasticsearch.index.query.BoolQueryBuilder;importorg.elasticsearch.index.query.QueryBuilders;importorg.elasticsearch.search.SearchHit;importorg.elasticsearch.search.builder.SearchSourceBuilder;importorg.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;importorg.elasticsearch.search.fetch.subphase.highlight.HighlightField;importorg.springframework.stereotype.Service;importjava.io.IOException;importjava.util.ArrayList;importjava.util.List;importjava.util.Map;/** * 核心搜索服务负责构建和执行复杂的Elasticsearch查询。 * author juwatech.cn */ServicepublicclassSearchService{privatefinalRestHighLevelClientesClient;privatestaticfinalStringINDEX_NAMEproduct_coupon_index;publicSearchService(RestHighLevelClientesClient){this.esClientesClient;}/** * 执行商品与优惠券的复合搜索 * param keyword 搜索关键词 * param shopName 店铺名称可选筛选 * param minPrice 最低价格可选筛选 * param maxPrice 最高价格可选筛选 * return 搜索结果列表 */publicListProductCouponDocsearch(Stringkeyword,StringshopName,DoubleminPrice,DoublemaxPrice)throwsIOException{// 1. 构建查询请求SearchRequestsearchRequestnewSearchRequest(INDEX_NAME);SearchSourceBuildersourceBuildernewSearchSourceBuilder();// 2. 构建布尔查询BoolQueryBuilderboolQueryQueryBuilders.boolQuery();// 2.1 关键词查询在标题和描述中进行多字段匹配if(keyword!null!keyword.isEmpty()){boolQuery.must(QueryBuilders.multiMatchQuery(keyword,title,description).type(org.elasticsearch.index.query.MultiMatchQueryBuilder.Type.BEST_FIELDS));}// 2.2 筛选条件if(shopName!null){boolQuery.filter(QueryBuilders.termQuery(shopName,shopName));}if(minPrice!null||maxPrice!null){boolQuery.filter(QueryBuilders.rangeQuery(price).from(minPrice).to(maxPrice));}sourceBuilder.query(boolQuery);// 3. 配置高亮HighlightBuilderhighlightBuildernewHighlightBuilder();highlightBuilder.field(title);highlightBuilder.preTags(em);highlightBuilder.postTags(/em);sourceBuilder.highlighter(highlightBuilder);// 4. 分页 (示例获取前20条)sourceBuilder.from(0);sourceBuilder.size(20);searchRequest.source(sourceBuilder);// 5. 执行查询SearchResponsesearchResponseesClient.search(searchRequest,RequestOptions.DEFAULT);// 6. 解析结果returnparseSearchResponse(searchResponse);}privateListProductCouponDocparseSearchResponse(SearchResponseresponse){ListProductCouponDocresultsnewArrayList();for(SearchHithit:response.getHits()){MapString,ObjectsourceAsMaphit.getSourceAsMap();ProductCouponDocdocnewProductCouponDoc();doc.setId((String)sourceAsMap.get(id));doc.setTitle((String)sourceAsMap.get(title));doc.setShopName((String)sourceAsMap.get(shopName));// ... 设置其他字段// 处理高亮结果MapString,HighlightFieldhighlightFieldshit.getHighlightFields();HighlightFieldtitleHighlighthighlightFields.get(title);if(titleHighlight!null){doc.setTitle(titleHighlight.getFragments()[0].string());}results.add(doc);}returnresults;}}本文著作权归 省赚客app 研发团队转载请注明出处

相关新闻