11.9.黑馬旅游案例
下面,我們通過黑馬旅游的案例來實(shí)戰(zhàn)演練下之前學(xué)習(xí)的知識。
我們實(shí)現(xiàn)四部分功能:
- 酒店搜索和分頁
- 酒店結(jié)果過濾
- 我周邊的酒店
- 酒店競價(jià)排名
啟動我們提供的hotel-demo項(xiàng)目,其默認(rèn)端口是8089,訪問http://localhost:8089,就能看到項(xiàng)目頁面了:
11.9.1.酒店搜索和分頁
案例需求:實(shí)現(xiàn)黑馬旅游的酒店搜索功能,完成關(guān)鍵字搜索和分頁
11.9.1.1.需求分析
在項(xiàng)目的首頁,有一個(gè)大大的搜索框,還有分頁按鈕:
點(diǎn)擊搜索按鈕,可以看到瀏覽器控制臺發(fā)出了請求:
請求參數(shù)如下:
由此可以知道,我們這個(gè)請求的信息如下:
- 請求方式:POST
- 請求路徑:/hotel/list
- 請求參數(shù):JSON對象,包含4個(gè)字段:
- key:搜索關(guān)鍵字
- page:頁碼
- size:每頁大小
- sortBy:排序,目前暫不實(shí)現(xiàn)
- 返回值:分頁查詢,需要返回分頁結(jié)果PageResult,包含兩個(gè)屬性:
-
total
:總條數(shù) -
List<HotelDoc>
:當(dāng)前頁的數(shù)據(jù)
-
因此,我們實(shí)現(xiàn)業(yè)務(wù)的流程如下:
- 步驟一:定義實(shí)體類,接收請求參數(shù)的JSON對象
- 步驟二:編寫controller,接收頁面的請求
- 步驟三:編寫業(yè)務(wù)實(shí)現(xiàn),利用RestHighLevelClient實(shí)現(xiàn)搜索、分頁
11.9.1.2.定義實(shí)體類
實(shí)體類有兩個(gè),一個(gè)是前端的請求參數(shù)實(shí)體,一個(gè)是服務(wù)端應(yīng)該返回的響應(yīng)結(jié)果實(shí)體。
1)請求參數(shù)
前端請求的json結(jié)構(gòu)如下:
{
"key": "搜索關(guān)鍵字",
"page": 1,
"size": 3,
"sortBy": "default"
}
因此,我們在cn.itcast.hotel.pojo
包下定義一個(gè)實(shí)體類:
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,包含兩個(gè)屬性:
-
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;
}
}
11.9.1.3.定義controller
定義一個(gè)HotelController,聲明查詢接口,滿足下列要求:
- 請求方式:Post
- 請求路徑:/hotel/list
- 請求參數(shù):對象,類型為RequestParam
- 返回值:PageResult,包含兩個(gè)屬性
-
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);
}
}
11.9.1.4.實(shí)現(xiàn)搜索業(yè)務(wù)
我們在controller調(diào)用了IHotelService,并沒有實(shí)現(xiàn)該方法,因此下面我們就在IHotelService中定義方法,并且去實(shí)現(xiàn)業(yè)務(wù)邏輯。
1)在cn.itcast.hotel.service
中的IHotelService
接口中定義一個(gè)方法:
/**
* 根據(jù)關(guān)鍵字搜索酒店信息
* @param params 請求參數(shù)對象,包含用戶輸入的關(guān)鍵字
* @return 酒店文檔列表
*/
PageResult search(RequestParams params);
2)實(shí)現(xiàn)搜索業(yè)務(wù),肯定離不開RestHighLevelClient,我們需要把它注冊到Spring中作為一個(gè)Bean。在cn.itcast.hotel
中的HotelDemoApplication
中聲明這個(gè)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
中實(shí)現(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();
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
if (key == null || "".equals(key)) {
boolQuery.must(QueryBuilders.matchAllQuery());
} else {
boolQuery.must(QueryBuilders.matchQuery("all", key));
}
request.source().query(boolQuery);
// 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);
}
11.9.2.酒店結(jié)果過濾
需求:添加品牌、城市、星級、價(jià)格等過濾功能
11.9.2.1.需求分析
在頁面搜索框下面,會有一些過濾項(xiàng):
傳遞的參數(shù)如圖:
包含的過濾條件有:
- brand:品牌值
- city:城市
- minPrice~maxPrice:價(jià)格范圍
- starName:星級
我們需要做兩件事情:
- 修改請求參數(shù)的對象RequestParams,接收上述參數(shù)
- 修改業(yè)務(wù)邏輯,在搜索條件之外,添加一些過濾條件
11.9.2.2.修改實(shí)體類
修改在cn.itcast.hotel.pojo
包下的實(shí)體類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;
}
11.9.2.3.修改搜索業(yè)務(wù)
在HotelService的search方法中,只有一個(gè)地方需要修改:requet.source().query( … )其中的查詢條件。
在之前的業(yè)務(wù)中,只有match查詢,根據(jù)關(guān)鍵字搜索,現(xiàn)在要添加條件過濾,包括:
- 品牌過濾:是keyword類型,用term查詢
- 星級過濾:是keyword類型,用term查詢
- 價(jià)格過濾:是數(shù)值類型,用range查詢
- 城市過濾:是keyword類型,用term查詢
多個(gè)查詢條件組合,肯定是boolean查詢來組合:
- 關(guān)鍵字搜索放到must中,參與算分
- 其它過濾條件放到filter中,不參與算分
因?yàn)闂l件構(gòu)建的邏輯比較復(fù)雜,這里先封裝為一個(gè)函數(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.價(jià)格
if (params.getMinPrice() != null && params.getMaxPrice() != null) {
boolQuery.filter(QueryBuilders
.rangeQuery("price")
.gte(params.getMinPrice())
.lte(params.getMaxPrice())
);
}
// 7.放入source
request.source().query(boolQuery);
}
11.9.3.我周邊的酒店
需求:我附近的酒店
11.9.3.1.需求分析
在酒店列表頁的右側(cè),有一個(gè)小地圖,點(diǎn)擊地圖的定位按鈕,地圖會找到你所在的位置:
并且,在前端會發(fā)起查詢請求,將你的坐標(biāo)發(fā)送到服務(wù)端:
我們要做的事情就是基于這個(gè)location坐標(biāo),然后按照距離對周圍酒店排序。實(shí)現(xiàn)思路如下:
- 修改RequestParams參數(shù),接收location字段
- 修改search方法業(yè)務(wù)邏輯,如果location有值,添加根據(jù)geo_distance排序的功能
11.9.3.2.修改實(shí)體類
修改在cn.itcast.hotel.pojo
包下的實(shí)體類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;
}
11.9.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代碼示例:
11.9.3.4.添加距離排序
在cn.itcast.hotel.service.impl
的HotelService
的search
方法中,添加一個(gè)排序功能:
完整代碼:
@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);
}
}
11.9.3.5.排序距離顯示
重啟服務(wù)后,測試我的酒店功能:
發(fā)現(xiàn)確實(shí)可以實(shí)現(xiàn)對我附近酒店的排序,不過并沒有看到酒店到底距離我多遠(yuǎn),這該怎么辦?
排序完成后,頁面還要獲取我附近每個(gè)酒店的具體距離值,這個(gè)值在響應(yīng)結(jié)果中是獨(dú)立的:
因此,我們在結(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;
// 排序時(shí)的 距離值
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)頁面能成功顯示距離了:
11.9.4.酒店競價(jià)排名
需求:讓指定的酒店在搜索結(jié)果中排名置頂
11.9.4.1.需求分析
要讓指定酒店在搜索結(jié)果中排名置頂,效果如圖:
頁面會給指定的酒店添加廣告標(biāo)記。
那怎樣才能讓指定的酒店排名置頂呢?
我們之前學(xué)習(xí)過的function_score查詢可以影響算分,算分高了,自然排名也就高了。而function_score包含3個(gè)要素:
- 過濾條件:哪些文檔要加分
- 算分函數(shù):如何計(jì)算function score
- 加權(quán)方式:function score 與 query score如何運(yùn)算
這里的需求是:讓指定酒店排名靠前。因此我們需要給這些酒店添加一個(gè)標(biāo)記,這樣在過濾條件中就可以根據(jù)這個(gè)標(biāo)記來判斷,是否要提高算分。
比如,我們給酒店添加一個(gè)字段:isAD,Boolean類型:
- true:是廣告
- false:不是廣告
這樣function_score包含3個(gè)要素就很好確定了:
- 過濾條件:判斷isAD 是否為true
- 算分函數(shù):我們可以用最簡單暴力的weight,固定加權(quán)值
- 加權(quán)方式:可以用默認(rèn)的相乘,大大提高算分
因此,業(yè)務(wù)的實(shí)現(xiàn)步驟包括:
-
給HotelDoc類添加isAD字段,Boolean類型
-
挑選幾個(gè)你喜歡的酒店,給它的文檔數(shù)據(jù)添加isAD字段,值為true
-
修改search方法,添加function score功能,給isAD值為true的酒店增加權(quán)重
11.9.4.2.修改HotelDoc實(shí)體
給cn.itcast.hotel.pojo
包下的HotelDoc類添加isAD字段:
11.9.4.3.添加廣告標(biāo)記
接下來,我們挑幾個(gè)酒店,添加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
}
}
11.9.4.4.添加算分函數(shù)查詢
接下來我們就要修改查詢條件了。之前是用的boolean 查詢,現(xiàn)在要改成function_socre查詢。
function_score查詢結(jié)構(gòu)如下:
對應(yīng)的JavaAPI如下:
我們可以將之前寫的boolean查詢作為原始查詢條件放到query中,接下來就是添加過濾條件、算分函數(shù)、加權(quán)模式了。所以原來的代碼依然可以沿用。文章來源:http://www.zghlxwxcb.cn/news/detail-449658.html
修改cn.itcast.hotel.service.impl
包下的HotelService
類中的buildBasicQuery
方法,添加算分函數(shù)查詢:文章來源地址http://www.zghlxwxcb.cn/news/detail-449658.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()));
}
// 價(jià)格
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[]{
// 其中的一個(gè)function score 元素
new FunctionScoreQueryBuilder.FilterFunctionBuilder(
// 過濾條件
QueryBuilders.termQuery("isAD", true),
// 算分函數(shù)
ScoreFunctionBuilders.weightFactorFunction(10)
)
});
request.source().query(functionScoreQuery);
}
到了這里,關(guān)于【黑馬旅游案例記錄(結(jié)合ES)】的文章就介紹完了。如果您還想了解更多內(nèi)容,請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!