目錄

4.黑馬旅游案例

4.1.酒店搜索和分頁

4.1.1.需求分析

4.1.2.定義實體類

4.1.3.定義controller

4.1.4.實現(xiàn)搜索業(yè)務(wù)

4.2.酒店結(jié)果過濾

4.2.1.需求分析

4.2.2.修改實體類

4.2.3.修改搜索業(yè)務(wù)

4.3.我周邊的酒店

4.3.1.需求分析

4.3.2.修改實體類

4.3.3.距離排序API

4.3.4.添加距離排序

4.3.5.排序距離顯示

4.4.酒店競價排名

4.4.1.需求分析

4.4.2.修改HotelDoc實體

4.4.3.添加廣告標(biāo)記

4.4.4.添加算分函數(shù)查詢

4.黑馬旅游案例

下面，我們通過黑馬旅游的案例來實戰(zhàn)演練下之前學(xué)習(xí)的知識。

我們實現(xiàn)四部分功能：

• 酒店搜索和分頁

• 酒店結(jié)果過濾

• 我周邊的酒店

• 酒店競價排名

啟動我們提供的hotel-demo項目，其默認(rèn)端口是8089，訪問http://localhost:8090，就能看到項目頁面了：

4.1.酒店搜索和分頁

案例需求：實現(xiàn)黑馬旅游的酒店搜索功能，完成關(guān)鍵字搜索和分頁

4.1.1.需求分析

在項目的首頁，有一個大大的搜索框，還有分頁按鈕：

點擊搜索按鈕，可以看到瀏覽器控制臺發(fā)出了請求：

請求參數(shù)如下：

由此可以知道，我們這個請求的信息如下：

• 請求方式：POST

• 請求路徑：/hotel/list

• 請求參數(shù)：JSON對象，包含4個字段：

  • key：搜索關(guān)鍵字

  • page：頁碼

  • size：每頁大小

  • sortBy：排序，目前暫不實現(xiàn)

• 返回值：分頁查詢，需要返回分頁結(jié)果PageResult，包含兩個屬性：

  • total：總條數(shù)

  • List<HotelDoc>：當(dāng)前頁的數(shù)據(jù)

因此，我們實現(xiàn)業(yè)務(wù)的流程如下：

• 步驟一：定義實體類，接收請求參數(shù)的JSON對象

• 步驟二：編寫controller，接收頁面的請求

• 步驟三：編寫業(yè)務(wù)實現(xiàn)，利用RestHighLevelClient實現(xiàn)搜索、分頁

4.1.2.定義實體類

實體類有兩個，一個是前端的請求參數(shù)實體，一個是服務(wù)端應(yīng)該返回的響應(yīng)結(jié)果實體。

1）請求參數(shù)

前端請求的json結(jié)構(gòu)如下：

{
 ? ?"key": "搜索關(guān)鍵字",
 ? ?"page": 1,
 ? ?"size": 3,
 ? ?"sortBy": "default"
}

因此，我們在cn.itcast.hotel.pojo包下定義一個實體類：

package cn.itcast.hotel.pojo;
?
import lombok.Data;
?
@Data
public class RequestParams {
 ? ?private String key;
 ? ?private Integer page;
 ? ?private Integer size;
 ? ?private String sortBy;
}

2）返回值

分頁查詢，需要返回分頁結(jié)果PageResult，包含兩個屬性：

• total：總條數(shù)

• List<HotelDoc>：當(dāng)前頁的數(shù)據(jù)

因此，我們在cn.itcast.hotel.pojo中定義返回結(jié)果：

package cn.itcast.hotel.pojo;
?
import lombok.Data;
?
import java.util.List;
?
@Data
public class PageResult {
 ? ?private Long total;
 ? ?private List<HotelDoc> hotels;
?
 ? ?public PageResult() {
 ?  }
?
 ? ?public PageResult(Long total, List<HotelDoc> hotels) {
 ? ? ? ?this.total = total;
 ? ? ? ?this.hotels = hotels;
 ?  }
}

4.1.3.定義controller

定義一個HotelController，聲明查詢接口，滿足下列要求：

• 請求方式：Post

• 請求路徑：/hotel/list

• 請求參數(shù)：對象，類型為RequestParam

• 返回值：PageResult，包含兩個屬性

  • Long total：總條數(shù)

  • List<HotelDoc> hotels：酒店數(shù)據(jù)

