摘要：執(zhí)行請(qǐng)求一旦創(chuàng)建了，就可以通過(guò)調(diào)用或來(lái)發(fā)送請(qǐng)求，是同步的，將阻塞調(diào)用線程并在請(qǐng)求成功時(shí)返回，如果失敗則拋出異常。自定義響應(yīng)消費(fèi)者。處理返回的響應(yīng)。由于通信錯(cuò)誤或帶有指示錯(cuò)誤的狀態(tài)碼的響應(yīng)，處理返回的異常。

一旦創(chuàng)建了RestClient，就可以通過(guò)調(diào)用performRequest或performRequestAsync來(lái)發(fā)送請(qǐng)求，performRequest是同步的，將阻塞調(diào)用線程并在請(qǐng)求成功時(shí)返回Response，如果失敗則拋出異常。performRequestAsync是異步的，它接受一個(gè)ResponseListener參數(shù)，它在請(qǐng)求成功時(shí)調(diào)用Response，如果失敗則調(diào)用Exception。

這是同步的：

Request request = new Request(
    "GET",  
    "/");   
Response response = restClient.performRequest(request);

第一個(gè)參數(shù)：HTTP方法（GET，POST，HEAD等）。

第二個(gè)參數(shù)：服務(wù)器上的端點(diǎn)。

這是異步的：

Request request = new Request(
    "GET",  
    "/");   
restClient.performRequestAsync(request, new ResponseListener() {
    @Override
    public void onSuccess(Response response) {
        
    }

    @Override
    public void onFailure(Exception exception) {
        
    }
});

onSuccess方法：處理響應(yīng)。

onFailure：處理失敗。

你可以將請(qǐng)求參數(shù)添加到請(qǐng)求對(duì)象：

request.addParameter("pretty", "true");

你可以將請(qǐng)求的body設(shè)置為任何HttpEntity：

request.setEntity(new NStringEntity(
        "{"json":"text"}",
        ContentType.APPLICATION_JSON));

為HttpEntity指定的ContentType很重要，因?yàn)樗鼘⒂糜谠O(shè)置Content-Type header，以便Elasticsearch可以正確解析內(nèi)容。

你還可以將其設(shè)置為String，默認(rèn)為ContentType為application/json。

request.setJsonEntity("{"json":"text"}");

RequestOptions類保存應(yīng)在同一應(yīng)用程序中的多個(gè)請(qǐng)求之間共享的部分請(qǐng)求，你可以創(chuàng)建單例實(shí)例并在所有請(qǐng)求之間共享它：

private static final RequestOptions COMMON_OPTIONS;
static {
    RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
    builder.addHeader("Authorization", "Bearer " + TOKEN); 
    builder.setHttpAsyncResponseConsumerFactory(           
        new HeapBufferedResponseConsumerFactory(30 * 1024 * 1024 * 1024));
    COMMON_OPTIONS = builder.build();
}

builder.addHeader：添加所有請(qǐng)求所需的任何header。

builder.setHttpAsyncResponseConsumerFactory：自定義響應(yīng)消費(fèi)者。

addHeader用于授權(quán)或在Elasticsearch前使用代理所需的header，無(wú)需設(shè)置Content-Type header，因?yàn)榭蛻舳藢⒆詣?dòng)從附加到請(qǐng)求的HttpEntity設(shè)置該header。

你可以設(shè)置NodeSelector來(lái)控制哪些節(jié)點(diǎn)將接收請(qǐng)求。

NodeSelector.NOT_MASTER_ONLY是一個(gè)不錯(cuò)的選擇。

你還可以自定義用于緩沖異步響應(yīng)的響應(yīng)消費(fèi)者，默認(rèn)消費(fèi)者將在JVM堆上緩沖最多100MB的響應(yīng)，如果響應(yīng)較大，則請(qǐng)求將失敗。例如，如果你在堆約束環(huán)境（如上面的例子）中運(yùn)行，則可以降低可能有用的最大大小。

創(chuàng)建單例后，你可以在發(fā)出請(qǐng)求時(shí)使用它：

request.setOptions(COMMON_OPTIONS);

你還可以根據(jù)請(qǐng)求自定義這些選項(xiàng)，例如，這會(huì)添加額外的header：

RequestOptions.Builder options = COMMON_OPTIONS.toBuilder();
options.addHeader("cats", "knock things off of other things");
request.setOptions(options);

客戶端很樂(lè)意并行執(zhí)行許多操作，以下示例并行索引許多文檔，在現(xiàn)實(shí)世界的場(chǎng)景中，你可能希望使用_bulk API，但示例是作例證的。

final CountDownLatch latch = new CountDownLatch(documents.length);
for (int i = 0; i < documents.length; i++) {
    Request request = new Request("PUT", "/posts/doc/" + i);
    //let"s assume that the documents are stored in an HttpEntity array
    request.setEntity(documents[i]);
    restClient.performRequestAsync(
            request,
            new ResponseListener() {
                @Override
                public void onSuccess(Response response) {
                    
                    latch.countDown();
                }

                @Override
                public void onFailure(Exception exception) {
                    
                    latch.countDown();
                }
            }
    );
}
latch.await();

onSuccess：處理返回的響應(yīng)。

onFailure：由于通信錯(cuò)誤或帶有指示錯(cuò)誤的狀態(tài)碼的響應(yīng)，處理返回的異常。