1.添加文档

使用RestHightLevelClient对象
使用client对象的index方法添加文档
创建IndexRequest对象，其中包含了索引库名称、文档的id、文档的内容

{"id":"1","title":"测试文档1","content":"测试文档中的内容"}

package com.xd.cubemall.es;import org.apache.http.HttpHost;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;public class DocumentManager {private RestHighLevelClient client;@BeforeEachpublic void init() {//创建一个client对象client = new RestHighLevelClient(RestClient.builder(new HttpHost("1.1.1.1",9200),new HttpHost("2.2.2.2",9200),new HttpHost("3.3.3.3",9200)));}@Testpublic void addDocument() throws Exception{String document = "{\"id\":\"1\",\"title\":\"测试文档1\",\"content\":\"测试文档中的内容\"}";//创建IndexRequest对象，其中包含了索引库名称、文档id、文档的内容IndexRequest indexRequest = new IndexRequest(/**"hello1"**/).index("hello1").id("1").source(document, XContentType.JSON);IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);System.out.println(response);}}

2.更新文档

使用client对象的update方法。
需要UpdateRequest参数：
1.更新的索引
2.更新的文档的id
3.更新的文档内容

    @Testpublic void updateDocument() throws Exception {String document = "{\"id\":\"1\",\"title\":\"测试文档2\",\"content\":\"测试文档中的内容2\"}";UpdateRequest request = new UpdateRequest().index("hello1").id("1").doc(document,XContentType.JSON);UpdateResponse response = client.update(request, RequestOptions.DEFAULT);System.out.println(response);}

3.删除文档

使用client的delete方法
需要DeleteRequest对象，需要三个参数
1.操作的索引
2.文档的id

    @Testpublic void deleteDocument() throws Exception {DeleteRequest request = new DeleteRequest("hello1","1");client.delete(request, RequestOptions.DEFAULT);}

4.根据id取文档对象

使用client对象的get方法
需要使用GetRequest对象，两个参数：
1.操作的索引
2.文档的id

    @Testpublic void getDocument() throws Exception {GetRequest request = new GetRequest("hello1","2");GetResponse response = client.get(request, RequestOptions.DEFAULT);System.out.println(response);}

5.批量操作bulk

使用client对象的bulk方法
BulkRequest对象，使用add方法，添加要批量处理的请求。
支持的处理：
IndexRequest
DeleteRequest
UpdateRequest

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;@Testpublic void bulkDocument() throws Exception {String json = "";JSONArray jsonArray = JSONObject.parseArray(json);BulkRequest request = new BulkRequest();jsonArray.stream().forEach(j->{IndexRequest r = new IndexRequest().index("hello1").id(((JSONObject)j).getString("id")).source(((JSONObject) j).toJSONString(),XContentType.JSON);request.add(r);});BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);System.out.println(response);   }