2014-12-01 19 views
8

Elasticsearch Java NodeBuilder İstemcisi'ni kullanarak sunucuma bağlanmaya çalışıyorum. Ancak, sunucu adresimi ve bağlantı noktasını belirtme seçeneği (addNewTransportAddress("serveraddress", port)) kullanarak Transport Client'ta yapabileceğimiz gibi bir seçenek görmüyorum. Node İstemcisini sunucuma nasıl bağlarım yapabilirim? Kod aşağıdadır, bağlanılacak sunucu adresini nereden bulabilirim? ?Elasticsearch Node İstemcisi'ni kullanarak uzak sunucuya nasıl bağlanır? İstemci Java

//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()); 

cevap

8

için düğüm istemci noktaya yayın üzerinde temelidir. müşterileriniz ve düğümler arasında ağ noktaya yayın etkinleştirmek etti ağda olmak zorunda. ve sonra müşteri üzerinde düğümler tabanı "keşfedeceksiniz" küme adı

Uzak sunuculara bağlanmanız gerekiyorsa (ip adreslerini belirterek), transport client numaralı telefonu kullanmalısınız

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

ImmutableSettings kullanıldığında "ImmutableSettings cannot be resolved" var.

Benim kodudur:

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

Ben aynı sorunu vardı. Görünüşe göre ImmutableSettings, 2.2.0 sürüm –

+0

Düğüm düğümünde = NodeBuilder.nodeBuilder(). Ayarları (Settings.builder() \t .put ("path.home", "/ media/rajnish/7F58-E3202/elasticsearch-2.1.0 ")) \t .client (false) \t .local (true) \t .node(); // İstemci Nesnesi Oluştur. \t İstemci istemcisi = node.client(); – user3269486

İlgili konular