我開始使用IP 127.0.0.1 Hazelcast和端口5701.爲什麼它嘗試連接另外兩個端口5702和5703?他們用了什麼,爲什麼連接失敗?爲什麼Hazelcast試圖連接到另外兩個端口
下面是我如何配置編程:
Config config = new Config();
NetworkConfig network = config.getNetworkConfig();
network.setPort(5701);
JoinConfig join = network.getJoin();
join.getMulticastConfig().setEnabled(false);
join.getTcpIpConfig().setEnabled(true);
join.getTcpIpConfig().addMember("127.0.0.1");
下面是日誌開始hazelcast時。
INFO:[127.0.0.1]:5701 [dev的] [3.6.3]創建TcpIpJoiner
2016年6月22日上午11點58分41秒com.hazelcast.core.LifecycleService INFO:[127.0。 0.1]:5701 [dev] [3.6.3]地址[127.0.0.1]:5701正在開發
2016年6月22日上午11:58:41 com.hazelcast.nio.tcp.nonblocking.NonBlockingIOThreadingModel 信息: [127.0.0.1]:5701 [dev] [3.6.3]配置了非阻塞IO線程模型的TcpIpConnectionManager:3個輸入線程和3個輸出線程
Jun 22,2016 11:58:41 A M com.hazelcast.nio.tcp.InitConnectionTask INFO:[127.0.0.1]:5701 [dev] [3.6.3]連接到/127.0.0.1:5702,超時:0,bind-any:true
2016年6月22日上午11:58:41 com.hazelcast.nio.tcp.InitConnectionTask 信息:[127.0.0.1]:5701 [dev] [3.6.3]連接到/127.0.0.1:5703,超時:0, bind-any:true
2016年6月22日上午11:58:41 com.hazelcast.nio.tcp.InitConnectionTask 信息:[127.0.0.1]:5701 [dev] [3.6.3]無法連接到:/127.0.0.1:5702。原因:SocketException [連接拒絕地址/127.0.0.1:5702]
2016年6月22日上午11:58:41 com.hazelcast.nio.tcp.InitConnectionTask 信息:[127.0.0.1]:5701 [dev ] [3.6.3]無法連接到:/127.0.0.1:5703。原因:SocketException [連接拒絕地址/127.0.0.1:5703]
2016年6月22日上午11:58:41 com.hazelcast.cluster.impl.TcpIpJoiner 信息:[127.0.0.1]:5701 [dev ] [3.6.3]地址[127.0.0.1]:5702被添加到黑名單。
2016年6月22日上午11:58:41 com.hazelcast.cluster.impl.TcpIpJoiner 信息:[127.0.0.1]:5701 [dev] [3.6.3]地址[127.0.0.1]:5703是添加到黑名單。
2016年6月22日上午11時58分42秒com.hazelcast.cluster.impl.TcpIpJoiner 信息:[127.0.0.1]:5701 [開發] [3.6.3]
謝謝!
我明白了。如何以編程方式將特定IP和端口配置爲羣集成員,而不是自動檢查相鄰端口?我想向集羣添加兩個正好兩個成員,兩個成員具有不同的IP和端口。謝謝! – Ryan
以下代碼將在本地主機內啓動兩個成員。如果要開始添加兩個單獨的IP地址,請禁用自動增量並將成員和端口地址設置爲屬性驅動。 –
您可以通過將端口數設置爲2並從這些機器運行實例啓動來實現此目的。在上面的示例代碼中: 'network.setPortAutoIncrement(false); network.setPortCount(2); network.setPort(PORT_NUM); 列表 members = new ArrayList <>(2); members.add(「IP_ADDRESS_1」); members.add(「IP_ADDRESS_2」); network.getJoin()。getTcpIpConfig()。setMembers(members);' –