如何使用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();