elasticsearch-java api之client

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