elasticsearch5.5.2实现搜索结果高亮显示和搜索建议

package com.lpl; import org.apache.lucene.util.QueryBuilder; import org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest; import org.elasticsearch.action.delete.DeleteRequestBuilder; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchRequestBuilder; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchType; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.text.Text; import org.elasticsearch.common.xcontent.XContentBuilder; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.index.query.BoolQueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.RangeQueryBuilder; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder; import org.elasticsearch.search.fetch.subphase.highlight.HighlightField; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Map; /** * Created by Lenovo on 2017/9/17. */ @RestController public class BookController { @Autowired private TransportClient client; /** * 根据id查询book * @param id * @return */ @GetMapping("/shop/product") @ResponseBody public ResponseEntity getBookById(@RequestParam(value = "id",defaultValue = "") String id){ if(id.isEmpty()){ return new ResponseEntity(HttpStatus.NOT_FOUND); } GetResponse result = this.client.prepareGet("shop","product",id). get(); if(!result.isExists()){ return new ResponseEntity(HttpStatus.NOT_FOUND); } return new ResponseEntity(result.getSource(), HttpStatus.OK); } /** * 增加一个book * @param name * @param author * @param price * @param country * @return */ @PostMapping("shop/addBook") @ResponseBody public ResponseEntity addBook( @RequestParam("name") String name, @RequestParam("author") String author, @RequestParam("price") String price, @RequestParam("country") String country ) { try { //构造数据 XContentBuilder content = XContentFactory.jsonBuilder() .startObject() .field("name",name) .field("author",author) .field("price",price) .field("country",country) .endObject(); IndexResponse response = this.client.prepareIndex("shop","product") .setSource(content) .get(); return new ResponseEntity(response.getId(),HttpStatus.OK); } catch (IOException e) { e.printStackTrace(); return new ResponseEntity(HttpStatus.INTERNAL_SERVER_ERROR); } } /** * 删除book * @param id * @return */ @DeleteMapping("shop/delProduct") @ResponseBody public ResponseEntity delBook(@RequestParam(name="id") String id){ DeleteResponse result = this.client.prepareDelete("shop", "product", id) .get(); return new ResponseEntity(result.getResult(),HttpStatus.OK); } /** * 修改book 根据Id * @param id * @param name * @param author * @return */ @PutMapping("shop/updateProduct") @ResponseBody public ResponseEntity updateBook( @RequestParam(name="id")String id, @RequestParam(name="name",required = false) String name, @RequestParam(name="author",required = false) String author ){ try { XContentBuilder builder = XContentFactory.jsonBuilder() .startObject(); if(name!=null){ builder.field("name",name); } if(author!=null){ builder.field("author",author); } builder.endObject(); UpdateResponse updateResponse = this.client.prepareUpdate("shop", "product", id) .setDoc(builder) .get(); return new ResponseEntity(updateResponse.getResult().toString(),HttpStatus.OK); } catch (IOException e) { e.printStackTrace(); return new ResponseEntity(HttpStatus.INTERNAL_SERVER_ERROR); } } // @RequestMapping("testCreateIndex") // public void testCreateIndex(){ // //创建映射 // try { // //配置mapping // XContentBuilder mapping = XContentFactory.jsonBuilder() // .startObject() // .startObject("properties") // // .startObject("m_id").field("type","keyword").endObject() // .startObject("id").field("type", "keyword").endObject() // .startObject("catid").field("type", "keyword").endObject() // .startObject("classify").field("type", "integer").endObject() // .startObject("title").field("type", "text").field("analyzer", "ik_max_word").endObject() // .startObject("author").field("type", "text").field("analyzer", "ik_max_word").endObject() // .startObject("published").field("type", "date").field("format", "yyyy-MM-dd HH:mm:ss").endObject() // .startObject("article").field("type", "text").endObject() // .endObject() // .endObject(); // // // IndexResponse response = this.client.prepareIndex("lpl","lplp") // .setSource(mapping) // .get(); // //创建索引 // System.out.print(response.status()); // } catch (IOException e) { // e.printStackTrace(); // } // } @PostMapping("shop/product") @ResponseBody public ResponseEntity query( @RequestParam(name = "author",required = false) String author, @RequestParam(name ="name",required = false)String name, @RequestParam(name="gtPrice",defaultValue = "0") int gtPrice, @RequestParam(name="ltPrice",required = false) Integer ltPrice ){ BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); if(author != null){ boolQuery.must(QueryBuilders.matchQuery("author",author)); } if(name != null){ boolQuery.must(QueryBuilders.matchQuery("name",name)); } RangeQueryBuilder rangQuery = QueryBuilders.rangeQuery("price") .from(gtPrice); if(ltPrice!=null && ltPrice>0){ rangQuery.to(ltPrice); } boolQuery.filter(rangQuery); SearchRequestBuilder buider = this.client.prepareSearch("shop") .setTypes("product") .setSearchType(SearchType.DFS_QUERY_THEN_FETCH) .setQuery(boolQuery) .setFrom(0) .setSize(10); System.out.print(buider); SearchResponse response = buider.get(); List<Map<String,Object>> result = new ArrayList<>(); for(SearchHit hit:response.g