Java, ElasticSearch Beispiel mit TransportCilent

Den folgenden code erklärt die Kommunikation zwischen Java und ElasticSearch

mit Transport-client. Wenn ich Laufe bin ich immer der org.elasticsearch.nodedisconnectedException. Ein klares Beispiel für Java, Elasticsearch, der vergeben wird, gewürdigt werden, oder jemand kann mir helfen bei der Suche nach der Lösung.

public static Client function() {
    Settings setting = ImmutableSettings.settingsBuilder().put("cluster.name", "localtestsearch").build();
    client = new TransportClient();
    client = client.addTransportAddress(new InetSocketTransportAddress("localhost", 9300));
    return client;

}

public static void main(String[] args) {

    System.out.println("In Main Method");

    try {
        System.out.println("In try block");
        Client client = new TransportClient()
                .addTransportAddress(new InetSocketTransportAddress("localhost",
                        9300));


        System.out.println("Connected");

        client.close();

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


        org.elasticsearch.node.Node node = nodeBuilder().node();
        System.out.println("Node " + node);

        Client client = node.client();

        System.out.println("calling Client from Node " + client);

        node.close();
        System.out.println("Node CLosed");
    } catch (Exception ex) {
        ex.printStackTrace();
    }

}

}
InformationsquelleAutor user3337854 | 2014-04-24
  1. 2
    import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;

public class Test {
   public static void main(String[] args) {
       TransportClient client = new TransportClient();

       for(String host: client.settings().getAsArray("transport.client.initial_nodes")) {
           int port = 9300;

          //or parse it from the host string...
           String[] splitHost = host.split(":", 2);
           if(splitHost.length == 2) {
               host = splitHost[0];
               port = Integer.parseInt(splitHost[1]);
           }

           client.addTransportAddress(new InetSocketTransportAddress(host, port));
       }

       //...
   }
}
    InformationsquelleAutor BlackPOP
Schreibe einen Kommentar