elasticsearch 使用jest客户端 写bulk代码

使用Jest客户端对Elasticsearch进行批量操作的代码示例如下：

import io.searchbox.client.JestClient;
import io.searchbox.client.JestClientFactory;
import io.searchbox.client.config.HttpClientConfig;
import io.searchbox.core.Bulk;
import io.searchbox.core.Index;
import io.searchbox.core.SearchResult;
import io.searchbox.indices.CreateIndex;
import io.searchbox.indices.mapping.PutMapping;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

public class ElasticBulkExample {

    private static final String INDEX_NAME = "example_index";
    private static final String TYPE_NAME = "example_type";
    private static final String HOST = "http://localhost:9200";

    public static void main(String[] args) throws IOException {
        JestClientFactory factory = new JestClientFactory();
        factory.setHttpClientConfig(new HttpClientConfig
                .Builder(HOST)
                .multiThreaded(true)
                .build());

        JestClient client = factory.getObject();

        // create index
        client.execute(new CreateIndex.Builder(INDEX_NAME).build());

        // define mapping
        XContentBuilder builder = XContentFactory.jsonBuilder()
                .startObject()
                .startObject(TYPE_NAME)
                .startObject("properties")
                .startObject("name")
                .field("type", "text")
                .endObject()
                .startObject("age")
                .field("type", "integer")
                .endObject()
                .endObject()
                .endObject()
                .endObject();

        client.execute(new PutMapping.Builder(INDEX_NAME, TYPE_NAME, builder.string()).build());

        // add documents to index
        List<Index> indexList = new ArrayList<>();
        indexList.add(new Index.Builder("{\"name\":\"John Doe\",\"age\":25}").index(INDEX_NAME).type(TYPE_NAME).build());
        indexList.add(new Index.Builder("{\"name\":\"Jane Doe\",\"age\":30}").index(INDEX_NAME).type(TYPE_NAME).build());

        Bulk bulk = new Bulk.Builder()
                .defaultIndex(INDEX_NAME)
                .defaultType(TYPE_NAME)
                .addAction(indexList)
                .build();

        client.execute(bulk);

        // search for documents
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());

        SearchResult searchResult = client.execute(new io.searchbox.core.Search.Builder(searchSourceBuilder.toString())
                .addIndex(INDEX_NAME)
                .addType(TYPE_NAME)
                .build());

        System.out.println(searchResult.getJsonString());

        client.shutdownClient();
    }
}

上面的代码演示了如何使用Jest客户端创建索引、设置映射、写入文档和搜索文档。其中，Bulk类用于批量操作，addAction()方法用于添加操作，execute()方法用于执行操作。在添加操作时，可以使用Index类来构建写入文档的请求。在搜索操作时，使用Search类来构建请求，并使用SearchResult类来处理响应。