【ES】JavaAPI学习-01

前言

本文档及关联项目用于ElasticSearch的JavaAPI的学习。

本节将完成环境配置，索引创建

环境

JDK8

IntelliJ IDEA 2021.2.3 (Community Edition)

Postman-win64-8.12.4

elasticsearch-7.15.0-windows-x86_64

实现 启动ES和POSTMAN

找到elasticsearch的安装路径，打开bin文件夹

打开elasticsearch.bat 文件

稍等片刻，看到

则其启动成功。

可以测试一下 http://127.0.0.1:9200/ 是否能打开。

然后启动POSTMAN，我用的是POSTMAN客户端:

项目创建

创建一个新项目

取名为：ElasticSearch-JavaAPI-learning

依赖配置

pom.xml

    4.0.0

    org.example
    ElasticSearch-JavaAPI-learning
    1.0-SNAPSHOT

    
        8
        8
    

    
        
            org.elasticsearch
            elasticsearch
            7.8.0
        
        
        
            org.elasticsearch.client
            elasticsearch-rest-high-level-client
            7.8.0
        
        
        
            org.apache.logging.log4j
            log4j-api
            2.8.2
        
        
            org.apache.logging.log4j
            log4j-core
            2.8.2
        
        
            com.fasterxml.jackson.core
            jackson-databind
            2.9.9
        
        
        
            junit
            junit
            4.12
        
    

配置好之后记得更新maven

es

在src.main.java下创建com.zwy.es文件夹：

创建测试客户端

ESTest_Client.java

package com.zwy.es;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import sun.rmi.transport.TransportConstants;

import java.io.IOException;

public class ESTest_Client {
    public static void main(String[] args) throws IOException {

        // 创建ES客户端
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 关闭ES客户端
        esClient.close();

    }
}

ESTest_Index_Create.java

package com.zwy.es;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;

import java.io.IOException;

public class ESTest_Index_Create {
    public static void main(String[] args) throws IOException {

        //
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 创建索引
        CreateIndexRequest request = new CreateIndexRequest("users");  // 创建请求对象
        CreateIndexResponse createIndexResponse = esClient.indices().create(request, RequestOptions.DEFAULT);  // 返回响应

        // 响应状态
        boolean acknowledged = createIndexResponse.isAcknowledged();

        System.out.println("索引 *** 作 : " + acknowledged);

        // 关闭ES客户端
        esClient.close();

    }
}

文件结构

项目文件结构如下：

运行

先运行ESTest_Client.java

没有报错。

这时打开postman，创建一个请求的collection：

我把它命名为ES基础 *** 作。

然后创建一个 GET 请求（request）如下：

http://127.0.0.1:9200/_cat/indices?v

点击 Send 搜索索引，应该没有出现 users的索引，如果有，可以自己修改ESTest_Index_Create.java的CreateIndexRequest中的入参。

则继续运行ESTest_Index_Create.java

运行成功，返回true，这时在回到POSTMAN中调用刚刚的 GET 请求，可以看到：

成功创建users索引。