因此，我們在cn.itcast.hotel.web中定義HotelController：

@RestController
@RequestMapping("/hotel")
public class HotelController {
?
 ? ?@Autowired
 ? ?private IHotelService hotelService;
    // 搜索酒店數(shù)據(jù)
 ? ?@PostMapping("/list")
 ? ?public PageResult search(@RequestBody RequestParams params){
 ? ? ? ?return hotelService.search(params);
 ?  }
}

4.1.4.實現(xiàn)搜索業(yè)務(wù)

我們在controller調(diào)用了IHotelService，并沒有實現(xiàn)該方法，因此下面我們就在IHotelService中定義方法，并且去實現(xiàn)業(yè)務(wù)邏輯。

1）在cn.itcast.hotel.service中的IHotelService接口中定義一個方法：

/**
 * 根據(jù)關(guān)鍵字搜索酒店信息
 * @param params 請求參數(shù)對象，包含用戶輸入的關(guān)鍵字 
 * @return 酒店文檔列表
 */
PageResult search(RequestParams params);

2）實現(xiàn)搜索業(yè)務(wù)，肯定離不開RestHighLevelClient，我們需要把它注冊到Spring中作為一個Bean。在cn.itcast.hotel中的HotelDemoApplication中聲明這個Bean：

@Bean
public RestHighLevelClient client(){
 ? ?return ?new RestHighLevelClient(RestClient.builder(
 ? ? ? ?HttpHost.create("http://192.168.150.101:9200")
 ?  ));
}

3）在cn.itcast.hotel.service.impl中的HotelService中實現(xiàn)search方法：

@Override
public PageResult search(RequestParams params) {
 ? ?try {
 ? ? ? ?// 1.準(zhǔn)備Request
 ? ? ? ?SearchRequest request = new SearchRequest("hotel");
 ? ? ? ?// 2.準(zhǔn)備DSL
 ? ? ? ?// 2.1.query
 ? ? ? ?String key = params.getKey();
 ? ? ? ?if (key == null || "".equals(key)) {
 ? ? ? ? ? ?request.source().query(QueryBuilders.matchAllQuery());
 ? ? ?  } else {
 ? ? ? ? ? ?request.source().query(QueryBuilders.matchQuery("all", key));
 ? ? ?  }
?
 ? ? ? ?// 2.2.分頁
 ? ? ? ?int page = params.getPage();
 ? ? ? ?int size = params.getSize();
 ? ? ? ?request.source().from((page - 1) * size).size(size);
?
 ? ? ? ?// 3.發(fā)送請求
 ? ? ? ?SearchResponse response = client.search(request, RequestOptions.DEFAULT);
 ? ? ? ?// 4.解析響應(yīng)
 ? ? ? ?return handleResponse(response);
 ?  } catch (IOException e) {
 ? ? ? ?throw new RuntimeException(e);
 ?  }
}
?
// 結(jié)果解析
private PageResult handleResponse(SearchResponse response) {
 ? ?// 4.解析響應(yīng)
 ? ?SearchHits searchHits = response.getHits();
 ? ?// 4.1.獲取總條數(shù)
 ? ?long total = searchHits.getTotalHits().value;
 ? ?// 4.2.文檔數(shù)組
 ? ?SearchHit[] hits = searchHits.getHits();
 ? ?// 4.3.遍歷
 ? ?List<HotelDoc> hotels = new ArrayList<>();
 ? ?for (SearchHit hit : hits) {
 ? ? ? ?// 獲取文檔source
 ? ? ? ?String json = hit.getSourceAsString();
 ? ? ? ?// 反序列化
 ? ? ? ?HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
        // 放入集合
 ? ? ? ?hotels.add(hotelDoc);
 ?  }
 ? ?// 4.4.封裝返回
 ? ?return new PageResult(total, hotels);
}

4.2.酒店結(jié)果過濾

需求：添加品牌、城市、星級、價格等過濾功能

4.2.1.需求分析

在頁面搜索框下面，會有一些過濾項：

傳遞的參數(shù)如圖：

包含的過濾條件有：

• brand：品牌值

• city：城市

• minPrice~maxPrice：價格范圍

• starName：星級

我們需要做兩件事情：

• 修改請求參數(shù)的對象RequestParams，接收上述參數(shù)

• 修改業(yè)務(wù)邏輯，在搜索條件之外，添加一些過濾條件

