Elasticsearch 的自动补全以及RestAPI的使用

Elasticsearch 提供了强大的自动补全 (Autocomplete) 功能,以下为一个基础的自动补全DSL语句

{"suggest": {"my_suggestion": {  // 自定义建议器名称，可按需修改"text": "ap",     // 用户输入的前缀（如搜索框输入的字符）"completion": {"field": "title_completion",  // 必须是 mapping 中定义的 completion 类型字段"size": 5,                    // 返回最多 5 条补全结果"skip_duplicates": true       // 跳过重复结果}}}
}

带上下文过滤器的DSL语句,如果你的补全需要区分类别 / 场景（如「手机」和「电脑」分类下的不同补全），可以用 contexts 过滤：

{"suggest": {"my_suggestion": {"text": "ip","completion": {"field": "title_completion","size": 5,"contexts": {  // 上下文过滤规则"category": [  // 假设 mapping 中定义了 category 上下文{"context": "electronics",  // 只返回「电子产品」分类的补全"boost": 2  // 结果权重 +2（可选，用于调整优先级）}]}}}}
}

如果用户输入可能有拼写错误,可以开启 fuzzy

{"suggest": {"my_suggestion": {"text": "aple",  // 故意模拟拼写错误"completion": {"field": "title_completion","fuzzy": {      // 开启模糊匹配"fuzziness": 1  // 允许 1 次编辑距离（如增/删/改 1 个字符）}}}}
}

以下为在java代码当中运用的实例

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.suggest.Suggest;
import org.elasticsearch.search.suggest.SuggestBuilder;
import org.elasticsearch.search.suggest.SuggestBuilders;
import org.elasticsearch.search.suggest.completion.CompletionSuggestion;
import org.elasticsearch.search.builder.SearchSourceBuilder;
​
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
​
public class SimpleESAutocomplete {public static void main(String[] args) {// 构建 ES 客户端，连接本地 9200 端口try (RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")))) {
​// 执行最简自动补全查询，参数：客户端、索引名、补全字段、用户输入前缀List<String> results = basicCompletionSuggest(client, "users", "name_suggest", "mic");System.out.println("自动补全结果: " + results);
​} catch (IOException e) {e.printStackTrace();}}
​/*** 最简自动补全方法：仅用 Completion Suggester 实现基础补全* 流程拆分：1.准备Request  2.准备DSL  3.发起请求  4.解析结果* @param client   ES 客户端* @param index    索引名称* @param field    补全字段（需是 mapping 中配置的 completion 类型）* @param prefix   用户输入的前缀关键字* @return 补全建议结果列表* @throws IOException 网络或 ES 操作异常*/private static List<String> basicCompletionSuggest(RestHighLevelClient client, String index, String field, String prefix) throws IOException {// 1. 准备 Request（初始化搜索请求 & 绑定索引）SearchRequest searchRequest = new SearchRequest(index); 
​// 2. 准备 DSL（构建补全相关的查询逻辑，设置到 SearchSourceBuilder 中）// 2.1 构建补全建议器CompletionSuggestionBuilder suggestionBuilder = SuggestBuilders.completionSuggestion(field).prefix(prefix)  // 设置用户输入的前缀.size(5);        // 最多返回 5 条补全结果（可按需调整）// 2.2 组装建议查询SuggestBuilder suggestBuilder = new SuggestBuilder();suggestBuilder.addSuggestion("simple_suggest", suggestionBuilder); // 2.3 把建议查询放入搜索源SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();sourceBuilder.suggest(suggestBuilder); // 2.4 将构建好的 DSL 关联到 RequestsearchRequest.source(sourceBuilder); 
​// 3. 发起请求（调用客户端的 search 方法执行查询）SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT); 
​// 4. 解析结果（从响应中提取补全建议并封装成 List 返回）List<String> results = new ArrayList<>();Suggest suggest = response.getSuggest();if (suggest != null) {//根据补全查询名称，获取补全结果CompletionSuggestion completionSuggestion = suggest.getSuggestion("simple_suggest");//获取option里面就是我们要传回的数据completionSuggestion.getOptions().forEach(option -> results.add(option.getText().string()));}return results;}
}

自动补全对字段也是有要求的，比方说类型应该是completion，字段值是多词条的数组以便于分词。、

关键步骤：

1. 准备 Request：创建SearchRequest并指定索引。

2. 准备 DSL：

   • 使用CompletionSuggestionBuilder构建补全查询，设置前缀和返回数量。

   • 将补全查询添加到SearchSourceBuilder中。

3. 发起请求：执行查询并获取响应。

4. 解析结果：从响应中提取补全建议文本，存入List返回。

注意事项：

1. 数据准备：

   • 必须先在 ES 中创建索引并定义completion类型字段。

   • 向索引中写入文档时，需填充补全字段。

2. 映射限制：

   • completion类型字段不支持分词，仅支持精确前缀匹配。

   • 如需分词后的前缀匹配，可使用search_as_you_type类型。

3. 部署要求：

   • 本地需运行 Elasticsearch 服务（默认 9200 端口）。

   • 依赖 ES Java 客户端（Maven/Gradle 引入）。