SpringBoot集成ES实现分词查询，并实现相关内容高亮

四. 具体操作

1.创建索引

这个直接用postman put一个请求就行。链接依次为http协议:IP地址:端口/索引名称。ES默认的通信端口就是9200。lll是我随便取的一个索引名称。

没有postman的也可以写一个单元测试，然后使用javaAPI创建。

//创建客户端链接对象，localhost为IP地址，可以更改。
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http"))
);
//创建创建索引请求，eee为索引名称，可以更换
CreateIndexRequest request = new CreateIndexRequest("eee");
//获取ES的响应
CreateIndexResponse respOnse= client.indices().create(request,
RequestOptions.DEFAULT);
//打印true则成功创建
System.out.println(response.isAcknowledged());
//关闭客户端
client.close();


2. 给ES中添加数据

这里是添加的一行的数据，实际中可以循环添加多行，也可以一次性添加多行，ES有对应的接口。

//创建客户端，localhost为IP地址，可以更改。
RestHighLevelClient client =
new RestHighLevelClient(RestClient.builder(
new HttpHost("localhost",9200,"http")));
//创建索引请求
IndexRequest request = new IndexRequest();
//假设我们这里查出的每条记录都封装成一个map集合对象(当然也可以是普通的对象)
//eee是上面创建的索引名称
//userid是给增加的文档的ID（相当于MySQL表的一行数据的ID）ID不写也可以，ES会默认给一个ID。
request.index("eee").id(userid);
//转换为JSON字符串
ObjectMapper objectMapper = new ObjectMapper();
String string = objectMapper.writeValueAsString(map);
request.source(string, XContentType.JSON);
//发送请求并获取响应
IndexResponse respOnse= client.index(request, RequestOptions.DEFAULT);
System.out.println(response);
}
//关闭客户端
client.close();


3. 分词查询并对相关词条进行高亮

LinkedList list = new LinkedList<>();
//链接客户端
RestHighLevelClient client =
new RestHighLevelClient(RestClient.builder(
new HttpHost("localhost", 9200, "http")));
//构建查询请求
SearchRequest request = new SearchRequest();
//绑定索引
request.indices("eee");
//构建查询条件，username为想查询对应的字段，英雄联盟为输入的查询的内容
SearchSourceBuilder builder = new SearchSourceBuilder();
builder.query(QueryBuilders.matchQuery("articleTitle", "英雄联盟"));
//构建高亮条件
HighlightBuilder highlightBuilder =new HighlightBuilder();
//高亮词条前缀
highlightBuilder.preTags("");
//高亮词条后缀
highlightBuilder.postTags("");
//高亮的字段
highlightBuilder.field("articleTitle");
builder.highlighter(highlightBuilder);
//添加查询条件到请求中
request.source(builder);
//发送请求并获得响应
SearchResponse respOnse= client.search(request, RequestOptions.DEFAULT);
//获取查询到的结果
for (SearchHit hit : response.getHits()) {
//以map集合封装，highlightFields 就是查出来一条文档(记录)
Map highlightFields = hit.getHighlightFields();
//获取高亮结果
Text[] username= highlightFields.get("articleTitle").getFragments();
//覆盖原来map集合中的username的值
hit.getSourceAsMap().put("articleTitle",articleTitles[0].toString());
}
//关闭客户端
client.close();


4. 测试结果

我这里用swagger测试，也可以用postman，或者单元测试。