在elasticsearch中获取TransportClient实例时获取ConnectTransportException

Question

我正在使用TransportClient创建elasticsearch客户端实例，代码如下。

public static Client getInstance() {
    String ipAddress = MessageTranslator.getMessage("es.cluster.ip");
    int transportClientPort = Integer.parseInt(MessageTranslator
                .getMessage("es.transportclient.port"));

    logger.debug("got the client ip as :" + ipAddress + " and port :"
            + transportClientPort);
    if (instance == null) {
        logger.debug("the client instance is null, creating a new instance");
        ImmutableSettings.Builder settings = ImmutableSettings
                .settingsBuilder();
        settings.put("node.client", true);
        settings.put("node.data", false);
        settings.put("node.name", "node-client");
        settings.put("cluster.name", "elasticsearch");
        settings.build();
        instance = new TransportClient(settings)
                .addTransportAddress(new InetSocketTransportAddress(
                        ipAddress, transportClientPort));
        logger.debug("returning the new created client instance...");
        return instance;
    }
    logger.debug("returning the existing transport client object connection.");
    return instance;
}

问题有时是代码正在工作并索引数据，但有时我会遇到以下问题。

14-08-2014 12:49:07846调试[elasticsearch[节点客户端][传输客户端工作者][T#8]{新I/O工作者#8}]组织。弹性搜索。常见的登录中。log4j。Log4jESLogger 104-[node client]与[[Nuke-Frank Simpson][P_-PZbTXyimWCOvkC7ow][aricloudvmserver3.aricent.com][inet[/10.203.238.139:9300]]，频道关闭事件14-08-2014 12:49:11134调试[elasticsearch[node client][generic][T#1]]org。弹性搜索。常见的登录中。log4j。Log4jESLogger 109-[node client]无法连接到节点[[#transport#-1][BGHWV2099][inet[/10.203.238.139:9300]]，已从节点列表组织中删除。弹性搜索。运输ConnectTransportException:[[inet[/10.203.238.139:9300]]在组织上连接超时[30s]。弹性搜索。运输内蒂。网络运输。org上的connectToChannelsLight（NettyTransport.java:683）。弹性搜索。运输内蒂。网络运输。org上的connectToNode（NettyTransport.java:643）。弹性搜索。运输内蒂。网络运输。connectToNodeLight（NettyTransport.java:610）

请帮我找到问题。

谢啦

Answer 1

你的代码在我看来是正确的。如果这是一个间歇性问题，可以归因于：

• 失去连接

也如上一篇文章所建议的，删除与节点相关的设置，并尝试设置下面提到的属性

settingsBuilder.put("cluster.name", searchClusterName);
settingsBuilder.put("client.transport.sniff", true);
settingsBuilder.put("http.enabled", "false");

尝试一下并分享你的发现