弹性搜索中无节点可用异常

Question

我对弹性搜索概念非常陌生。我试图建立一个简单的应用程序使用弹性搜索。

public class App 
{
public static void main( String[] args )
{
    try {
        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
                .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));

        ElasticOperations.addDocToIndex(client, ElasticUtility.getJsonMap("Sandesha", "male", "[e-mail]", "Hassan"));
        System.out.println("Doc added");
        client.close();
    } catch (UnknownHostException e) {

        e.printStackTrace();
    }

}
}

public class ElasticOperations {

public static void addDocToIndex(TransportClient client, Map<String,Object> jsonMap)
{
    client.prepareIndex("customers", "personal").setSource(jsonMap).execute().actionGet();
}

}

我的ElasticUtility类看起来像，

public class ElasticUtility {

public static Map<String, Object> getJsonMap(String name, String gender, String email, String city)
{
    Map<String,Object> jsonMap = new HashMap<String, Object>();
    jsonMap.put("name", name);
    jsonMap.put("gender", gender);
    jsonMap.put("email", email);
    jsonMap.put("city", city);

    return jsonMap;
}
}

谢谢你。

Answer 1

我想您的群集名称不匹配。如果集群名称不是“ElasticSearch”，这可能是问题所在。

在浏览器中转到http://localhost:9200，获取集群名称。然后，尝试将集群名称属性添加到TransportClient，如下所示：

Settings settings = Settings.builder()
                            .put("cluster.name", "elasticsearch_foo").build();
TransportClient client = new PreBuiltTransportClient(settings)
                         .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));