2016-06-22 25 views
3

我開始使用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]

謝謝!

回答

2

無論何時啓動Hazelcast成員,它首先會嘗試查看是否有任何其他具有當前配置的集羣成員可用或不可用。如果找到一個,它將加入它們以形成羣集,否則它將僅以單個成員啓動羣集。
默認情況下,它會檢查相鄰的端口,即你的情況5702,5703。

+0

我明白了。如何以編程方式將特定IP和端口配置爲羣集成員,而不是自動檢查相鄰端口?我想向集羣添加兩個正好兩個成員,兩個成員具有不同的IP和端口。謝謝! – Ryan

+0

以下代碼將在本地主機內啓動兩個成員。如果要開始添加兩個單獨的IP地址,請禁用自動增量並將成員和端口地址設置爲屬性驅動。 –

+0

您可以通過將端口數設置爲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);' –

相關問題