spring mvc 集成elasticSearch 5.5.0版本

package com.atguigu.springmvc.service.Impl; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; import org.elasticsearch.action.bulk.BulkItemResponse; import org.elasticsearch.action.bulk.BulkRequestBuilder; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchType; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.common.text.Text; import org.elasticsearch.common.xcontent.XContentBuilder; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; 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; import com.atguigu.springmvc.entities.Client; import com.atguigu.springmvc.entities.Student; import com.atguigu.springmvc.service.ElSerarchService; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; @Service public class ElSerarchServiceImpl implements ElSerarchService { @Autowired private Client client; @Override public String get(String index, String type, String id) { GetResponse getResponse=client.getClient().prepareGet(index,type,id).get(); return getResponse.getSourceAsString(); } @Override public String update(String name, String value, String id) { long result = 0; try { XContentBuilder source=XContentFactory.jsonBuilder().startObject().field(name,value) .endObject(); UpdateResponse updateResponse=client.getClient().prepareUpdate("test", "emp",id).setDoc(source).get(); result=updateResponse.getVersion(); } catch (IOException e) { e.printStackTrace(); } return Long.toString(result); } @Override public String add(String index, String type, String id,Map<String,Object> map) { IndexResponse response=client.getClient().prepareIndex(index,type).setSource(map).get(); long result=response.getVersion(); return Long.toString(result); } @Override public String addBean(String index, String type, String id, Student stu) { ObjectMapper mapper=new ObjectMapper(); IndexResponse indexResponse = null; try { indexResponse = client.getClient().prepareIndex(index, type,id) .setSource(mapper.writeValueAsString(stu)).get(); } catch (JsonProcessingException e) { e.printStackTrace(); } return Long.toString(indexResponse.getVersion()); } @Override public String deleteById(String index,String type,String id) { DeleteResponse deleteResponse=client.getClient().prepareDelete(index,type,id).get(); return deleteResponse.getVersion()+""; } @Override public String deleteAll(String index) { client.getClient().prepareDelete().setIndex(index); return null; } @Override public String DeleteeIndex(String index, String type) { DeleteIndexResponse deleteIndex= client.getClient().admin().indices().prepareDelete(index,type).get(); return deleteIndex.toString(); } @Override public String bluk(String index,String type,String id) throws IOException { //1:生成bulk BulkRequestBuilder bulk = client.getClient().prepareBulk(); //2:新增 IndexRequest add = new IndexRequest(index, type, "10"); add.source(XContentFactory.jsonBuilder() .startObject() .field("name", "Henrry").field("age", 30) .endObject()); //3:删除 DeleteRequest del = new DeleteRequest(index, type, "AV1VF_IKFfAXVe6cyga3"); //4:修改 XContentBuilder source = XContentFactory.jsonBuilder().startObject().field("name", "jack_1").endObject(); UpdateRequest update = new UpdateRequest(index, type, "10"); update.doc(source); /* bulk.add(del); */ bulk.add(add); bulk.add(update); //5:执行批处理 BulkResponse bulkResponse = bulk.get(); if(bulkResponse.hasFailures()) { BulkItemResponse[] items = bulkResponse.getItems(); for(BulkItemResponse item : items) { System.out.println(item.getFailureMessage()); } } else { System.out.println("全部执行成功！"); } return id; } @Override public List<String> search(String index, String type) { SearchResponse searchResponse=client.getClient().prepareSearch(index).setTypes(type) //.setQuery(QueryBuilders.matchAllQuery()) //.setQuery(QueryBuilders.matchQuery("name","lijixiang")) .setQuery(QueryBuilders.multiMatchQuery("lijxiang","name")) .setSearchType(SearchType.QUERY_THEN_FETCH) .setFrom(0).setSize(10)//分页 .addSort("age",SortOrder.DESC).get(); SearchHits hits=searchResponse.getHits(); long total=hits.getTotalHits(); System.out.println(total); SearchHit[] searchHits=hits.hits(); List<String> list=new ArrayList<String>(); for(SearchHit s:searchHits){ list.add(s.getSourceAsString()); } return list; } @Override public List<String> searchHight(String index, String type) throws Exception { QueryBuilder matchQuery = QueryBuilders.matchQuery("name", "lijixiang"); HighlightBuilder hibuilder=new HighlightBuilder(); hibuilder.preTags("<h2>"); hibuilder.postTags("</h2>"); hibuilder.field("name"); List<String> list=new ArrayList<String>(); SearchResponse response=client.getClient().prepareSearch(index).setTypes(type) .setQuery(matchQuery).highlighter(hibuilder).execute().get(); SearchHits searchHits=response.getHits(); for(SearchHit hit:searchHits){ Text [] text=hit.getHighlightFields().get("name").getFragments(); for(Text str:text){ list.add(str.toString()); } } return list; } }