如何使用Java Client编程创建和发布索引

import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.mapper.ObjectMapper;
import org.elasticsearch.index.mapper.RootObjectMapper;
import org.elasticsearch.index.mapper.TextFieldMapper;
import org.elasticsearch.index.mapper.MapperBuilders;
import org.elasticsearch.index.mapper.Mapping;
import org.elasticsearch.client.indices.PutMappingRequest;

public class IndexCreationExample {
    public static void main(String[] args) {
        // 创建Elasticsearch客户端
        RestHighLevelClient client = new RestHighLevelClient();

        try {
            // 创建索引请求
            CreateIndexRequest request = new CreateIndexRequest("my_index");
            
            // 设置索引的设置
            request.settings(Settings.builder()
                .put("index.number_of_shards", 3)
                .put("index.number_of_replicas", 2)
            );
            
            // 创建索引的映射
            Mapping mapping = Mapping.create(
                new RootObjectMapper.Builder("my_type")
                    .add(new TextFieldMapper.Builder("title"))
            );
            request.mapping(mapping);
            
            // 发送索引请求
            CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
            
            // 处理响应
            if (response.isAcknowledged()) {
                System.out.println("索引创建成功！");
            } else {
                System.out.println("索引创建失败！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭Elasticsearch客户端
            client.close();
        }
    }
}