【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)]

点击搜索按钮,可以看到浏览器控制台发出了请求:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(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)]

由此可以知道,我们这个请求的信息如下:

  • 请求方式: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)]

传递的参数如图:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(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)]

包含的过滤条件有:

  • 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 修改搜索业务

HotelServicesearch方法中,只有一个地方需要修改: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)]

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)]

并且,在前端会发起查询请求,将你的坐标发送到服务端:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(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)]

我们要做的事情就是基于这个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)]

3.4 添加距离排序

cn.itcast.hotel.service.implHotelServicesearch方法中,添加一个排序功能:

在这里插入图片描述

代码如下:

@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)]

发现确实可以实现对我附近酒店的排序,不过并没有看到酒店到底距离我多远

排序完成后,页面还要获取我附近每个酒店的具体距离值,这个值在响应结果中是独立的:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(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)]

因此,我们在结果解析阶段,除了解析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)]

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)]

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)]

那怎样才能让指定的酒店排名置顶呢?

我们之前学习过的function_score查询可以影响算分,算分高了,自然排名也就高了。而function_score包含3个要素:

  • 过滤条件:哪些文档要加分
  • 算分函数:如何计算function score
  • 加权方式:function score 与 query score如何运算

解决办法:让指定酒店排名靠前。因此我们需要给这些酒店添加一个标记,这样在过滤条件中就可以根据这个标记来判断,是否要提高算分

比如,我们给酒店添加一个字段:isADBoolean类型:

  • true:是广告
  • false:不是广告

这样function_score包含3个要素就很好确定了:

  • 过滤条件:判断isAD 是否为true
  • 算分函数:我们可以用最简单暴力的weight,固定加权值
  • 加权方式:可以用默认的相乘,大大提高算分

因此,业务的实现步骤包括:

  1. HotelDoc类添加isAD字段,Boolean类型

  2. 挑选几个你喜欢的酒店,给它的文档数据添加isAD字段,值为true

  3. 修改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)]

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)]

对应的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)]

我们可以将之前写的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)]

分析

首先我们看看为什么需要实现聚合?

目前,页面的城市列表、星级列表、品牌列表都是写死的,并不会随着搜索结果的变化而变化。但是用户搜索条件改变时,搜索结果会跟着变化。

例如:用户搜索“东方明珠”,那搜索的酒店肯定是在上海东方明珠附近,因此,城市只能是上海,此时城市列表中就不应该显示北京、深圳、杭州这些信息了。也就是说,搜索结果中包含哪些城市,页面就应该列出哪些城市;搜索结果中包含哪些品牌,页面就应该列出哪些品牌。

如何得知搜索结果中包含哪些品牌?如何得知搜索结果中包含哪些城市?

解决办法:

使用聚合功能,利用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)]

请求参数与搜索文档的参数完全一致

返回值类型就是页面要展示的最终结果:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(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)]

结果是一个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等都放进去,作为自动补全的提示。

因此,总结一下,我们需要做的事情包括:

  1. 修改hotel索引库结构,设置自定义拼音分词器

  2. 修改索引库的nameall字段,使用自定义分词器

  3. 索引库添加一个新字段suggestion,类型为completion类型,使用自定义的分词器

  4. HotelDoc类添加suggestion字段,内容包含brandbusiness

  5. 重新导入数据到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)]

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)]

返回值是补全词条的集合,类型为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);}
}

在这里插入图片描述
最后喜欢的小伙伴,记得三连哦!😏🍭😘


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

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部