es异步增添数据java示例

以下是一个使用 Elasticsearch Java API 异步增加数据的示例代码：

import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.AsyncRestHighLevelClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.RestClient;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class AsyncIndexExample {

    public static void main(String[] args) throws IOException {
        // 创建 RestClientBuilder 对象
        RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200));

        // 创建 AsyncRestHighLevelClient 对象
        AsyncRestHighLevelClient client = new AsyncRestHighLevelClient(builder);

        // 创建要增加的数据
        Map<String, Object> jsonMap = new HashMap<>();
        jsonMap.put("title", "示例文档");
        jsonMap.put("content", "这是一篇示例文档，用于演示 Elasticsearch 的异步 API。");
        jsonMap.put("tags", new String[]{"elasticsearch", "java", "异步编程"});

        // 创建 IndexRequest 对象
        IndexRequest request = new IndexRequest("my_index").source(jsonMap);

        // 调用异步 API 增加数据
        client.indexAsync(request, new ActionListener<IndexResponse>() {
            @Override
            public void onResponse(IndexResponse indexResponse) {
                // 处理响应结果
                System.out.println(indexResponse);
            }

            @Override
            public void onFailure(Exception e) {
                // 处理异常情况
                e.printStackTrace();
            }
        });

        // 关闭客户端连接
        client.close();
    }
}

在上面的示例中，我们首先创建了一个 `RestClientBuilder` 对象，然后使用它创建了一个 `AsyncRestHighLevelClient` 客户端对象。接着，我们定义了要增加的数据，创建了一个 `IndexRequest` 对象，并调用了 `client.indexAsync()` 方法来异步地增加数据。在调用方法时，我们传入了一个 `ActionListener` 对象，用于处理异步 API 的响应结果或异常情况。

需要注意的是，为了使用 Elasticsearch 的异步 API，我们需要将 `elasticsearch-rest-high-level-client` 和 `elasticsearch` 两个库都添加到项目的依赖中。并且，我们需要在程序结束时调用 `client.close()` 方法来关闭客户端连接。