RESTHighLevelClient创建索引详解

一、创建RESTHighLevelClient客户端

// 添加以下依赖
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>${elasticsearch.version}</version>
</dependency>

// 通过以下代码创建client
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(
                new HttpHost("localhost", 9200, "http"),
                new HttpHost("localhost", 9201, "http")));

// 使用完client后需关闭资源
client.close();

在使用RESTHighLevelClient API时，首先需要创建一个client对象，这个对象在应用程序中应当是全局唯一的。可以将其声明为单例，在整个应用程序上下文中重复使用。

二、创建索引

// 定义index名称及属性Mappings
// mappings: 在索引中预定义字段及其数据类型
// Settings: 在索引中定义设置。例如，默认分片数和副本数
String index = "indexName";
String type = "typeName";
XContentBuilder builder = XContentFactory.jsonBuilder();
builder.startObject();
{
    builder.startObject("properties");
    {
        builder.startObject("fieldName");
        {
            builder.field("type", "text"); // 字段类型
        }
        builder.endObject();
    }
    builder.endObject();
}
builder.endObject();
PutIndexTemplateRequest request = new PutIndexTemplateRequest("templateName");
request.settings(Settings.builder().put("index.number_of_shards", 1) // 分片数
        .put("index.number_of_replicas", 0)) // 副本数
        .mapping(type, builder);
CreateIndexRequest createIndexRequest = new CreateIndexRequest(index).settings(Settings.builder().put("index.number_of_shards", 1) // 分片数
        .put("index.number_of_replicas", 0)) // 副本数
        .mapping(type, builder);

// 同步调用，会阻塞当前线程直至操作完成
CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);

// 异步调用，需要设置监听器
client.indices().createAsync(createIndexRequest, RequestOptions.DEFAULT, listener);

创建索引的过程可以分为两个步骤：定义索引的属性和创建索引。在定义索引属性时，需要使用XContentBuilder来创建一个JSON对象，包含了所需的索引属性。在创建完属性后，就可以使用CreateIndexRequest或PutIndexTemplateRequest来创建索引。

三、添加数据

// 创建IndexRequest
IndexRequest request = new IndexRequest(index, type, "documentId");

// 使用Json数据填充IndexRequest
request.source(jsonMap);

// 同步请求添加数据
IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);

// 异步请求添加数据，需要设置监听器
client.indexAsync(request, RequestOptions.DEFAULT, listener);

添加数据是通过创建一个IndexRequest对象来实现的，该对象有3个参数，这些参数分别是索引名称，type和文档ID。添加数据时可以设置数据源。可以将该源指定为Map，String或byte数组，以JSON格式表示。调用index方法将数据添加到指定的索引中。当数据添加完成后，将会获得一个IndexResponse，该response包含了有关添加的数据的详细信息，例如文档的版本号。

四、更新数据

// 创建UpdateRequest，指定需要更新的文档索引、类型和ID
UpdateRequest request = new UpdateRequest(index, type, "documentId");

// 配置需要更新的数据
request.doc(jsonMap);

// 进行同步请求更新
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);

// 异步请求更新，需要设置监听器
client.updateAsync(request, RequestOptions.DEFAULT, listener);

更新数据需要使用UpdateRequest对象，此对象的构造函数中需要传递索引的名称，type和文档ID。更新数据时需要配置更新后的数据，可以将其指定为Map，String或byte数组，以JSON格式表示。调用update方法将更新请求发送到ES。更新后，将会返回一个UpdateResponse，其中包含有关更新数据的详细信息，例如文档的版本号。

五、删除数据

// 创建DeleteRequest，指定需要删除的文档索引、类型和ID
DeleteRequest request = new DeleteRequest(index, type, "documentId");

// 同步删除数据
DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);

// 异步删除数据，需要设置监听器
client.deleteAsync(request, RequestOptions.DEFAULT, listener);

删除数据需要通过创建DeleteRequest对象来实现，该对象的构造函数中需要传递索引的名称，类型和文档ID。调用delete方法将删除请求发送到ES。如果文档删除成功，则会返回一个DeleteResponse，其中包含有关已删除文档的详细信息，例如文档的版本号。

六、搜索数据

// 构建SearchSourceBuilder对象，指定查询条件
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchQuery("fieldName", "value"));

// 构建SearchRequest对象
SearchRequest searchRequest = new SearchRequest(index);
searchRequest.source(searchSourceBuilder);

// 发送搜索请求
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

在ES中搜索数据是非常常见的。搜索数据需要先创建一个SearchSourceBuilder对象，其中包含搜索的查询条件。可以使用QueryBuilder API创建查询条件。创建SearchRequest对象，该对象是发送搜索请求的必要条件。可以使用SearchRequest对象的source方法设置搜索条件，发送搜索请求的结果可以通过SearchResponse对象获得。

七、批量操作

// 构建BulkRequest对象
BulkRequest bulkRequest = new BulkRequest();
// 添加IndexRequest，UpdateRequest和DeleteRequest
bulkRequest.add(indexRequest);
bulkRequest.add(updateRequest);
bulkRequest.add(deleteRequest);
// 添加批量操作的监听器
client.bulkAsync(bulkRequest, RequestOptions.DEFAULT, listener);

批量操作可以大大提高操作效率，例如批量索引或删除数据都是非常有用的。要执行批量操作，需要先创建一个BulkRequest对象，然后添加多个IndexRequest，UpdateRequest或DeleteRequest对象，每个对象都需要指定所需的参数。添加操作后，可以使用bulkAsync方法将批量操作发送到ES，并设置适当的监听器。