4.2.2.修改實體類

修改在cn.itcast.hotel.pojo包下的實體類RequestParams：

@Data
public class RequestParams {
 ? ?private String key;
 ? ?private Integer page;
 ? ?private Integer size;
 ? ?private String sortBy;
 ? ?// 下面是新增的過濾條件參數(shù)
 ? ?private String city;
 ? ?private String brand;
 ? ?private String starName;
 ? ?private Integer minPrice;
 ? ?private Integer maxPrice;
}

4.2.3.修改搜索業(yè)務(wù)

在HotelService的search方法中，只有一個地方需要修改：requet.source().query( ... )其中的查詢條件。

在之前的業(yè)務(wù)中，只有match查詢，根據(jù)關(guān)鍵字搜索，現(xiàn)在要添加條件過濾，包括：

• 品牌過濾：是keyword類型，用term查詢

• 星級過濾：是keyword類型，用term查詢

• 價格過濾：是數(shù)值類型，用range查詢

• 城市過濾：是keyword類型，用term查詢

多個查詢條件組合，肯定是boolean查詢來組合：

• 關(guān)鍵字搜索放到must中，參與算分

• 其它過濾條件放到filter中，不參與算分

因為條件構(gòu)建的邏輯比較復(fù)雜，這里先封裝為一個函數(shù)：

buildBasicQuery的代碼如下：

private void buildBasicQuery(RequestParams params, SearchRequest request) {
 ? ?// 1.構(gòu)建BooleanQuery
 ? ?BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
 ? ?// 2.關(guān)鍵字搜索
 ? ?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.放入source
 ? ?request.source().query(boolQuery);
}

4.3.我周邊的酒店

需求：我附近的酒店

4.3.1.需求分析

在酒店列表頁的右側(cè)，有一個小地圖，點擊地圖的定位按鈕，地圖會找到你所在的位置：

并且，在前端會發(fā)起查詢請求，將你的坐標(biāo)發(fā)送到服務(wù)端：

我們要做的事情就是基于這個location坐標(biāo)，然后按照距離對周圍酒店排序。實現(xiàn)思路如下：

• 修改RequestParams參數(shù)，接收location字段

• 修改search方法業(yè)務(wù)邏輯，如果location有值，添加根據(jù)geo_distance排序的功能

4.3.2.修改實體類

修改在cn.itcast.hotel.pojo包下的實體類RequestParams：

package cn.itcast.hotel.pojo;
?
import lombok.Data;
?
@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;
 ? ?// 我當(dāng)前的地理坐標(biāo)
 ? ?private String location;
}

4.3.3.距離排序API

我們以前學(xué)習(xí)過排序功能，包括兩種：

• 普通字段排序

• 地理坐標(biāo)排序

我們只講了普通字段排序?qū)?yīng)的java寫法。地理坐標(biāo)排序只學(xué)過DSL語法，如下：

GET?/indexName/_search
{
??"query":?{
????"match_all":?{}
??},
 ?"sort":?[
????{
??????"price":?"asc"??
????},
????{
??????"_geo_distance"?:?{
??????????"FIELD"?:?"緯度，經(jīng)度",
??????????"order"?:?"asc",
??????????"unit"?:?"km"
??????}
????}
??]
}

對應(yīng)的java代碼示例：

4.3.4.添加距離排序

在cn.itcast.hotel.service.impl的HotelService的search方法中，添加一個排序功能：

完整代碼：

