SpringBoot整合ES解析搜索返回字段问题
作者：我一直在流浪 发布时间：2023-01-26 21:39:53
标签：SpringBoot,整合,ES
1. 数据构造
索引2个文档到 hotel 索引中：
PUT /hotel/_doc/1
{
"title": "文雅酒店",
"city": "青岛",
"price": 556,
"create_time": "20200418120000",
"amenities": "浴池,普通停车场/充电停车场",
"full_room": false,
"location": {
"lat": 36.083078,
"lon": 120.37566
},
"praise": 10
}
PUT /hotel/_doc/2
{
"title": "金都嘉怡假日酒店",
"city": "北京",
"price": 337,
"create_time": "20210315200000",
"amenities": "wifi,充电停车场/可升降停车场",
"full_room": false,
"location": {
"lat": 39.915153,
"lon": 116.403
},
"praise": 60
}
PUT /hotel/_doc/1
{
"title": "文雅酒店",
"city": "青岛",
"price": 556,
"create_time": "20200418120000",
"amenities": "浴池,普通停车场/充电停车场",
"full_room": false,
"location": {
"lat": 36.083078,
"lon": 120.37566
},
"praise": 10
}
PUT /hotel/_doc/2
{
"title": "金都嘉怡假日酒店",
"city": "北京",
"price": 337,
"create_time": "20210315200000",
"amenities": "wifi,充电停车场/可升降停车场",
"full_room": false,
"location": {
"lat": 39.915153,
"lon": 116.403
},
"praise": 60
}
2. ElasticSearch 查询集群中所有索引中的所有文档
GET /hotel/_search
{
"took" : 499,
"timed_out" : false,
"_shards" : {
"total" : 5,
"successful" : 5,
"skipped" : 0,
"failed" : 0
},
"hits" : {
"total" : {
"value" : 2,
"relation" : "eq"
},
"max_score" : 1.0,
"hits" : [
{
"_index" : "hotel",
"_type" : "_doc",
"_id" : "2",
"_score" : 1.0,
"_source" : {
"title" : "金都嘉怡假日酒店",
"city" : "北京",
"price" : 337,
"create_time" : "20210315200000",
"amenities" : "wifi,充电停车场/可升降停车场",
"full_room" : false,
"location" : {
"lat" : 39.915153,
"lon" : 116.403
},
"praise" : 60
}
},
{
"_index" : "hotel",
"_type" : "_doc",
"_id" : "1",
"_score" : 1.0,
"_source" : {
"title" : "文雅酒店",
"city" : "青岛",
"price" : 556,
"create_time" : "20200418120000",
"amenities" : "浴池,普通停车场/充电停车场",
"full_room" : false,
"location" : {
"lat" : 36.083078,
"lon" : 120.37566
},
"praise" : 10
}
}
]
}
}
3. ElasticSearch 搜索结果字段解析
1. took 搜索请求耗费了多少毫秒
took 值告诉我们执行整个搜索请求耗费了多少毫秒。
2. shards 查询中参与分片的总数
_shards 部分告诉我们在查询中参与分片的总数，以及这些分片成功了多少个失败了多少个。正常情况下我们不希望分片失败，但是分片失败是可能发生的。如果我们遭遇到一种灾难级别的故障，在这个故障中丢失了相同分片的原始数据和副本，那么对这个分片将没有可用副本来对搜索请求作出响应。假若这样，Elasticsearch 将报告这个分片是失败的，但是会继续返回剩余分片的结果。
3. timed_out 查询是否超时
timed_out 值告诉我们查询是否超时。默认情况下，搜索请求不会超时。
4. hits 表示搜索结果
返回结果中最重要的部分是 hits ，它包含 total 字段来表示匹配到的文档总数，并且一个 hits 数组包含所查询结果的前十个文档。在解析搜索结果时，我们通常需要关注以下几个字段：
hits.total.value：匹配的文档总数。
hits.max_score：与查询所匹配文档的_score的最大值。
hits.hits：匹配的文档列表。
hits.hits._source：匹配的文档的原始数据。
hits.hits._score：匹配的文档的分数。它衡量了文档与查询的匹配程度,默认情况下，首先返回最相关的文档结果，就是说，返回的文档是按照score 降序排列的。
hits.hits.highlight：匹配的文档的高亮显示信息。
4. SpringBoot 整合ElasticSearch获取搜索结果
@Slf4j
@Service
public class ElasticSearchImpl {
@Autowired
private RestHighLevelClient restHighLevelClient;
public void searchUser() throws IOException {
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
SearchRequest searchRequest = new SearchRequest(new String[]{"hotel"},searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
TimeValue took = searchResponse.getTook();
System.out.println("took = " + took);
// 搜索结果
SearchHits searchHits = searchResponse.getHits();
// hits.total.value:匹配的文档总数
TotalHits totalHits = searchHits.getTotalHits();
long value = totalHits.value;
System.out.println("value = " + value);
// hits.max_score:与查询所匹配文档的_score的最大值
float maxScore = searchHits.getMaxScore();
System.out.println("maxScore = " + maxScore);
// hits.hits:匹配的文档列表
SearchHit[] hits = searchHits.getHits();
for (SearchHit hit : hits) {
// hits.hits._source：匹配的文档的原始数据
String sourceAsString = hit.getSourceAsString();
System.out.println("sourceAsString = " + sourceAsString);
// hits.hits._id：匹配的文档的id
String id = hit.getId();
System.out.println("id = " + id);
Map<String, DocumentField> fields = hit.getFields();
System.out.println("fields = " + fields);
String index = hit.getIndex();
System.out.println("index = " + index);
float score = hit.getScore();
System.out.println("score = " + score);
}
System.out.println(searchResponse);
}
}
@Slf4j
@Service
public class ElasticSearchImpl {
@Autowired
private RestHighLevelClient restHighLevelClient;
public void searchUser() throws IOException {
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
SearchRequest searchRequest = new SearchRequest(new String[]{"hotel"},searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
TimeValue took = searchResponse.getTook();
System.out.println("took = " + took);
// 搜索结果
SearchHits searchHits = searchResponse.getHits();
// hits.total.value:匹配的文档总数
TotalHits totalHits = searchHits.getTotalHits();
long value = totalHits.value;
System.out.println("value = " + value);
// hits.max_score:与查询所匹配文档的_score的最大值
float maxScore = searchHits.getMaxScore();
System.out.println("maxScore = " + maxScore);
// hits.hits:匹配的文档列表
SearchHit[] hits = searchHits.getHits();
for (SearchHit hit : hits) {
// hits.hits._source：匹配的文档的原始数据
String sourceAsString = hit.getSourceAsString();
System.out.println("sourceAsString = " + sourceAsString);
// hits.hits._id：匹配的文档的id
String id = hit.getId();
System.out.println("id = " + id);
Map<String, DocumentField> fields = hit.getFields();
System.out.println("fields = " + fields);
String index = hit.getIndex();
System.out.println("index = " + index);
float score = hit.getScore();
System.out.println("score = " + score);
}
System.out.println(searchResponse);
}
}
took=2ms
value = 2
maxScore = 1.0
sourceAsString = {"title":"金都嘉怡假日酒店","city":"北京","price":337,"create_time":"20210315200000","amenities":"wifi,充电停车场/可升降停车场","full_room":false,"location":{"lat":39.915153,"lon":116.403},"praise":60}
id = 2
fields = {}
index = hotel
score = 1.0
sourceAsString = {"title":"文雅酒店","city":"青岛","price":556,"create_time":"20200418120000","amenities":"浴池,普通停车场/充电停车场","full_room":false,"location":{"lat":36.083078,"lon":120.37566},"praise":10}
id = 1
fields = {}
index = hotel
score = 1.0
{
"took": 2,
"timed_out": false,
"_shards": {
"total": 5,
"successful": 5,
"skipped": 0,
"failed": 0
},
"hits": {
"total": {
"value": 2,
"relation": "eq"
},
"max_score": 1.0,
"hits": [
{
"_index": "hotel",
"_type": "_doc",
"_id": "2",
"_score": 1.0,
"_source": {
"title": "金都嘉怡假日酒店",
"city": "北京",
"price": 337,
"create_time": "20210315200000",
"amenities": "wifi,充电停车场/可升降停车场",
"full_room": false,
"location": {
"lat": 39.915153,
"lon": 116.403
},
"praise": 60
}
},
{
"_index": "hotel",
"_type": "_doc",
"_id": "1",
"_score": 1.0,
"_source": {
"title": "文雅酒店",
"city": "青岛",
"price": 556,
"create_time": "20200418120000",
"amenities": "浴池,普通停车场/充电停车场",
"full_room": false,
"location": {
"lat": 36.083078,
"lon": 120.37566
},
"praise": 10
}
}
]
}
}
5 .ElasticSearch 搜索结果的面试题
1. ElasticSearch 搜索结果中的 _score 字段是什么意思？
答：_score 字段表示匹配文档的相关度得分，分数越高表示匹配度越高。
2. ElasticSearch 搜索结果中的 highlight 字段是什么意思？
答：highlight 字段表示匹配文档中被高亮显示的字段及其高亮显示的内容。
3. 如何获取 ElasticSearch 搜索结果中的总文档数？
答：可以通过 hits.total.value 字段获取匹配的文档总数。
4. 如何获取 ElasticSearch 搜索结果中的匹配文档列表？
答：可以通过 hits.hits 字段获取匹配的文档列表。
5. 如何获取 ElasticSearch 搜索结果中匹配文档的原始数据？
答：可以通过 hits.hits._source 字段获取匹配文档的原始数据。
6. 如何获取 ElasticSearch 搜索结果中匹配文档的高亮显示信息？
答：可以通过 hits.hits.highlight 字段获取匹配文档的高亮显示信息。
7. ElasticSearch 搜索结果中的 _shards 字段是什么意思？
答：_shards 字段表示搜索涉及的分片信息，包括总分片数、成功的分片数、跳过的分片数和失败的分片数。
8. ElasticSearch 搜索结果中的 took 字段是什么意思？
答：took 字段表示搜索耗时，单位为毫秒。
来源：https://blog.csdn.net/qq_42764468/article/details/129674422
0
投稿猜你喜欢
- Java 实现网络爬虫框架最近在做一个搜索相关的项目，需要爬取网络上的一些链接存储到索引库中，虽然有很多开源的强大的爬虫框架，但本着学习的态
- Pom依赖<parent> <groupId>org.springframework.bo
ViewDragHelper是support.v4下提供的用于处理拖拽滑动的辅助类,查看Android的DrawerLayout源码,可以发- 前言今天给大家总结介绍一下Java类中this关键字和static关键字的用法。this关键字用法：this.属性可以调用类中的成员变量th
- 1、深度总结引用一位网友的话，说的非常好，如果别人问你static的作用；如果你说静态修饰 类的属性 和 类的方法 别人认为你是合格的；如果
- 1、 流的继承关系，以及字节流和字符流。2、 节点流FileOutputStream和FileInputStream和处理流Buffered
- 获取自定义菜单查询返回的结果有乱码解决方法：string Posturl = "https://api.weixin.qq.com
- 一个线程如何知道另一线程已经结束？Thread类提供了回答此问题的方法。有两种方法可以判定一个线程是否结束。第一，可以在线程中调用isAli
- 本文的目的是把json串转成map键值对存储，而且只存储叶节点的数据比如json数据如下：{responseHeader:{status:0
- 对接支付宝支付接口，官方文档已经写的很清楚了，但是也有很多像我一样的小白，第一次对接支付宝支付接口，会有些迷茫，所以我在此写下这篇文章，给我
- spring-boot-devtools是一个为开发者服务的一个模块，其中最重要的功能就是自动应用代码更改到最新的App上面去。原理是在发现
- 本文实例讲述了Java实现多个wav文件合成一个的方法。分享给大家供大家参考，具体如下：前面一篇介绍了java切割wav音频文件的方法，这里
- 写在前面关于数据结构，Java官方其实已经帮我们写好并封装起来了，在真正需要使用的时候直接调用即可，但为了更好的理解数据结构，我会按照源码的
- SqlMapConfig.xml的约束，也就是Mybatis主配置文件的约束<?xml version="1.0"
- 1集合的概念把集合看做是一个容器,集合不是一个类，是一套集合框架，框架体系包含很多的集合类，java api提供了集合存储任意类型（基本包装
- 在实际工作中，重试重发请求处理是一个非常常见的场景，比如:1、发送消息失败。2、调用远程服务失败。3、争抢锁失败。这些错误可能是因为网络波动
- 前言空间分配要点有：一是空间分配的连续性；二是动态内存申请；三是防止程序执行中出现异常错误。提示：开始讲解了嗷~后续会根据精力持续更新嗷！！
- 回顾Tomcat8打法先回顾下之前Tomcat789的打法这里先抛开 7 8之间的区别， 在8中，最后add到filterchain的都是一
- 1、继承Thread类方式这种方式适用于执行特定任务，并且需要获取处理后的数据的场景。举例：一个用于累加数组内数据的和的线程。public
- 责任链模式责任链模式的定义：使多个对象都有机会处理请求，从而避免请求的发送者和接受者之间的耦合关系， 将这个对象连成一条链，并沿着这条链传递
