Java使用RestClient连接ElasticSearch

public class demo {
    void demo() {
        /*全局索引名称*/
        String indexName = "posts";
        IndexRequest indexRequest = new IndexRequest(indexName);
        /*载入资源*/
        String jsonString = "{\"user\":\"maxzhao\",\"addtime\":\"2013-01-30\",\"message\":\"add data Elasticsearch\"}";
        indexRequest.source(jsonString, XContentType.JSON);
        /**/
        indexRequest.routing("routing");
        /*超时时间*/
        indexRequest.timeout(TimeValue.timeValueSeconds(60));
        /*超时时间*/
        indexRequest.timeout("1m");
        /*刷新策略*/
        indexRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
        /*刷新策略：wait_for、true、false*/
        indexRequest.setRefreshPolicy("wait_for");
        /*文档主键*/
        indexRequest.id();
        /*版本号*/
        indexRequest.version(2);
        /*校验类型*/
        indexRequest.versionType(VersionType.EXTERNAL);
        /*操作类型，这里使用 create 必须要设置文档ID*/
        indexRequest.opType(DocWriteRequest.OpType.CREATE);
        /*操作类型：create or index (default)*/
        indexRequest.opType("create");
        /*索引文档之前执行的管道名称*/
        indexRequest.setPipeline("pipeline");
        /*即将废除：indexRequest.type("_doc");*/
        /*获取响应结果*/
        IndexResponse indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
    }
}

public class demo {
    /**
     * 建立索引
     */
    public void IndexRequest() {
        /*方式一：*/
        String indexName = "posts";
        IndexRequest indexRequest = new IndexRequest(indexName);
        String jsonString = "{" +
                "\"user\":\"maxzhao\"," +
                "\"message\":\"add data Elasticsearch\"" +
                "}";
        indexRequest.source(jsonString, XContentType.JSON);
        /*方式二：*/
        Map<String, Object> jsonMap = new HashMap<>();
        jsonMap.put("user", "maxzhao");
        jsonMap.put("addtime", new Date());
        jsonMap.put("message", "add data Elasticsearch");
        indexRequest = new IndexRequest(indexName)
                .source(jsonMap);
        /*方式三：*/
        XContentBuilder builder = null;
        try {
            builder = XContentFactory.jsonBuilder();
            builder.startObject();
            {
                builder.field("user", "maxzhao");
                builder.timeField("addtime", new Date());
                builder.field("message", "add data Elasticsearch");
            }
            builder.endObject();
            indexRequest = new IndexRequest(indexName)
                    .source(builder);
        } catch (IOException e) {

        }
        /*方式四：*/
        indexRequest = new IndexRequest(indexName)
                .source("user", "maxzhao",
                        "addtime", new Date(),
                        "message", "add data Elasticsearch");
    }
}

public class demo {
    void demo() {
        /*同步*/
        IndexResponse indexResponse = null;
        try {
            indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
            this.HandleIndexResponse(indexResponse);
        } catch (ElasticsearchException e) {
            log.warn(e.toString());
            /*版本冲突所抛出的异常*/
            /*同样会发生,以防opType将创建和相同的索引文档id已经存在:*/
            if (e.status() == RestStatus.CONFLICT) {
            }
        } catch (IOException e) {
            log.warn(e.toString());
        }
        /*异步*/
        Cancellable cancellable = restHighLevelClient.indexAsync(indexRequest, RequestOptions.DEFAULT, new ActionListener<IndexResponse>() {
            @Override
            public void onResponse(IndexResponse indexResponse) {
                HandleIndexResponse(indexResponse);
            }

            @Override
            public void onFailure(Exception e) {
                log.warn(e.toString());
            }
        });
    }
}