将Java客户端连接到Hazelcast Kubernetes失败

Question

我正在运行一个kubernetes集群，在其中按照kubernetes hazelcast github页面上的说明部署一个“云原生hazelcast”。一旦运行了许多hazelcast实例，我就会尝试将java客户端连接到其中一个实例，但由于某种原因，连接失败。

使用kubernetes外部endpoint，我可以从kubernetes集群外部连接到hazelcast。当我使用curl-kubernetes-master:32469/hazelcast/REST/cluster进行REST调用时，我从hazelcast得到了正确的响应，其中包含集群信息。所以我知道我的endpoint是有效的。

hazelcast kubernetes部署使用hazelcast kubernetes引导程序，该引导程序允许通过使用复制控制器设置环境变量进行一些配置，但我使用的是所有默认值。所以我的组和密码是“someGroup”和“someSecret”。

我Java客户端代码非常简单：

ClientConfig clientConfig = new ClientConfig();
clientConfig.getNetworkConfig().setConnectionAttemptLimit(0);
clientConfig.getNetworkConfig().setConnectionTimeout(10000);
clientConfig.getNetworkConfig().setConnectionAttemptPeriod(2000);
clientConfig.getNetworkConfig().addAddress("kubernetes-master:32469");
clientConfig.getGroupConfig().setName("someGroup");
clientConfig.getGroupConfig().setPassword("someSecret")
HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

启动客户端时，这是hazelcast容器的日志输出

2016-07-05 12:54:38.143  INFO 5 --- [thread-Acceptor] com.hazelcast.nio.tcp.SocketAcceptor     : [172.16.15.4]:5701 [someGroup] [3.5.2] Accepting socket connection from /172.16.29.0:54333
2016-07-05 12:54:38.143  INFO 5 --- [        cached4] c.h.nio.tcp.TcpIpConnectionManager       : [172.16.15.4]:5701 [someGroup] [3.5.2] Established socket connection between /172.16.15.4:5701
2016-07-05 12:54:38.157  INFO 5 --- [.IO.thread-in-1] c.h.nio.tcp.SocketClientMessageReader    : [172.16.15.4]:5701 [someGroup] [3.5.2] Unknown client type: <

和客户端的控制台输出

jul 05, 2016 2:54:37 PM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_someGroup][3.6.2] is STARTING
jul 05, 2016 2:54:38 PM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_someGroup][3.6.2] is STARTED
jul 05, 2016 2:54:48 PM com.hazelcast.client.spi.impl.ClusterListenerSupport
WARNING: Unable to get alive cluster connection, try in 0 ms later, attempt 1 of 2147483647.
jul 05, 2016 2:54:58 PM com.hazelcast.client.spi.impl.ClusterListenerSupport
WARNING: Unable to get alive cluster connection, try in 0 ms later, attempt 2 of 2147483647.
jul 05, 2016 2:55:08 PM com.hazelcast.client.spi.impl.ClusterListenerSupport
etc...

客户端只是不断尝试连接，但从未建立过连接。

那么，为什么我的客户端不能连接到hazelcast实例？这是我缺少的配置部分吗？

Answer 1

查看控制台日志，Node和Client之间有不同的Hazelcast版本？您可以将两者都更新为3.6.4，即最新版本，或者只是将集群更改为3.6.2以与客户端匹配。3.6. x也有许多配置更改和许多错误修复。

Answer 2

不确定kubernetes的官方支持，但是Hazelcast有一个kubernetes发现插件（基于新的discovery spi），可在客户端和节点上运行：https://github.com/noctarius/hazelcast-kubernetes-discovery