elasticsearch-java api之client

布满荆棘的人生 2021-06-24 15:57 388阅读 0赞

Elasticsearch 的Java API 提供了非常便捷的方法来索引和查询数据等。 通过添加jar包，不需要编写HTTP层的代码就可以开始着手进行连接到Elasticsearch的工作。它提供了两种方法连接到Elasticsearch：创建一个本地节点并加入集群（cluster），或者利用传输（transport）。这两种方法都是利用一个Client（org.elasticsearch.client.Client）实例来实现的，而且他们都是通过9300端口与集群交互（9200端口是es提供的restful服务），使用Elasticsearch传输协议(Elasticsearch Transport Protocol)。集群中的节点之间也通过9300端口进行通信。

首先，需要添加maven的pom.xml：

<dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>2.3.2</version>
    </dependency>

1、节点客户端：

节点客户端以无数据节点(none data node)身份加入集群，换言之，它自己不存储任何数据，但是它知道数据在集群中的具体位置，并且能够直接转发请求到对应的节点上。

Node node = nodeBuilder().clusterName("escluster2").client(true).node();  
    Client client = node.client();

2、传输客户端（Transport client）：

是一种更轻量的传输客户端能够发送请求到远程集群。它自己不加入集群，只是简单转发请求给集群中的节点。这种方式是比较高效（推荐使用），但是发送查询信息以及数据需要更多的资源，因为TransportClient不清楚整个集群的拓扑，所以她不能直接将数据发送到目的节点，而是发送至一个初始化后的transport节点，ElasticSearch完成接下来的转发。

private static final String clusterHost = "test1:9300,test2:9300,test3:9300,test4:9300,test5:9300";
    private static final String clusterName = "test-es-online";
    
    private static TransportClient transportClient = null;
    
    static {
    		Settings settings = Settings.settingsBuilder()
    				.put("cluster.name", clusterName).build();
    
    		transportClient = TransportClient.builder().settings(settings).build();
    
    		String[] hostNames = clusterHost.split(",");
    		InetSocketTransportAddress[] serverAddresses = new InetSocketTransportAddress[hostNames.length];
    		for (int i = 0; i < hostNames.length; i++) {
    			String[] hostPort = hostNames[i].trim().split(":");
    			String host = hostPort[0].trim();
    			int port = hostPort.length == 2 ? Integer.parseInt(hostPort[1]
    					.trim()) : 9300;
    			serverAddresses[i] = new InetSocketTransportAddress(
    					new InetSocketAddress(host, port));
    		}
    
    		for (InetSocketTransportAddress host : serverAddresses) {
    			transportClient.addTransportAddress(host);
    		}
    
    }

通常，系统中的es-client只需要创建一个即可，所以可以设计成单例的方式。

参考：

http://www.cnblogs.com/wenbronk/p/6383194.html  
http://www.cnblogs.com/shuaiwang/p/4686224.html