springboot+elasticsearch7.3.0创建索引

首先参考: /qq_27950699/article/details/99354774搭建Client

   首先排除内置包(有可能不需要,可自行测试):

<dependency>
    <groupId></groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.3.0</version>
    <exclusions>
        <exclusion>
            <groupId></groupId>
            <artifactId>elasticsearch</artifactId>
        </exclusion>
        <exclusion>
            <groupId></groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId></groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.3.0</version>
</dependency>
<dependency>
    <groupId></groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.3.0</version>
</dependency>

---

开始集成es:index:索引名称

EsConfig esConfig = new EsConfig();
RestHighLevelClient client = ();
CreateIndexRequest request = new CreateIndexRequest(index);
(()
        .put("index.number_of_shards",10)   //分片数
        .put("index.number_of_replicas", 1));//副本数
(new Alias(index+"alias"));//设置别名
((2));//设置创建索引超时2分钟
// 同步请求(亲测可以)
try {
    CreateIndexResponse createIndexResponse = ().create(request,);
    // 处理响应
    boolean acknowledged = ();
    boolean shardsAcknowledged = ();
    (acknowledged+","+shardsAcknowledged);
   ();
} catch (IOException e) {
    ("索引{}创建异常:"+(),index);
    return false;
}
//异步请求 (自己测试)
/** ActionListener<CreateIndexResponse> listener = new ActionListener<CreateIndexResponse>() {
                @Override
                public void onResponse(CreateIndexResponse createIndexResponse) {
                    boolean acknowledged = ();
                    boolean shardsAcknowledged = ();
                }
                @Override
                public void onFailure(Exception e) {
                    ();
                }
            };
  ().createAsync(request, listener);*/

return true;
不管用什么方法,都不要忘记();