摘要：將刷新策略作為。的典型偵聽器如下所示執(zhí)行成功完成時調(diào)用。響應(yīng)返回的允許檢索有關(guān)已執(zhí)行操作的信息，如下所示處理成功碎片數(shù)小于總分片數(shù)的情況。處理潛在的失敗。如果存在版本沖突，則拋出引發(fā)的異常表示返回了版本沖突錯誤。

DeleteRequest沒有參數(shù)。

DeleteRequest request = new DeleteRequest(
        "posts",    
        "doc",      
        "1");

posts — 索引。

doc — 類型。

1 — 文檔id。

可以選擇提供以下參數(shù)：

request.routing("routing");

路由值。

request.parent("parent");

parent值。

request.timeout(TimeValue.timeValueMinutes(2)); 
request.timeout("2m");

等待主碎片可用的作為TimeValue的超時。

等待主碎片可用的作為String 的超時。

request.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
request.setRefreshPolicy("wait_for");

將刷新策略作為WriteRequest.RefreshPolicy實(shí)例。

將刷新策略作為String。

request.version(2);

版本。

request.versionType(VersionType.EXTERNAL);

版本類型。

以下列方式執(zhí)行DeleteRequest時，客戶端在繼續(xù)執(zhí)行代碼之前等待返回DeleteResponse：

DeleteResponse deleteResponse = client.delete(
        request, RequestOptions.DEFAULT);

執(zhí)行DeleteRequest也可以以異步方式完成，以便客戶端可以直接返回，用戶需要通過將請求和偵聽器傳遞給異步刪除方法來指定響應(yīng)或潛在故障的處理方式：

client.deleteAsync(request, RequestOptions.DEFAULT, listener);

要執(zhí)行的DeleteRequest和執(zhí)行完成時要使用的ActionListener。

異步方法不會阻塞并立即返回，完成后，如果執(zhí)行成功完成，則使用onResponse方法回調(diào)ActionListener，如果失敗則使用onFailure方法。

delete的典型偵聽器如下所示：

listener = new ActionListener() {
    @Override
    public void onResponse(DeleteResponse deleteResponse) {
        
    }

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

onResponse — 執(zhí)行成功完成時調(diào)用。

onFailure — 在整個DeleteRequest失敗時調(diào)用。

返回的DeleteResponse允許檢索有關(guān)已執(zhí)行操作的信息，如下所示：

String index = deleteResponse.getIndex();
String type = deleteResponse.getType();
String id = deleteResponse.getId();
long version = deleteResponse.getVersion();
ReplicationResponse.ShardInfo shardInfo = deleteResponse.getShardInfo();
if (shardInfo.getTotal() != shardInfo.getSuccessful()) {
    
}
if (shardInfo.getFailed() > 0) {
    for (ReplicationResponse.ShardInfo.Failure failure :
            shardInfo.getFailures()) {
        String reason = failure.reason(); 
    }
}

處理成功碎片數(shù)小于總分片數(shù)的情況。

處理潛在的失敗。

還可以檢查文檔是否被找到：

DeleteRequest request = new DeleteRequest("posts", "doc", "does_not_exist");
DeleteResponse deleteResponse = client.delete(
        request, RequestOptions.DEFAULT);
if (deleteResponse.getResult() == DocWriteResponse.Result.NOT_FOUND) {
    
}

如果找不到要刪除的文檔，請執(zhí)行某些操作。

如果存在版本沖突，則拋出ElasticsearchException：

try {
    DeleteResponse deleteResponse = client.delete(
            new DeleteRequest("posts", "doc", "1").version(2),
            RequestOptions.DEFAULT);
} catch (ElasticsearchException exception) {
    if (exception.status() == RestStatus.CONFLICT) {
        
    }
}

引發(fā)的異常表示返回了版本沖突錯誤。