1.java 如何连接ES?
(1)创建maven项目,添加ES依赖!
~添加ES依赖;
~添加ES高级API依赖;
顺便添加
~junit依赖,做测试;
~lombok依赖;构造方法;
(2)写一个测试类; 创建:传递参数对象,连接对象,客户端对象,关闭连接;
@Test
public void test1() throws IOException {
//建立java与ES的连接
//创建ES服务器地址和端口对象;传递连接地址+端口;
HttpHost httpHost = new HttpHost("10.11.57.76",9200);
//创建builder对象,这是一个构建连接的对象;
RestClientBuilder clientBuilder = RestClient.builder(httpHost);
//创建一个客户端对象;
RestHighLevelClient client = new RestHighLevelClient(clientBuilder);
System.out.println(client);//打印连接情况;如果这个对象成功创建,就说明成功连接;
//关闭连接
client.close();
}
为了以后方便我们一般通常把以上连接封装到一个工具类中!!!这样以后直接调用就好;
(1)工具类:
public class ClientUtils {
public static RestHighLevelClient client(){
//建立java与ES的连接
//创建ES服务器地址和端口对象;传递连接地址+端口;
HttpHost httpHost = new HttpHost("10.11.57.76",9200);
//创建builder对象,这是一个构建连接的对象;
RestClientBuilder clientBuilder = RestClient.builder(httpHost);
//创建一个客户端对象;
RestHighLevelClient client = new RestHighLevelClient(clientBuilder);
return client;
}
}
(2)测试类:
@Test
public void test2() throws IOException {
//直接调用自己封装的工具类
RestHighLevelClient client = ClientUtils.client();
System.out.println(client);
client.close();
}
。。。。。。。。。。。。。
嘻哈的简写笔记
。。。。。。。。。。。。。