springboot+elasticsearch，入门最详细的项目

package com.example.controller; import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; import org.elasticsearch.action.bulk.BulkRequestBuilder; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchType; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.*; @RestController @RequestMapping("/es") public class ElasticsearchController { @Autowired private TransportClient client; protected String index="movies"; protected String indexType="movie"; // 获取单条记录 @RequestMapping("/get") public GetResponse hello() { GetResponse response = client.prepareGet(index, indexType, "2").get(); return response; } // 插入数据 @RequestMapping("/save") public String save() { Map map = new HashMap<String, Object>(); map.put("id", "2"); map.put("name", "hehe"); map.put("age", 18); IndexResponse response = client.prepareIndex("movies", "movie", map.get("id").toString()) .setSource(map).execute().actionGet(); return response.getId(); } // 获取单条记录 @RequestMapping("/del") public String del() { DeleteIndexResponse deleteIndexResponse = client.admin().indices().prepareDelete("test").execute().actionGet(); System.out.println("是否删除成功:"+deleteIndexResponse.isAcknowledged()); return "成功"; } @RequestMapping("/addAll") public String addAll() throws IOException{ BulkRequestBuilder bulkRequest = client.prepareBulk(); Date time = new Date(); index="schools"; indexType="getSchools"; // either use client#prepare, or use Requests# to directly build index/delete requests for(int i=0;i<10000;i++){ bulkRequest.add(client.prepareIndex(index, indexType, i+"") .setSource(XContentFactory.jsonBuilder() .startObject() .field("id",i+"") .field("author","EGDRE"+i) .field("title","EGB"+i) .field("content","这是EGB"+i+""+"有关的书籍") .field("price","40"+i) .field("age","40") .field("view","300") .field("tag","e,c"+i) .field("date",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(time)) .endObject() ) ); } BulkResponse bulkResponse = bulkRequest.get(); if (bulkResponse.hasFailures()) { // process failures by iterating through each bulk response item System.out.println(bulkResponse.getTook()); } return "成功"; } // 查询搜索 @RequestMapping("/search") public List<String> search() { SearchResponse response = client.prepareSearch("movies") .setTypes("movie") .setSearchType(SearchType.DFS_QUERY_THEN_FETCH) //.setQuery(QueryBuilders.termQuery("tag", "a,b,c14")) // Query .setPostFilter(QueryBuilders.rangeQuery("age").from(0).to(188)) // Filter .setFrom(0).setSize(60).setExplain(true) .get(); // SearchResponse response =client.prepareSearch().execute().actionGet(); SearchHits searchHits = response.getHits(); System.err.println("总数：" + searchHits.getTotalHits()); List<String> data = new ArrayList<String>(); SearchHit[] hits = searchHits.getHits(); for (SearchHit hit : hits) { String json = hit.getSourceAsString(); data.add(json); System.err.println(json); } return data; } }