ES操作参考

@Autowired
	private RestHighLevelClient restHighLevelClient;

	@Override
	public ResponseResult search(UserSearchDto userSearchDto) throws IOException {
		//1 检查参数
		if (userSearchDto==null|| StringUtils.isBlank(userSearchDto.getSearchWords())){
			return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
		}
		//2 设置查询条件
		SearchRequest searchRequest = new SearchRequest("app_info_article");
		SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
		//布尔查询
		BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
		//关键字的分词之后查询
		QueryStringQueryBuilder queryStringQueryBuilder = QueryBuilders.queryStringQuery(userSearchDto.getSearchWords())
				.field("title").field("content").defaultOperator(Operator.OR);
		boolQueryBuilder.must(queryStringQueryBuilder);
		//查询小于mindate的数据
		RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("publishTime").lt(userSearchDto.getMinBehotTime().getTime());
		boolQueryBuilder.filter(rangeQueryBuilder);
		//分页查询
		searchSourceBuilder.from(0);
		searchSourceBuilder.size(userSearchDto.getPageSize());
		//按照发布时间倒序查询
		searchSourceBuilder.sort("publishTime", SortOrder.DESC);
		//设置高亮域 title
		HighlightBuilder highlightBuilder = new HighlightBuilder();
		highlightBuilder.field("title");
		highlightBuilder.preTags("<font style='color: red; font-size: inherit;'>");
		highlightBuilder.postTags("</font>");
		searchSourceBuilder.highlighter(highlightBuilder);

		searchSourceBuilder.query(boolQueryBuilder);
		searchRequest.source(searchSourceBuilder);
		SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
		//3 结果封装返回
		ArrayList<Map> list = new ArrayList<>();
		SearchHit[] hits = searchResponse.getHits().getHits();
		for (SearchHit hit : hits) {
			String json = hit.getSourceAsString();
			Map map = JSON.parseObject(json, Map.class);
			//处理高亮
			if (hit.getHighlightFields()!=null&&hit.getHighlightFields().size()>0){
				Text[] titles = hit.getHighlightFields().get("title").getFragments();
				String title = StringUtils.join(titles);
				//高亮标题
				map.put("h_title",title);
			}else {
				//原始标题
				map.put("h_title",map.get("title"));
			}
			list.add(map);
		}
		return ResponseResult.okResult(list);