Springboot集成RESTful风格的搜索引擎Elasticsearch+京东搜索实战代码.zip

package com.qi; import com.alibaba.fastjson.JSON; import com.qi.pojo.User; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.bulk.BulkRequest; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetRequest; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.support.master.AcknowledgedResponse; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.client.indices.CreateIndexRequest; import org.elasticsearch.client.indices.CreateIndexResponse; import org.elasticsearch.client.indices.GetIndexRequest; import org.elasticsearch.common.xcontent.XContentType; import org.elasticsearch.core.TimeValue; import org.elasticsearch.index.query.MatchAllQueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.TermQueryBuilder; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.search.fetch.subphase.FetchSourceContext; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.test.context.SpringBootTest; import java.io.IOException; import java.util.ArrayList; import java.util.concurrent.TimeUnit; /** * 讲解es7.6.x 高级客户端测试API */ @SpringBootTest class EsApiApplicationTests { //面向对象来进行操作 @Autowired @Qualifier("restHighLevelClient") private RestHighLevelClient client; //测试索引的创建 @Test void testCreatedIndex() throws IOException { //1.创建索引的请求 CreateIndexRequest request = new CreateIndexRequest("qi_index"); //2.客户端执行请求IndicesClient,获得请求后的响应createIndexResponse CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT); System.out.println(createIndexResponse); } //测试获取索引 @Test void testExistIndex() throws IOException { GetIndexRequest request = new GetIndexRequest("qi_index"); boolean exists = client.indices().exists(request, RequestOptions.DEFAULT); System.out.println(exists); } //测试删除索引 @Test void testDeleteIndex() throws IOException { DeleteIndexRequest request = new DeleteIndexRequest("qi_index"); AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT); System.out.println(delete.isAcknowledged()); } //测试添加文档 @Test void testAddDocument() throws IOException { //创建对象 User user = new User("张三", 3); //创建请求 IndexRequest request = new IndexRequest("qi_index"); //规则 put /qi_index/_doc/1 request.id("1"); request.timeout(TimeValue.timeValueSeconds(1)); request.timeout("1s"); //将我们的数据放入请求 json request.source(JSON.toJSONString(user), XContentType.JSON); //客户端发送请求,获取响应的结果 IndexResponse indexRequest = client.index(request, RequestOptions.DEFAULT); System.out.println(indexRequest.toString()); System.out.println(indexRequest.status()); //对应我们命令返回的状态 } //获取文档，判断是否存在 get /qi_index/_doc_1 @Test void testIsExists() throws IOException { GetRequest getRequest = new GetRequest("qi_index", "1"); //不获取返回的_source的上下文了 getRequest.fetchSourceContext(new FetchSourceContext(false)); getRequest.storedFields("_none_"); boolean exists = client.exists(getRequest, RequestOptions.DEFAULT); System.out.println(exists); } //获取文档的信息 @Test void testGetDocument() throws IOException { GetRequest getRequest = new GetRequest("qi_index", "1"); GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT); System.out.println(getResponse.getSourceAsString()); //打印文档的内容 System.out.println(getResponse); //返回的全部内容和命令式一样 } //更新文档的信息 @Test void testUpdateRequest() throws IOException { UpdateRequest updateRequest = new UpdateRequest("qi_index","1"); updateRequest.timeout("1s"); User user = new User("李四", 22); updateRequest.doc(JSON.toJSONString(user),XContentType.JSON); UpdateResponse update = client.update(updateRequest, RequestOptions.DEFAULT); System.out.println(update.status()); } //删除文档记录 @Test void testDeleteRequest() throws IOException { DeleteRequest deleteRequest = new DeleteRequest("qi_index","1"); deleteRequest.timeout("1s"); DeleteResponse delete = client.delete(deleteRequest, RequestOptions.DEFAULT); System.out.println(delete.status()); } //特殊的，真的项目一般都会批量插入项目 @Test void testBulkRequest() throws IOException { BulkRequest bulkRequest = new BulkRequest(); bulkRequest.timeout("10s"); ArrayList<User> userList = new ArrayList<>(); userList.add(new User("zhangsan0",3)); userList.add(new User("zhangsan1",3)); userList.add(new User("zhangsan2",3)); userList.add(new User("lisi0",3)); userList.add(new User("lisi1",3)); userList.add(new User("lisi2",3)); for (int i = 0; i < userList.size(); i++) { //批量更新和批量删除，就在这里修改对应的请求就可以了 bulkRequest.add( new IndexRequest("qi_index") .id(""+(i+1)) .source(JSON.toJSONString(userList.get(i)),XContentType.JSON)); BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT); System.out.println(bulk.hasFailures());//是否失败 false } } //查询一下 //searchRequest 搜索请求 //SearchSourceBuilder 条件构造 //HighlightBuilder 构建高亮 //TermQueryBuilder 构建精确查询 //MatchAllQueryBuilder //xxx QueryBuilder 对应我们刚才看到的所有命令 @Test void testSearch() throws IOException { SearchRequest searchRequest = new SearchRequest("qi_index"); //构建搜索条件 SearchSourceBuilder searchBuilder = new SearchSourceBuilder(); //查询条件，我们可以使用QueryBuilders工具来实现 //QueryBuilders.termQuery 精确 TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "zhangsan1"); //QueryBuilders.matchAllQuery 匹配所有 //MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery(); searchBuilder.query(termQueryBuilder); searchBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS)); searchRequest.source(searchBuilder); SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT); System.out.println(JSON.toJSONString(searchResponse.getHits())); System.out.println("================================"); for (SearchHit hit : searchResponse.getHits().getHits()) { System.out.println(hit.getSourceAsMap()); } } }