原生依赖es-snapshotselasticsearch snapshot repohttps://snapshots.elastic.co/maven/实际我们导入的依赖org.springframework.bootspring-boot-starter-data-elasticsearch注意依赖的版本必须要和自己的本地的es版本一致所以需要自定义版本依赖初始化RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http"),new HttpHost("localhost", 9201, "http"))); 用完记得关client.close(); @Beanpublic RestHighLevelClient restHighLevelClient(){RestHighLevelClient client =new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http"),new HttpHost("localhost", 9201, "http"))); return client; }

@Testpublic void CreateIndex() throws IOException {//创建索引CreateIndexRequest requst = new CreateIndexRequest("shuaikb_index"); //执行请求 获得响应CreateIndexResponse createIndexResponse =client.indices().create(requst, RequestOptions.DEFAULT); System.out.println(createIndexResponse); }@Testvoid testExisIndex() throws IOException {//判断存在GetIndexRequest request =new GetIndexRequest("shuaikb_index"); boolean exists = client.indices().exists(request, RequestOptions.DEFAULT); System.out.println(exists); }@Testvoid testDeleteIndex() throws IOException {//删除索引DeleteIndexRequest request =new DeleteIndexRequest("shuaikb_index"); AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT); System.out.println(delete); }

@Testvoid testAddDocument() throws IOException {//添加文档Dog dog = new Dog(); dog.setName("多帅哦"); dog.setAge(12); IndexRequest requst = new IndexRequest("shuaikb_index"); //规则 PUT /shuaikb_index/_doc/1requst.id("1"); requst.timeout(TimeValue.timeValueSeconds(1)); requst.timeout("1s"); //将我们的数据放入请求 jsonrequst.source(JSON.toJSONString(dog), XContentType.JSON); //客户端发送请求IndexResponse indexResponse = client.index(requst, RequestOptions.DEFAULT); System.out.println(indexResponse.toString()); System.out.println(indexResponse.status()); }@Testvoid testExisDocument() throws IOException {//判断文档存在GetRequest getRequest = new GetRequest("shuaikb_index","1"); //不获取返回的_source的上下文getRequest.fetchSourceContext(new FetchSourceContext(false)); getRequest.storedFields("_noe_"); boolean exists = client.exists(getRequest, RequestOptions.DEFAULT); System.out.println(exists); }@Testvoid testGetDocument() throws IOException {//获取文档信息GetRequest getRequest = new GetRequest("shuaikb_index","1"); GetResponse documentFields = client.get(getRequest, RequestOptions.DEFAULT); System.out.println(documentFields.getSourceAsString()); System.out.println(documentFields); }@Testvoid testUpdateDocument() throws IOException {//更新文档信息UpdateRequest updateRequest = new UpdateRequest("shuaikb_index","1"); updateRequest.timeout("1s"); Dog dog = new Dog("你怎么说",20); updateRequest.doc(JSON.toJSONString(dog),XContentType.JSON); client.update(updateRequest,RequestOptions.DEFAULT); }@Testvoid testDeleteDocument() throws IOException {//删除文档信息DeleteRequest deleteRequest = new DeleteRequest("shuaikb_index","1"); deleteRequest.timeout("1s"); DeleteResponse delete = client.delete(deleteRequest, RequestOptions.DEFAULT); System.out.println(delete); }

//大量数据操作@Testvoid testBulkRequest() throws IOException {BulkRequest bulkRequest = new BulkRequest(); bulkRequest.timeout("10s"); ArrayList dogArrayList = new ArrayList(); dogArrayList.add(new Dog("test1",1)); dogArrayList.add(new Dog("test2",1)); dogArrayList.add(new Dog("test3",1)); dogArrayList.add(new Dog("test4",1)); dogArrayList.add(new Dog("shuaikb1",1)); dogArrayList.add(new Dog("shuaikb2",1)); dogArrayList.add(new Dog("shuaikb3",1)); dogArrayList.add(new Dog("shuaikb4",1)); for (int i = 0; i