分布式搜索elasticsearch java API 之（一）

这是关于elasticsearch Java api的第一篇教程，陆续会把es的一些心得写出来。

可以通过两种方式来连接到elasticsearch（简称es）集群，第一种是通过在你的程序中创建一个嵌入es节点（Node），使之成为es集群的一部分，然后通过这个节点来与es集群通信。第二种方式是用TransportClient这个接口和es集群通信。

Node方式

创建嵌入节点的方式如下：

[java] view plaincopy

1. import static org.elasticsearch.node.NodeBuilder.*;   
2. //启动节点  
3. Node node = nodeBuilder().node();  
4. Client client = node.client();   
5. //关闭节点 
6. node.close(); 

[java] view plain copy

1. import static org.elasticsearch.node.NodeBuilder.*;    
2. //启动节点   
3. Node node = nodeBuilder().node();   
4. Client client = node.client();    
5. //关闭节点  
6. node.close();  

当你启动一个节点，它会自动加入同网段的es集群，一个前提就是es的集群名（cluster.name）这个参数要设置一致。

默认的话启动一个节点，es集群会自动给它分配一些索引的分片，如果你想这个节点仅仅作为一个客户端而不去保存数据，你就可以设置把node.data设置成false或 node.client设置成true。下面是例子：

[java] view plaincopy

1. Node node = nodeBuilder().clusterName(clusterName).client(true).node();  

[java] view plain copy

1. Node node = nodeBuilder().clusterName(clusterName).client(true).node();   

还有一种情况是你并不想把节点加入集群，只想用它进行单元测试时，就要启动一个“本地”的es，这里“本地”指的是在jvm的级别下运行，即两个不同的es节点运行在同一个JVM中时会组成一个集群。它需要把节点的local参数设置成true，下面是例子：

[java] view plaincopy

1. Node node = nodeBuilder().local(true).node();  

[java] view plain copy

1. Node node = nodeBuilder().local(true).node();   

TransportClient方式
通过TransportClient这个接口，我们可以不启动节点就可以和es集群进行通信，它需要指定es集群中其中一台或多台机的ip地址和端口，例子如下：

[java] view plaincopy

1. Client client = new TransportClient()  
2.         .addTransportAddress(new InetSocketTransportAddress("host1", 9300))  
3.         .addTransportAddress(new InetSocketTransportAddress("host2", 9300));  
4.   
5. client.close(); 

[java] view plain copy

1. Client client = new TransportClient()   
2.         .addTransportAddress(new InetSocketTransportAddress("host1", 9300))   
3.         .addTransportAddress(new InetSocketTransportAddress("host2", 9300));   
4.    
5. client.close();  

    
如果你需要更改集群名（默认是elasticsearch），需要如下设置：

[java] view plaincopy

1. Settings settings = ImmutableSettings.settingsBuilder()  
2.                 .put("cluster.name", "myClusterName").build();  
3. Client client = new TransportClient(settings); 

[java] view plain copy

1. Settings settings = ImmutableSettings.settingsBuilder()   
2.                 .put("cluster.name", "myClusterName").build();   
3. Client client = new TransportClient(settings);  

你可以设置client.transport.sniff为true来使客户端去嗅探整个集群的状态，把集群中其它机器的ip地址加到客户端中，这样做的好处是一般你不用手动设置集群里所有集群的ip到连接客户端，它会自动帮你添加，并且自动发现新加入集群的机器。代码实例如下：

[java] view plaincopy

1. Settings settings = ImmutableSettings.settingsBuilder()  
2.                 .put("client.transport.sniff", true).build();  
3. TransportClient client = new TransportClient(settings); 

[java] view plain copy

1. Settings settings = ImmutableSettings.settingsBuilder()   
2.                 .put("client.transport.sniff", true).build();   
3. TransportClient client = new TransportClient(settings);  

参考资料：http://www./articles/2013/02/18/1361194853254.html