【Elasticsearch】黑马旅游网实践
文章目录
- 黑马旅游网实践
- 1.酒店搜索和分页
- 1.1 需求分析
- 1.2 定义实体类
- 1.3 定义controller
- 1.4 实现搜索业务
- 2.酒店结果过滤
- 2.1 需求分析
- 2.2 修改实体类RequestParams
- 2.3 修改搜索业务
- 3.查询周边的酒店
- 3.1 需求分析
- 3.2 修改实体类
- 3.3 距离排序API
- 3.4 添加距离排序
- 3.5 排序距离显示
- 4.酒店竞价排名
- 4.1 需求分析
- 4.2 修改HotelDoc实体
- 4.3 添加广告标记
- 4.4 添加算分函数查询
- 5.酒店实现聚合
- 5.1 需求分析
- 5.2 业务实现
- 6.酒店数据自动补全
- 6.1 需求分析
- 6.2 修改酒店映射结构
- 6.3 修改HotelDoc实体
- 6.4 实现搜索框自动补全
视频指路👉 B站黑马微服务超级推荐!!
黑马旅游网实践
1.酒店搜索和分页
1.1 需求分析
需求:实现黑马旅游的酒店搜索功能,完成关键字搜索和分页
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xHIc4bhd-1637396115894)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210721223859419.png?lastModify=1637367358)]](https://img-blog.csdnimg.cn/c1812788dd1d447bb090364849afd4cc.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
点击搜索按钮,可以看到浏览器控制台发出了请求:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-U8osrlj2-1637396115897)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210721224112708.png?lastModify=1637367392)]](https://img-blog.csdnimg.cn/6260cd090a004c51a46c496a23c55edc.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
由此可以知道,我们这个请求的信息如下:
- 请求方式:
POST - 请求路径:
/hotel/list - 请求参数:JSON对象,包含4个字段:
key:搜索关键字page:页码size:每页大小sortBy:排序,目前暂不实现
- 返回值:分页查询,需要返回分页结果
PageResult,包含两个属性:total:总条数List:当前页的数据
因此,我们实现业务的流程如下:
- 步骤一:定义实体类
RequestParams,接收请求参数的JSON对象 - 步骤二:编写
controller,接收页面的请求 - 步骤三:编写业务实现,利用
RestHighLevelClient实现搜索、分页
1.2 定义实体类
实体类有两个:
- 一个是前端的请求参数实体
RequestParams - 一个是服务端应该返回的响应结果实体
PageResult
(1)请求参数
前端请求的json结构如下:
{"key": "搜索关键字","page": 1,"size": 3,"sortBy": "default"
}
因此,我们在cn.itcast.hotel.pojo包下定义一个实体类RequestParams:
@Data
public class RequestParams {private String key;private Integer page;private Integer size;private String sortBy;
}
(2)返回值
分页查询,需要返回分页结果PageResult,包含两个属性:
total:总条数List:当前页的数据
因此,我们在cn.itcast.hotel.pojo中定义返回结果类PageResult:
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PageResult {private Long total;private List<HotelDoc> hotels;
}
1.3 定义controller
定义一个HotelController,声明查询接口,满足下列要求:
- 请求方式:
Post - 请求路径:
/hotel/list - 请求参数:对象,类型为
RequestParam - 返回值:
PageResult,包含两个属性Long total:总条数List:酒店数据hotels
因此,我们在cn.itcast.hotel.web中定义HotelController:
@RestController
@RequestMapping("/hotel")
public class HotelController {@Autowiredprivate IHotelService hotelService;// 搜索酒店数据@PostMapping("/list")public PageResult search(@RequestBody RequestParams params){return hotelService.search(params);}
}
1.4 实现搜索业务
(1)在cn.itcast.hotel.service中的IHotelService接口中定义一个方法:
/*** 根据关键字搜索酒店信息* @param params 请求参数对象,包含用户输入的关键字 * @return 酒店文档列表*/
PageResult search(RequestParams params);
(2)实现搜索业务,肯定离不开RestHighLevelClient,我们需要把它注册到Spring中作为一个Bean。在cn.itcast.hotel中的HotelDemoApplication中声明这个Bean:
@MapperScan("cn.itcast.hotel.mapper")
@SpringBootApplication
public class HotelDemoApplication {public static void main(String[] args) {SpringApplication.run(HotelDemoApplication.class, args);}@Beanpublic RestHighLevelClient client(){return new RestHighLevelClient(RestClient.builder(HttpHost.create("http://192.168.75.130:9200")));}
}
(3)在cn.itcast.hotel.service.impl中的HotelService中实现search方法:
@Override
public PageResult search(RequestParams params) {try {// 1.准备RequestSearchRequest request = new SearchRequest("hotel");// 2.准备DSL// 2.1.queryString key = params.getKey();if (key == null || "".equals(key)) {boolQuery.must(QueryBuilders.matchAllQuery());} else {boolQuery.must(QueryBuilders.matchQuery("all", key));}// 2.2.分页int page = params.getPage();int size = params.getSize();request.source().from((page - 1) * size).size(size);// 3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析响应return handleResponse(response);} catch (IOException e) {throw new RuntimeException(e);}
}
解析相响应方法handleResponse:
// 结果解析
private PageResult handleResponse(SearchResponse response) {// 4.解析响应SearchHits searchHits = response.getHits();// 4.1.获取总条数long total = searchHits.getTotalHits().value;// 4.2.文档数组SearchHit[] hits = searchHits.getHits();// 4.3.遍历List<HotelDoc> hotels = new ArrayList<>();for (SearchHit hit : hits) {// 获取文档sourceString json = hit.getSourceAsString();// 反序列化HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);// 放入集合hotels.add(hotelDoc);}// 4.4.封装返回return new PageResult(total, hotels);
}
2.酒店结果过滤
2.1 需求分析
需求:添加品牌、城市、星级、价格等过滤功能
如图:在页面搜索框下面,会有一些过滤项:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-02B8fWpS-1637396115900)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722091940726.png?lastModify=1637368217)]](https://img-blog.csdnimg.cn/bfebfe1f35464783a3bde7b549112305.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
传递的参数如图:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-fEPpvUwX-1637396115903)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722092051994.png?lastModify=1637368293)]](https://img-blog.csdnimg.cn/207272698efa44f1b18efc8d27be0c3c.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
包含的过滤条件有:
brand:品牌值city:城市minPrice~maxPrice:价格范围starName:星级
我们需要做两件事情:
- 修改请求参数的对象
RequestParams,接收上述参数 - 修改业务逻辑,在搜索条件之外,添加一些过滤条件
2.2 修改实体类RequestParams
修改在cn.itcast.hotel.pojo包下的实体类RequestParams:
@Data
public class RequestParams {private String key;private Integer page;private Integer size;private String sortBy;// 下面是新增的过滤条件参数private String city;private String brand;private String starName;private Integer minPrice;private Integer maxPrice;
}
2.3 修改搜索业务
在HotelService的search方法中,只有一个地方需要修改:requet.source().query( ... )其中的查询条件。
在之前的业务中,只有match查询,根据关键字搜索,现在要添加条件过滤,包括:
- 品牌过滤:是
keyword类型,用term查询 - 星级过滤:是
keyword类型,用term查询 - 价格过滤:是数值类型,用
range查询 - 城市过滤:是
keyword类型,用term查询
多个查询条件组合,肯定是boolean查询来组合:
- 关键字搜索放到
must中,参与算分 - 其它过滤条件放到
filter中,不参与算分
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-c7YovUeM-1637396115906)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722092935453.png?lastModify=1637368682)]](https://img-blog.csdnimg.cn/ac9e7bf4aa4d4bae8c6caeeabcfc4215.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
buildBasicQuery的代码如下:
private void buildBasicQuery(RequestParams params, SearchRequest request) {// 1.构建BooleanQueryBoolQueryBuilder boolQuery = QueryBuilders.boolQuery();// 2.关键字搜索String key = params.getKey();if (key == null || "".equals(key)) {boolQuery.must(QueryBuilders.matchAllQuery());} else {boolQuery.must(QueryBuilders.matchQuery("all", key));}// 3.城市条件if (params.getCity() != null && !params.getCity().equals("")) {boolQuery.filter(QueryBuilders.termQuery("city", params.getCity()));}// 4.品牌条件if (params.getBrand() != null && !params.getBrand().equals("")) {boolQuery.filter(QueryBuilders.termQuery("brand", params.getBrand()));}// 5.星级条件if (params.getStarName() != null && !params.getStarName().equals("")) {boolQuery.filter(QueryBuilders.termQuery("starName", params.getStarName()));}// 6.价格if (params.getMinPrice() != null && params.getMaxPrice() != null) {boolQuery.filter(QueryBuilders.rangeQuery("price").gte(params.getMinPrice()).lte(params.getMaxPrice()));}// 7.放入sourcerequest.source().query(boolQuery);
}
3.查询周边的酒店
3.1 需求分析
需求:查询我附近的酒店
在酒店列表页的右侧,有一个小地图,点击地图的定位按钮,地图会找到你所在的位置:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pGNn8Dm9-1637396115909)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722093414542.png?lastModify=1637369289)]](https://img-blog.csdnimg.cn/6bf180d829ae42759e82f32297267c0c.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
并且,在前端会发起查询请求,将你的坐标发送到服务端:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pA0Tuouk-1637396115912)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722093642382.png?lastModify=1637369522)]](https://img-blog.csdnimg.cn/b0c6ebb7c55248359299a2a43b17d78b.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
我们要做的事情就是基于这个location坐标,然后按照距离对周围酒店排序。实现思路如下:
- 修改
RequestParams参数,接收location字段 - 修改
search方法业务逻辑,如果location有值,添加根据geo_distance排序的功能
3.2 修改实体类
修改在cn.itcast.hotel.pojo包下的实体类RequestParams:
@Data
public class RequestParams {private String key;private Integer page;private Integer size;private String sortBy;private String city;private String brand;private String starName;private Integer minPrice;private Integer maxPrice;// 我当前的地理坐标private String location;
}
3.3 距离排序API
地理坐标排序的DSL语法,如下:
GET /indexName/_search
{"query": {"match_all": {}},"sort": [{"price": "asc" },{"_geo_distance" : {"FIELD" : "纬度,经度","order" : "asc","unit" : "km"}}]
}
对应的java代码示例:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-bj5VdxOe-1637396115913)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722095227059.png?lastModify=1637370477)]](https://img-blog.csdnimg.cn/52a91a7defdb47e7aaa3b358eeced5bc.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
3.4 添加距离排序
在cn.itcast.hotel.service.impl的HotelService的search方法中,添加一个排序功能:

代码如下:
@Override
public PageResult search(RequestParams params) {try {// 1.准备RequestSearchRequest request = new SearchRequest("hotel");// 2.准备DSL// 2.1.querybuildBasicQuery(params, request);// 2.2.分页int page = params.getPage();int size = params.getSize();request.source().from((page - 1) * size).size(size);// 2.3.排序String location = params.getLocation();if (location != null && !location.equals("")) {request.source().sort(SortBuilders.geoDistanceSort("location", new GeoPoint(location)).order(SortOrder.ASC).unit(DistanceUnit.KILOMETERS));}// 3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析响应return handleResponse(response);} catch (IOException e) {throw new RuntimeException(e);}
}
3.5 排序距离显示
重启服务后,测试我的酒店功能:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-PMjsqRyy-1637396115917)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722100040674.png?lastModify=1637370712)]](https://img-blog.csdnimg.cn/535d28eaa5bd46c8b0738d3771d1b9f4.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
发现确实可以实现对我附近酒店的排序,不过并没有看到酒店到底距离我多远
排序完成后,页面还要获取我附近每个酒店的具体距离值,这个值在响应结果中是独立的:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-1EGDrVNl-1637396115920)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722095648542.png?lastModify=1637370732)]](https://img-blog.csdnimg.cn/04b3c64d5c8b4cbaa67a948ad6076e32.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
因此,我们在结果解析阶段,除了解析source部分以外,还要得到sort部分,也就是排序的距离,然后放到响应结果中。
我们要做两件事:
- 修改
HotelDoc,添加排序距离字段,用于页面显示 - 修改
HotelService类中的handleResponse方法,添加对sort值的获取
(1)修改HotelDoc类,添加距离字段:
@Data
@NoArgsConstructor
public class HotelDoc {private Long id;private String name;private String address;private Integer price;private Integer score;private String brand;private String city;private String starName;private String business;private String location;private String pic;// 排序时的 距离值private Object distance;public HotelDoc(Hotel hotel) {this.id = hotel.getId();this.name = hotel.getName();this.address = hotel.getAddress();this.price = hotel.getPrice();this.score = hotel.getScore();this.brand = hotel.getBrand();this.city = hotel.getCity();this.starName = hotel.getStarName();this.business = hotel.getBusiness();this.location = hotel.getLatitude() + ", " + hotel.getLongitude();this.pic = hotel.getPic();}
}
(2)修改HotelService中的handleResponse方法:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-jJHY391f-1637396115921)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722100613966.png?lastModify=1637371150)]](https://img-blog.csdnimg.cn/814e275a87db4e3cadbe14fb3d759ab8.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
private PageResult handleResponse(SearchResponse response) {SearchHits searchHits = response.getHits();// 4.1.总条数long total = searchHits.getTotalHits().value;// 4.2.获取文档数组SearchHit[] hits = searchHits.getHits();// 4.3.遍历List<HotelDoc> hotels = new ArrayList<>(hits.length);for (SearchHit hit : hits) {// 4.4.获取sourceString json = hit.getSourceAsString();// 4.5.反序列化,非高亮的HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);// 4.6.排序距离信息Object[] sortValues = hit.getSortValues();if (sortValues.length > 0) {hotelDoc.setDistance(sortValues[0]);}// 4.7.放入集合hotels.add(hotelDoc);}return new PageResult(total, hotels);
}
重启后测试,发现页面能成功显示距离了:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-UHuoN8wc-1637396115923)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722100838604.png?lastModify=1637371203)]](https://img-blog.csdnimg.cn/ac22d0c5cb4d43ff9ac04d130875d687.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
4.酒店竞价排名
4.1 需求分析
需求:让指定的酒店(打了广告的)在搜索结果中排名置顶
要让指定酒店在搜索结果中排名置顶,效果如图:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-NeQBc8Id-1637396115925)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722100947292.png?lastModify=1637371314)]](https://img-blog.csdnimg.cn/4a3a7cb63dfb4581a615e3b636bc14df.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
那怎样才能让指定的酒店排名置顶呢?
我们之前学习过的function_score查询可以影响算分,算分高了,自然排名也就高了。而function_score包含3个要素:
- 过滤条件:哪些文档要加分
- 算分函数:如何计算function score
- 加权方式:function score 与 query score如何运算
解决办法:让指定酒店排名靠前。因此我们需要给这些酒店添加一个标记,这样在过滤条件中就可以根据这个标记来判断,是否要提高算分。
比如,我们给酒店添加一个字段:isAD,Boolean类型:
- true:是广告
- false:不是广告
这样function_score包含3个要素就很好确定了:
- 过滤条件:判断isAD 是否为true
- 算分函数:我们可以用最简单暴力的weight,固定加权值
- 加权方式:可以用默认的相乘,大大提高算分
因此,业务的实现步骤包括:
-
给
HotelDoc类添加isAD字段,Boolean类型 -
挑选几个你喜欢的酒店,给它的文档数据添加
isAD字段,值为true -
修改
search方法,添加function score功能,给isAD值为true的酒店增加权重
4.2 修改HotelDoc实体
给cn.itcast.hotel.pojo包下的HotelDoc类添加isAD字段:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-2ttsnhWP-1637396115927)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722101908062.png?lastModify=1637371650)]](https://img-blog.csdnimg.cn/4499da8d55c4406e9ceee3a4585de856.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
4.3 添加广告标记
接下来,我们挑几个酒店,添加isAD字段,设置为true:
POST /hotel/_update/1902197537
{"doc": {"isAD": true}
}
POST /hotel/_update/2056126831
{"doc": {"isAD": true}
}
POST /hotel/_update/1989806195
{"doc": {"isAD": true}
}
POST /hotel/_update/2056105938
{"doc": {"isAD": true}
}
4.4 添加算分函数查询
接下来我们就要修改查询条件了。之前是用的boolean 查询,现在要改成function_socre查询。
function_score查询结构如下:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-RWttbUH2-1637396115928)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210721191544750.png?lastModify=1637371776)]](https://img-blog.csdnimg.cn/f46d8b614ba8448fb1bf846d25a96a50.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
对应的JavaAPI如下:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xvp06UXW-1637396115930)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day06-Elasticsearch02%E8%AE%B2%E4%B9%89\assets\image-20210722102850818.png?lastModify=1637371790)]](https://img-blog.csdnimg.cn/56c27ce85b18428ab2e0a4dca90dc73a.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
我们可以将之前写的boolean查询作为原始查询条件放到query中,接下来就是添加过滤条件、算分函数、加权模式了。所以原来的代码依然可以沿用。
修改cn.itcast.hotel.service.impl包下的HotelService类中的buildBasicQuery方法,添加算分函数查询:
private void buildBasicQuery(RequestParams params, SearchRequest request) {// 1.构建BooleanQueryBoolQueryBuilder boolQuery = QueryBuilders.boolQuery();// 关键字搜索String key = params.getKey();if (key == null || "".equals(key)) {boolQuery.must(QueryBuilders.matchAllQuery());} else {boolQuery.must(QueryBuilders.matchQuery("all", key));}// 城市条件if (params.getCity() != null && !params.getCity().equals("")) {boolQuery.filter(QueryBuilders.termQuery("city", params.getCity()));}// 品牌条件if (params.getBrand() != null && !params.getBrand().equals("")) {boolQuery.filter(QueryBuilders.termQuery("brand", params.getBrand()));}// 星级条件if (params.getStarName() != null && !params.getStarName().equals("")) {boolQuery.filter(QueryBuilders.termQuery("starName", params.getStarName()));}// 价格if (params.getMinPrice() != null && params.getMaxPrice() != null) {boolQuery.filter(QueryBuilders.rangeQuery("price").gte(params.getMinPrice()).lte(params.getMaxPrice()));}// 2.算分控制FunctionScoreQueryBuilder functionScoreQuery =QueryBuilders.functionScoreQuery(// 原始查询,相关性算分的查询boolQuery,// function score的数组new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{// 其中的一个function score 元素new FunctionScoreQueryBuilder.FilterFunctionBuilder(// 过滤条件QueryBuilders.termQuery("isAD", true),// 算分函数ScoreFunctionBuilders.weightFactorFunction(10))});request.source().query(functionScoreQuery);
}
5.酒店实现聚合
5.1 需求分析
需求:搜索页面的品牌、城市等信息不应该是在页面写死,而是通过聚合索引库中的酒店数据得来的:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kIKeE9hc-1637396115931)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723192605566.png?lastModify=1637372021)]](https://img-blog.csdnimg.cn/e810756edcba4aaeb7c3d3d231a64fdd.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
分析:
首先我们看看为什么需要实现聚合?
目前,页面的城市列表、星级列表、品牌列表都是写死的,并不会随着搜索结果的变化而变化。但是用户搜索条件改变时,搜索结果会跟着变化。
例如:用户搜索“东方明珠”,那搜索的酒店肯定是在上海东方明珠附近,因此,城市只能是上海,此时城市列表中就不应该显示北京、深圳、杭州这些信息了。也就是说,搜索结果中包含哪些城市,页面就应该列出哪些城市;搜索结果中包含哪些品牌,页面就应该列出哪些品牌。
如何得知搜索结果中包含哪些品牌?如何得知搜索结果中包含哪些城市?
解决办法:
使用聚合功能,利用Bucket聚合,对搜索结果中的文档基于品牌分组、基于城市分组,就能得知包含哪些品牌、哪些城市了。
因为是对搜索结果聚合,因此聚合是限定范围的聚合,也就是说聚合的限定条件跟搜索文档的条件一致。
查看浏览器可以发现,前端其实已经发出了这样的一个请求:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pJEhHUsq-1637396115934)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723193730799.png?lastModify=1637395243)]](https://img-blog.csdnimg.cn/47860f4f16874596bd90d898f0cc455a.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
请求参数与搜索文档的参数完全一致。
返回值类型就是页面要展示的最终结果:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-YH7f5EiD-1637396115936)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723203915982.png?lastModify=1637395273)]](https://img-blog.csdnimg.cn/cfe2505f9ebb45a5a898f90a56a3a182.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
结果是一个Map结构:
key是字符串,城市、星级、品牌、价格value是集合,例如多个城市的名称
5.2 业务实现
在cn.itcast.hotel.web包的HotelController中添加一个方法,遵循下面的要求:
- 请求方式:
POST - 请求路径:
/hotel/filters - 请求参数:
RequestParams,与搜索文档的参数一致 - 返回值类型:
Map>
代码:
@PostMapping("filters")
public Map<String, List<String>> getFilters(@RequestBody RequestParams params){return hotelService.getFilters(params);
}
在cn.itcast.hotel.service.IHotelService中定义新方法:
Map<String, List<String>> filters(RequestParams params);
在cn.itcast.hotel.service.impl.HotelService中实现该方法:
@Override
public Map<String, List<String>> filters(RequestParams params) {try {// 1.准备RequestSearchRequest request = new SearchRequest("hotel");// 2.准备DSL// 2.1.querybuildBasicQuery(params, request);// 2.2.设置sizerequest.source().size(0);// 2.3.聚合buildAggregation(request);// 3.发出请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析结果Map<String, List<String>> result = new HashMap<>();Aggregations aggregations = response.getAggregations();// 4.1.根据品牌名称,获取品牌结果List<String> brandList = getAggByName(aggregations, "brandAgg");result.put("品牌", brandList);// 4.2.根据品牌名称,获取品牌结果List<String> cityList = getAggByName(aggregations, "cityAgg");result.put("城市", cityList);// 4.3.根据品牌名称,获取品牌结果List<String> starList = getAggByName(aggregations, "starAgg");result.put("星级", starList);return result;} catch (IOException e) {throw new RuntimeException(e);}
}
//把对需要字段的聚合抽取出来,这里是品牌,城市,星级
private void buildAggregation(SearchRequest request) {request.source().aggregation(AggregationBuilders.terms("brandAgg").field("brand").size(100));request.source().aggregation(AggregationBuilders.terms("cityAgg").field("city").size(100));request.source().aggregation(AggregationBuilders.terms("starAgg").field("starName").size(100));
}
//把通过聚合名称获取聚合结果封装成一个方法
private List<String> getAggByName(Aggregations aggregations, String aggName) {// 4.1.根据聚合名称获取聚合结果Terms brandTerms = aggregations.get(aggName);// 4.2.获取bucketsList<? extends Terms.Bucket> buckets = brandTerms.getBuckets();// 4.3.遍历List<String> brandList = new ArrayList<>();for (Terms.Bucket bucket : buckets) {// 4.4.获取keyString key = bucket.getKeyAsString();brandList.add(key);}return brandList;
}
6.酒店数据自动补全
6.1 需求分析
现在,我们的hotel索引库还没有设置拼音分词器,需要修改索引库中的配置。但是我们知道索引库是无法修改的,只能删除然后重新创建。
另外,我们需要添加一个字段,用来做自动补全,将brand、suggestion等都放进去,作为自动补全的提示。
因此,总结一下,我们需要做的事情包括:
-
修改
hotel索引库结构,设置自定义拼音分词器 -
修改索引库的
name、all字段,使用自定义分词器 -
索引库添加一个新字段
suggestion,类型为completion类型,使用自定义的分词器 -
给
HotelDoc类添加suggestion字段,内容包含brand、business -
重新导入数据到
hotel库
6.2 修改酒店映射结构
代码如下:
// 酒店数据索引库
PUT /hotel
{"settings": {"analysis": {"analyzer": {"text_anlyzer": {"tokenizer": "ik_max_word","filter": "py"},"completion_analyzer": {"tokenizer": "keyword","filter": "py"}},"filter": {"py": {"type": "pinyin","keep_full_pinyin": false,"keep_joined_full_pinyin": true,"keep_original": true,"limit_first_letter_length": 16,"remove_duplicated_term": true,"none_chinese_pinyin_tokenize": false}}}},"mappings": {"properties": {"id":{"type": "keyword"},"name":{"type": "text","analyzer": "text_anlyzer","search_analyzer": "ik_smart", "copy_to": "all"},"address":{"type": "keyword","index": false},"price":{"type": "integer"},"score":{"type": "integer"},"brand":{"type": "keyword","copy_to": "all"},"city":{"type": "keyword"},"starName":{"type": "keyword"},"business":{"type": "keyword","copy_to": "all"},"location":{"type": "geo_point"},"pic":{"type": "keyword","index": false},"all":{"type": "text","analyzer": "text_anlyzer","search_analyzer": "ik_smart"},"suggestion":{"type": "completion","analyzer": "completion_analyzer"}}}
}
6.3 修改HotelDoc实体
HotelDoc中要添加一个字段,用来做自动补全,内容可以是酒店品牌、城市、商圈等信息。按照自动补全字段的要求,最好是这些字段的数组。
因此我们在HotelDoc中添加一个suggestion字段,类型为List,然后将brand、business等信息放到里面。
代码如下:
@Data
@NoArgsConstructor
public class HotelDoc {private Long id;private String name;private String address;private Integer price;private Integer score;private String brand;private String city;private String starName;private String business;private String location;private String pic;private Object distance;private Boolean isAD;private List<String> suggestion;public HotelDoc(Hotel hotel) {this.id = hotel.getId();this.name = hotel.getName();this.address = hotel.getAddress();this.price = hotel.getPrice();this.score = hotel.getScore();this.brand = hotel.getBrand();this.city = hotel.getCity();this.starName = hotel.getStarName();this.business = hotel.getBusiness();this.location = hotel.getLatitude() + ", " + hotel.getLongitude();this.pic = hotel.getPic();// 组装suggestionif(this.business.contains("/")){// business有多个值,需要切割String[] arr = this.business.split("/");// 添加元素this.suggestion = new ArrayList<>();this.suggestion.add(this.brand);Collections.addAll(this.suggestion, arr);}else {this.suggestion = Arrays.asList(this.brand, this.business);}}
}
改完后,记得重新执行之前编写的导入数据功能,可以看到新的酒店数据中包含suggestion了:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-8CX0ufXj-1637396115938)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723213546183.png?lastModify=1637395973)]](https://img-blog.csdnimg.cn/06ae1d7c93ea44d5b8b054c07613308c.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
6.4 实现搜索框自动补全
查看前端页面,可以发现当我们在输入框键入时,前端会发起ajax请求:
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-as6jubAN-1637396115939)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723214021062.png?lastModify=1637395993)]](https://img-blog.csdnimg.cn/8bf25939713245b296eed29190031c88.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBATEwuTEVCUk9O,size_20,color_FFFFFF,t_70,g_se,x_16)
返回值是补全词条的集合,类型为List
(1)在cn.itcast.hotel.web包下的HotelController中添加新接口,接收新的请求:
@GetMapping("suggestion")
public List<String> getSuggestions(@RequestParam("key") String prefix) {return hotelService.getSuggestions(prefix);
}
(2)在cn.itcast.hotel.service包下的IhotelService中添加方法:
List<String> getSuggestions(String prefix);
(3)在cn.itcast.hotel.service.impl.HotelService中实现该方法:
@Override
public List<String> getSuggestions(String prefix) {try {// 1.准备RequestSearchRequest request = new SearchRequest("hotel");// 2.准备DSLrequest.source().suggest(new SuggestBuilder().addSuggestion("suggestions",SuggestBuilders.completionSuggestion("suggestion").prefix(prefix).skipDuplicates(true).size(10)));// 3.发起请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析结果Suggest suggest = response.getSuggest();// 4.1.根据补全查询名称,获取补全结果CompletionSuggestion suggestions = suggest.getSuggestion("suggestions");// 4.2.获取optionsList<CompletionSuggestion.Entry.Option> options = suggestions.getOptions();// 4.3.遍历List<String> list = new ArrayList<>(options.size());for (CompletionSuggestion.Entry.Option option : options) {String text = option.getText().toString();list.add(text);}return list;} catch (IOException e) {throw new RuntimeException(e);}
}

最后喜欢的小伙伴,记得三连哦!😏🍭😘
本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!
