java连接elasticsearch将搜索结果高亮显示并分页。

package es.service; import java.util.ArrayList; import java.util.List; import org.elasticsearch.action.search.SearchRequestBuilder; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchType; import org.elasticsearch.client.Client; import org.elasticsearch.index.query.MatchPhrasePrefixQueryBuilder; import org.elasticsearch.index.query.MatchPhraseQueryBuilder; import org.elasticsearch.index.query.MultiMatchQueryBuilder; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.TermsQueryBuilder; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder; import org.elasticsearch.search.sort.SortOrder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @Service public class EsService { @Autowired private Client client; /** * 全文检索 模糊查询所有索引的索引字段 * @param query * @return */ public SearchResponse multiBatch(String query) { MultiMatchQueryBuilder queryBuilder = new MultiMatchQueryBuilder(query,"name","address"); // 高亮 // HighlightBuilder highlightBuilder = new HighlightBuilder().field("name")//字段名 // .fragmentSize(200).highlightFilter(true); HighlightBuilder highlightBuilder=new HighlightBuilder(); highlightBuilder.preTags("<h2>"); highlightBuilder.postTags("</h2>"); highlightBuilder.field("name"); SearchRequestBuilder requestBuilder = client.prepareSearch("codetype_index_ik","position_index")//"codetype_index_ik","position_index" "people","companyindex","oracleall_index"可以指定多个index 可以不传查询所有索引 .setTypes("position_type","code_type_ik") //也可以指定多个type // .addSort("id", SortOrder.ASC)//按照id升序排列 // .setQuery(QueryBuilders.matchQuery("name", query)) .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)// // .setExplain(true)//匹配度高的排在前面 .setQuery(queryBuilder) .highlighter(highlightBuilder) .setFrom(0).setMinScore(1).setSize(30); //设置只保留score>1的结果，并且最多保留100个 //.setFrom(0).setSize(100)//只设置保留个数 // .highlighter(highlightBuilder); SearchResponse searchResponse = requestBuilder.get(); return searchResponse; } /** * matchPhraseQuery 搜索的内容要完全匹配 搜索“saa” 搜索内容中必须含有“saa”这个内容 */ public SearchResponse matchPhraseQuery(String query) { MatchPhrasePrefixQueryBuilder match = new MatchPhrasePrefixQueryBuilder("address",query); SearchRequestBuilder requestBuilder = client.prepareSearch() .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)// .setExplain(true)//匹配度高的排在前面 .setQuery(match) // .setQuery(QueryBuilders.termQuery("name", query)) .setFrom(0).setMinScore(1).setSize(30); //设置只保留score>1的结果，并且最多保留100个 SearchResponse searchResponse = requestBuilder.get(); return searchResponse; } /** * //terms查询 */ public List<String> terms(String query) { List<String> list = new ArrayList<>(); TermsQueryBuilder builder = QueryBuilders.termsQuery("name","address",query); SearchResponse response = client.prepareSearch() .setQuery(builder) .setSize(2) .get(); SearchHits hits = response.getHits(); for (SearchHit hit : hits){ list.add(hit.getSourceAsString()); } return list; } //对所有字段分词查询（queryStringQuery） public SearchResponse query(String query) { // 1 条件查询 SearchRequestBuilder response = client.prepareSearch() .setTypes() .setQuery(QueryBuilders.queryStringQuery(query)) .setFrom(0) .setMinScore(1) .setSize(30); SearchResponse searchResponse = response.get(); // 2 打印查询结果 SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象 System.out.println("查询结果有：" + hits.getTotalHits() + "条"); return searchResponse; } //通配符查询（wildcardQuery）指定一个字段“content”不能多字段查询 public SearchResponse wildcardQuery(String query) { // 1 条件查询 SearchRequestBuilder response = client.prepareSearch() .setTypes() .setQuery(QueryBuilders.wildcardQuery("content", query)) .setFrom(0) .setMinScore(1) .setSize(30); SearchResponse searchResponse = response.get(); // 2 打印查询结果 SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象 System.out.println("查询结果有：" + hits.getTotalHits() + "条"); return searchResponse; } public void BoolSearch(){ //多条件设置 MatchPhraseQueryBuilder mpq1 = QueryBuilders .matchPhraseQuery("pointid","W3.UNIT1.10LBG01CP301"); MatchPhraseQueryBuilder mpq2 = QueryBuilders .matchPhraseQuery("inputtime","2016-07-21 00:00:01"); QueryBuilder qb2 = QueryBuilders.boolQuery() .must(mpq1) .must(mpq2); SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); sourceBuilder.query(qb2); //System.out.println(sourceBuilder.toString()); //查询建立 SearchRequestBuilder responsebuilder = client.prepareSearch("pointdata") .setTypes("pointdata"); SearchResponse myresponse=responsebuilder .setQuery(qb2) .setFrom(0).setSize(50) .addSort("inputtime", SortOrder.ASC) //.addSort("inputtime", SortOrder.DESC) .setExplain(true).execute().actionGet(); SearchHits hits = myresponse.getHits(); for(int i = 0; i < hits.getHits().length; i++) { System.out.println(hits.getHits()[i].getSourceAsString()); } } public void testSearch() { String index="index_log_daily"; String type="uq_log"; String uquestion = "139"; String province = "江苏"; SearchResponse searchResponse = client.prepareSearch(index) .setTypes(type) .setQuery(QueryBuilders.matchAllQuery()) //查询所有 .setQuery(QueryBuilders.boolQuery() .must(QueryBuilders.matchQuery("uquestion", uquestion))//查询uquestion为139的 .must(QueryBuilders.matchQuery("province", province)))//查询省份为江苏的 //.setQuery(QueryBuilders.matchQuery("uquestion", "12599").operator(Operator.AND)) //根据tom分词查询name,默认or //.setQuery(QueryBuilders.matchQuery("province", "江苏").operator(Operator.AND)) //根据tom分词查询name,默认or //.setQuery(QueryBuilders.multiMatchQuery("tom", "name", "age")) //指定查询的字段 //.setQuery(QueryBuilders.queryString("name:to* AND age:[0 TO 19]")) //根据条件查询,支持通配符大于等于0小于等于19 //.setQuery(QueryBuilders.termQuery("name", "tom"))//查询时不分词 .setSearchType(SearchType.QUERY_THEN_FETCH) .setFrom(0).setSize(10)//分页 //.addSort("age", SortOrder.DESC)//排序 .get(); S