我使用以下代码在Elastic Search中创建索引,
默认的JAVA API:

Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "myClusterName").put("client.transport.sniff", true).build();
Client client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress("localhost", 9200));
CreateIndexRequestBuilder createIndexRequestBuilder = client.admin().indices().prepareCreate("test1");
CreateIndexResponse response = createIndexRequestBuilder.execute().actionGet();
System.out.println(response.isAcknowledged());

REST服务:
HttpURLConnection con = null;
try
{
    String url = "http://localhost:9200/test2";

    URL resturl = new URL(url);
    con = (HttpURLConnection) resturl.openConnection();

    con.setDoOutput(true);
    con.setRequestMethod("PUT");
    BufferedReader in = null;
    try
    {
        if (con.getInputStream() != null)
        {
            in = new BufferedReader(new InputStreamReader(con.getInputStream()));
        }
    }
    catch (IOException e)
    {
        if (con.getErrorStream() != null)
        {
            in = new BufferedReader(new InputStreamReader(con.getErrorStream()));
        }
    }
    if (in == null)
    {
        throw new Exception("Unable to read response from server");
    }
    StringBuffer decodedString = new StringBuffer();
    String line;
    while ((line = in.readLine()) != null)
    {
        decodedString.append(line);
    }
    in.close();
    System.out.println("4");
    Integer responseCode = con.getResponseCode();
    System.out.println(responseCode);
}
catch (Exception ex)
{
    ex.printStackTrace();
}
finally
{
    if (con != null)
    {
        con.disconnect();
    }
}

通过使用REST API,我能够创建索引。默认情况下,JAVA API
我收到以下异常。
org.elasticsearch.client.transport.NoNodeAvailableException: No node available
at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:202)
at org.elasticsearch.client.transport.support.InternalTransportIndicesAdminClient.execute(InternalTransportIndicesAdminClient.java:85)
at org.elasticsearch.client.support.AbstractIndicesAdminClient.create(AbstractIndicesAdminClient.java:200)
at org.elasticsearch.action.admin.indices.create.CreateIndexRequestBuilder.doExecute(CreateIndexRequestBuilder.java:206)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:62)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:57)
at ElasticSearch.createIndex(ElasticSearch.java:121)
at ElasticSearch.main(ElasticSearch.java:157)

请指导我哪里出错了。提前致谢

最佳答案

TransportClient(通过Java API)的端口与Http不同
默认情况下,transportClient端口为9300

10-07 16:17
查看更多