使用java客户端创建elasticsearch索引库

你的名字 2021-01-22 18:11 580阅读 0赞

创建maven工程，导入下列依赖
pom.xml
````
    <dependencies>
            <dependency>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
                <version>6.2.1</version>
            </dependency>
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>transport</artifactId>
                <version>6.2.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-to-slf4j</artifactId>
                <version>2.11.1</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-api</artifactId>
                <version>1.7.25</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-simple</artifactId>
                <version>1.7.5</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
        </dependencies>
````
ElasticSearchClient.java
````
    package cn.neu.es;

import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    import org.junit.Test;
    
    import java.net.InetAddress;
    
    /** * @Author WCJ * @Description **/
    public class ElasticSearchClient { 
        @Test
        public void creatIndex() throws Exception{ 
            //1.创建settings对象，配置信息
            Settings settings = Settings.builder().put("cluster.name","my-elasticsearch").build();
            //2.创建客户端
            TransportClient client = new PreBuiltTransportClient(settings);
            client.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9301));
            client.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9302));
            client.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9303));
            client.admin().indices().prepareCreate("index_hello").get();
            client.close();

}
    }
````