如何基于Elasticsearch与Java Spring Boot实现性别个性化搜索自动补全

一、Elasticsearch 索引设计 #

直接用ES原生Completion Suggester的Category Context能力实现性别维度过滤，相比查询后二次过滤性能高10倍以上，适配补全场景的低延迟要求。

• 索引mapping配置参考：

PUT /search_autocomplete
{
  "mappings": {
    "properties": {
      "suggest_term": {
        "type": "completion",
        "analyzer": "standard",
        "preserve_position_increments": false,
        "contexts": [
          {
            "name": "gender_ctx",
            "type": "category",
            "path": "bind_genders"
          }
        ]
      },
      "bind_genders": {
        "type": "keyword"
      },
      "sort_weight": {
        "type": "integer"
      }
    }
  }
}

• 词条入库规则：
  • 性别专属词条：比如shirts for women绑定bind_genders = ["female"]，shoes for men绑定bind_genders = ["male"]，权重值参考对应性别用户群体的该词搜索热度设置，热度越高权重越大
  • 通用无性别偏向词条：比如shorts这类男女都有搜索需求的词，绑定bind_genders = ["male", "female", "neutral"]，权重参考全量用户搜索热度设置
  • 不要在查询时动态拼接"for men/for women"后缀，所有补全词条必须从真实搜索日志中沉淀，避免返回无对应商品结果的无效词条。

二、Spring Boot 后端实现 #

直接用官方Elasticsearch Java Client实现，不要用已经废弃的RestHighLevelClient，核心逻辑分三步：

• 用户性别上下文获取：请求进入补全接口时，从登录态/用户资料模块拉取当前用户的性别属性，未登录、性别未填写的场景默认走通用结果逻辑
• 构造带性别上下文的补全查询，核心代码参考：

// 入参是用户输入的搜索前缀，比如"Sh"
public List<String> getAutocompleteSuggestions(String prefix, Long userId) {
    // 拉取用户性别，空值代表无有效性别标识
    String userGender = userProfileService.getGenderByUserId(userId);
    // 构造上下文：匹配当前性别+中性通用词条
    List<CategoryQueryContext> genderContexts = StringUtils.isBlank(userGender)
            ? List.of(CategoryQueryContext.of(c -> c.category("neutral")))
            : List.of(
                    CategoryQueryContext.of(c -> c.category(userGender)),
                    CategoryQueryContext.of(c -> c.category("neutral"))
              );

    CompletionSuggester completionSuggester = CompletionSuggester.of(s -> s
            .field("suggest_term")
            .prefix(prefix)
            .size(10)
            .skipDuplicates(true)
            .contexts(Map.of("gender_ctx", genderContexts))
    );

    SearchResponse<SuggestDoc> response = elasticsearchClient.search(s -> s
                    .index("search_autocomplete")
                    .suggest(sug -> sug
                            .suggesters("gender_suggest", f -> f.completion(completionSuggester))
                    ),
            SuggestDoc.class
    );

    // 解析结果，按权重排序后返回
    return response.suggest()
            .get("gender_suggest")
            .stream()
            .flatMap(sug -> sug.completion().options().stream())
            .sorted(Comparator.comparingInt(opt -> -opt.score()))
            .map(opt -> opt.text())
            .toList();
}

// 索引对应的实体类
@Document(indexName = "search_autocomplete")
class SuggestDoc {
    @Id
    private String id;
    @CompletionField(contexts = {
            @CompletionContext(name = "gender_ctx", type = CompletionContextType.CATEGORY, path = "bind_genders")
    })
    private String suggestTerm;
    private List<String> bindGenders;
    private Integer sortWeight;
    // 省略getter/setter
}

• 降级逻辑：如果ES查询超时、报错，直接返回无性别过滤的通用前缀匹配补全结果，避免前端搜索框无响应。

三、日常运维规则 #

• 词库更新：每日离线统计前一天的全量搜索日志，分性别计算搜索词的PV、点击转化率，动态更新补全词库的词条和对应权重，删除连续7天无搜索量的冷词
• 排序规则：同前缀匹配下，性别专属词条权重高于通用词条，保证用户优先看到适配自己性别的结果
• 边界处理：对于性别属性为非二元的用户，统一返回中性+全量通用词条，不做强制性别适配

内容的提问来源于stack exchange，提问作者dev555