如何使用Elasticsearch节点客户端连接到远程服务器Java

Question

我正尝试使用Elasticsearch Java NodeBuilder客户端连接到我的服务器。但是，我没有看到任何选项来指定我的服务器地址和端口（就像我们可以在传输客户端中使用addNewTransportAddress("serveraddress", port))一样。我如何使节点客户端连接到我的服务器？代码如下，我在哪里提到要连接的服务器地址到？

//On Startup 
Node node = nodeBuilder() 
     .clusterName("elasticsearch") 
     .data(false) //No shards allocated; or can set client to true 
     .client(true) //No shards allocated; or can set data to false 
     .node(); 

//Node Client 
Client client = node.client(); 

//Get API  
GetResponse response = client.prepareGet("indexname", "type", "id") 
     .execute() 
     .actionGet(); 

System.out.println("----------------Index Output Begin----------------"); 
System.out.println("Index Name: " + response.getIndex()); 
System.out.println("Type: " + response.getType()); 
System.out.println("Document ID: " + response.getId()); 
System.out.println("Document Version: " + response.getVersion()); 
System.out.println("Source: " + response.getSourceAsString()); 

Answer 1

节点客户端上的多播的基础。 客户端和节点之间的网络必须是网络已播启用，然后客户端将“发现”上的节点基础群集名称

如果您需要连接到远程服务器（通过指定IP地址），则必须使用transport client。

Settings settings = ImmutableSettings.settingsBuilder() 
     .put("cluster.name", "myClusterName").build(); 
Client client = new TransportClient(settings) 
     .addTransportAddress(new InetSocketTransportAddress("host1", 9300)) 
     .addTransportAddress(new InetSocketTransportAddress("host2", 9300)); 

Answer 2

当我使用ImmutableSettings时，我得到了"ImmutableSettings cannot be resolved"。

我的代码是：

Node node =nodeBuilder() 
      .settings(ImmutableSettings.settingsBuilder().put("path.home", "/home/amit/elasticsearch-2.1.0/bin")) 
      .client(true) 
      .node(); 
     Client client = node.client();