@Override
public PageResult search(RequestParams params) {
 ? ?try {
 ? ? ? ?// 1.準(zhǔn)備Request
 ? ? ? ?SearchRequest request = new SearchRequest("hotel");
 ? ? ? ?// 2.準(zhǔn)備DSL
 ? ? ? ?// 2.1.query
 ? ? ? ?buildBasicQuery(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.發(fā)送請求
 ? ? ? ?SearchResponse response = client.search(request, RequestOptions.DEFAULT);
 ? ? ? ?// 4.解析響應(yīng)
 ? ? ? ?return handleResponse(response);
 ?  } catch (IOException e) {
 ? ? ? ?throw new RuntimeException(e);
 ?  }
}

4.3.5.排序距離顯示

重啟服務(wù)后，測試我的酒店功能：

發(fā)現(xiàn)確實可以實現(xiàn)對我附近酒店的排序，不過并沒有看到酒店到底距離我多遠(yuǎn)，這該怎么辦？

排序完成后，頁面還要獲取我附近每個酒店的具體距離值，這個值在響應(yīng)結(jié)果中是獨立的：

因此，我們在結(jié)果解析階段，除了解析source部分以外，還要得到sort部分，也就是排序的距離，然后放到響應(yīng)結(jié)果中。

我們要做兩件事：

• 修改HotelDoc，添加排序距離字段，用于頁面顯示

• 修改HotelService類中的handleResponse方法，添加對sort值的獲取

1）修改HotelDoc類，添加距離字段

package cn.itcast.hotel.pojo;
?
import lombok.Data;
import lombok.NoArgsConstructor;
?
?
@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方法

重啟后測試，發(fā)現(xiàn)頁面能成功顯示距離了：

4.4.酒店競價排名

需求：讓指定的酒店在搜索結(jié)果中排名置頂

4.4.1.需求分析

要讓指定酒店在搜索結(jié)果中排名置頂，效果如圖：

頁面會給指定的酒店添加廣告標(biāo)記。

那怎樣才能讓指定的酒店排名置頂呢？

我們之前學(xué)習(xí)過的function_score查詢可以影響算分，算分高了，自然排名也就高了。而function_score包含3個要素：

• 過濾條件：哪些文檔要加分

• 算分函數(shù)：如何計算function score

• 加權(quán)方式：function score 與 query score如何運算

這里的需求是：讓指定酒店排名靠前。因此我們需要給這些酒店添加一個標(biāo)記，這樣在過濾條件中就可以根據(jù)這個標(biāo)記來判斷，是否要提高算分。

比如，我們給酒店添加一個字段：isAD，Boolean類型：

• true：是廣告

• false：不是廣告

這樣function_score包含3個要素就很好確定了：

• 過濾條件：判斷isAD 是否為true

• 算分函數(shù)：我們可以用最簡單暴力的weight，固定加權(quán)值

• 加權(quán)方式：可以用默認(rèn)的相乘，大大提高算分

因此，業(yè)務(wù)的實現(xiàn)步驟包括：

1. 給HotelDoc類添加isAD字段，Boolean類型

2. 挑選幾個你喜歡的酒店，給它的文檔數(shù)據(jù)添加isAD字段，值為true

3. 修改search方法，添加function score功能，給isAD值為true的酒店增加權(quán)重

4.4.2.修改HotelDoc實體

給cn.itcast.hotel.pojo包下的HotelDoc類添加isAD字段：

4.4.3.添加廣告標(biāo)記

接下來，我們挑幾個酒店，添加isAD字段，設(shè)置為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.4.添加算分函數(shù)查詢

接下來我們就要修改查詢條件了。之前是用的boolean 查詢，現(xiàn)在要改成function_socre查詢。

function_score查詢結(jié)構(gòu)如下：

對應(yīng)的JavaAPI如下：

我們可以將之前寫的boolean查詢作為原始查詢條件放到query中，接下來就是添加過濾條件、算分函數(shù)、加權(quán)模式了。所以原來的代碼依然可以沿用。

修改cn.itcast.hotel.service.impl包下的HotelService類中的buildBasicQuery方法，添加算分函數(shù)查詢：文章來源地址http://www.zghlxwxcb.cn/news/detail-597550.html

private void buildBasicQuery(RequestParams params, SearchRequest request) {
 ? ?// 1.構(gòu)建BooleanQuery
 ? ?BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
 ? ?// 關(guān)鍵字搜索
 ? ?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(
 ? ? ? ?// 原始查詢，相關(guān)性算分的查詢
 ? ? ? ?boolQuery,
 ? ? ? ?// function score的數(shù)組
 ? ? ? ?new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{
 ? ? ? ? ? ?// 其中的一個function score 元素
 ? ? ? ? ? ?new FunctionScoreQueryBuilder.FilterFunctionBuilder(
 ? ? ? ? ? ? ? ?// 過濾條件
 ? ? ? ? ? ? ? ?QueryBuilders.termQuery("isAD", true),
 ? ? ? ? ? ? ? ?// 算分函數(shù)
 ? ? ? ? ? ? ? ?ScoreFunctionBuilders.weightFactorFunction(10)
 ? ? ? ? ?  )
 ? ? ?  });
 ? ?request.source().query(functionScoreQuery);
}

到了這里，關(guān)于【Elasticsearch】黑馬旅游案例的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！