1. 环境准备

安装ElasticSearch

2. 整合ElasticSearch

2.1 导入POM依赖

 <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>

2.2 编写配置类

编写配置文件，注入bean对象

@Configuration
public class ElasticSearchConfig {

    @Bean
    public RestHighLevelClient restHighLevelClient() {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));
        return client;
    }

}

3. Api使用

3.1 索引

3.1.1 创建索引


public void createIndex() throws IOException {
        // 创建索引请求
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("test_index");

        // 执行请求并获取执行结果
        CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);

    }

3.1.2 获取索引

    public void getIndex() throws IOException {
        GetIndexRequest request = new GetIndexRequest("test_index");
        // 判断索引是否存在 
        boolean exists = restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);

        // 执行请求并获取执行结果
        GetIndexResponse getIndexResponse = restHighLevelClient.indices().get(request, RequestOptions.DEFAULT);
        
    }

3.1.3 删除索引

    public void deleteIndex() throws IOException {
        DeleteIndexRequest request = new DeleteIndexRequest("test_index");

        // 执行请求并获取执行结果
        AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
        
        delete.isAcknowledged();
    }