引库操作1.1.1

dependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactId/dependency因为SpringBoot默认的ES版本是7.17.10所以我们需要覆盖默认的ES版本

propertiesmaven.compiler.source11/maven.compiler.sourcemaven.compiler.target11/maven.compiler.targetelasticsearch.version7.12.1/elasticsearch.version

Bean

RestHighLevelClient(RestClient.builder(HttpHost.create(http://192.168.164.128:9200)));

结合数据表结构创建索引库结构

1.创建Request对象CreateIndexRequest

request

2.准备请求参数request.source(MAPPING_TEMPLATE,

3.发送请求client.indices().create(request,

}//

1.创建Request对象DeleteIndexRequest

request

2.发送请求client.indices().delete(request,

}1.1.3

client.indices().exists(request,

索引库已经存在

索引库结构与数据库结构还存在一些差异因此我们要定义一个索引库结构对应的实体

package

com.hmall.item.domain.dto;import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

ItemDTO{ApiModelProperty(商品id)private

String

id;ApiModelProperty(商品名称)private

String

name;ApiModelProperty(价格分)private

Integer

price;ApiModelProperty(库存数量)private

Integer

stock;ApiModelProperty(商品图片)private

String

image;ApiModelProperty(类目名称)private

String

category;ApiModelProperty(品牌名称)private

String

brand;ApiModelProperty(销量)private

Integer

sold;ApiModelProperty(评论数)private

Integer

commentCount;ApiModelProperty(是否是推广广告true/false)private

Boolean

isAD;ApiModelProperty(更新时间)private

LocalDateTime

itemService.getById(100002644680L);//

2.转换为文档类型ItemDTO

IndexRequest(items).id(itemDTO.getId());//

}1.2.2

GetRequest(items).id(100002644680);//

2.发送请求GetResponse

response.getSourceAsString();ItemDTO

itemDTO

ItemDTO.class);System.out.println(itemDTO

itemDTO);

1.准备Request两个参数第一个是索引库名第二个是文档idDeleteRequest

request

2.2.创建新增文档的Request对象request.add(new

IndexRequest(hotel).id(hotelDoc.getId().toString()).source(JSONUtil.toJsonStr(hotelDoc),

}1.3

组织请求参数request.source().query(QueryBuilders.matchQuery(all,

如家));//

RequestOptions.DEFAULT);handleResponse(response);

}1.3.2

2.1.准备BooleanQueryBoolQueryBuilder

boolQuery

2.2.添加termboolQuery.must(QueryBuilders.termQuery(city,

杭州));//

2.3.添加rangeboolQuery.filter(QueryBuilders.rangeQuery(price).lte(250));request.source().query(boolQuery);//

3.发送请求SearchResponse

4.解析响应handleResponse(response);

}1.3.3

2.1.搜索条件参数//request.source().query(QueryBuilders.matchAllQuery());request.source().query(QueryBuilders.matchQuery(all,

如家));//

2.2.排序参数request.source().sort(price,

SortOrder.ASC);//

2.3.分页参数request.source().from((pageNo

3.发送请求SearchResponse

4.解析响应handleResponse(response);

}1.3.4

2.1.搜索条件参数request.source().query(QueryBuilders.matchQuery(all,

如家));//

);request.source().highlighter(new

HighlightBuilder().field(name).field(brand).requireFieldMatch(false));//

2.3.排序参数request.source().sort(price,

SortOrder.ASC);//

2.4.分页参数request.source().from((pageNo

3.发送请求SearchResponse

4.解析响应handleResponse(response);}1.3.5

/***

params.getSize();request.source().from((pageNo

发送请求SearchResponse

1.构建BooleanQueryBoolQueryBuilder

boolQuery

{boolQuery.must(QueryBuilders.matchAllQuery());}

else

{boolQuery.must(QueryBuilders.matchQuery(all,

key));}//

params.getCity();if(StrUtil.isNotEmpty(city)){boolQuery.filter(QueryBuilders.termQuery(city,

city));}//

params.getBrand();if(StrUtil.isNotEmpty(brand)){boolQuery.filter(QueryBuilders.termQuery(brand,

brand));}//

params.getStarName();if(StrUtil.isNotEmpty(starName)){boolQuery.filter(QueryBuilders.termQuery(starName,

starName));}//

params.getMaxPrice();if(minPrice

null

null){boolQuery.filter(QueryBuilders.rangeQuery(price).gte(minPrice).lte(maxPrice));}request.source().query(boolQuery);//

2.算分控制//

QueryBuilders.functionScoreQuery(//

boolQuery,//

FunctionScoreQueryBuilder.FilterFunctionBuilder[]{//

score

FunctionScoreQueryBuilder.FilterFunctionBuilder(//

true),//

ScoreFunctionBuilders.weightFactorFunction(10)//

)//

request.source().query(functionScoreQuery);

}1.3.6

searchHits.getTotalHits().value;log.info(总条数{},

total);//

searchHits.getHits();for(SearchHit

hit

hit.getHighlightFields();if(CollUtil.isNotEmpty(highlightFields)){//

5.1

highlightFields.get(name);HighlightField

field2

highlightFields.get(brand);if(field1

null

field1.getFragments()[0].string();String

brand

field2.getFragments()[0].string();hotelDoc.setName(name);hotelDoc.setBrand(brand);}}log.info(HotelDoc{},

hotelDoc);}

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId

192.168.164.128port:

TopicExchange(MqConstants.HOTEL_EXCHANGE,

true,

Queue(MqConstants.HOTEL_INSERT_QUEUE,

true);}Beanpublic

Queue(MqConstants.HOTEL_DELETE_QUEUE,

true);}Beanpublic

BindingBuilder.bind(insertQueue()).to(topicExchange()).with(MqConstants.HOTEL_INSERT_KEY)}Beanpublic

Binding

BindingBuilder.bind(deleteQueue()).to(topicExchange()).with(MqConstants.HOTEL_DELETE_KEY)}

}/***

MqConstants.HOTEL_INSERT_QUEUE)public

void

id){hotelService.insertById(id);}/***

param

MqConstants.HOTEL_DELETE_QUEUE)public

void

id){hotelService.deleteById(id);}/***

param

MqConstants.HOTEL_INSERT_QUEUE,

durable

id){hotelService.insertById(id);

}/***

MqConstants.HOTEL_DELETE_QUEUE,

durable

id){hotelService.deleteById(id);

}1.4.4

IndexRequest(hotel).id(hotel.getId().toString());//

2.准备Json文档request.source(JSONUtil.toJsonStr(hotelDoc),

catch