登录
当前位置： 首页 > 面试题库 >

您如何以编程方式为多播发现机制配置hazelcast？

缪风史
2023-03-14
问题内容：

您如何以编程方式为多播发现机制配置hazelcast？

细节：

该文档仅提供TCP
/ IP的示例，并且已过时：它使用了Config.setPort（），该属性不再存在。

我的配置如下所示，但是发现不起作用（即，我得到了输出"Members: 1"：

Config cfg = new Config();                  
NetworkConfig network = cfg.getNetworkConfig();
network.setPort(PORT_NUMBER);

JoinConfig join = network.getJoin();
join.getTcpIpConfig().setEnabled(false);
join.getAwsConfig().setEnabled(false);
join.getMulticastConfig().setEnabled(true);

join.getMulticastConfig().setMulticastGroup(MULTICAST_ADDRESS);
join.getMulticastConfig().setMulticastPort(PORT_NUMBER);
join.getMulticastConfig().setMulticastTimeoutSeconds(200);

HazelcastInstance instance = Hazelcast.newHazelcastInstance(cfg);
System.out.println("Members: "+hazelInst.getCluster().getMembers().size());

更新1，考虑了asimarslan的答案

如果我对MulticastTimeout感到困惑，我要么得到"Members: 1"要么

2013年12月5日晚上8:50:42 com.hazelcast.nio.ReadHandler警告：[192.168.0.9]：4446 [dev]
hz._hzInstance_1_dev.IO.thread-in-0关闭套接字到端点地址[192.168.0.7]
：4446，原因：java.io.EOFException：远程套接字已关闭！2013年12月5日8:57:24 PM
com.hazelcast.instance.Node SEVERE：[192.168.0.9]：4446
[dev]无法加入群集，正在关闭！com.hazelcast.core.HazelcastException：在300秒内无法加入！

更新2，考虑了pveentjer关于使用tcp / ip的答案

如果将配置更改为以下内容，我仍然只能获得1个成员：

Config cfg = new Config();                  
NetworkConfig network = cfg.getNetworkConfig();
network.setPort(PORT_NUMBER);

JoinConfig join = network.getJoin();

join.getMulticastConfig().setEnabled(false);
join.getTcpIpConfig().addMember("192.168.0.1").addMember("192.168.0.2").
addMember("192.168.0.3").addMember("192.168.0.4").
addMember("192.168.0.5").addMember("192.168.0.6").
addMember("192.168.0.7").addMember("192.168.0.8").
addMember("192.168.0.9").addMember("192.168.0.10").
addMember("192.168.0.11").setRequiredMember(null).setEnabled(true);

//this sets the allowed connections to the cluster? necessary for multicast, too?
network.getInterfaces().setEnabled(true).addInterface("192.168.0.*");

HazelcastInstance instance = Hazelcast.newHazelcastInstance(cfg);
System.out.println("debug: joined via "+join+" with "+hazelInst.getCluster()
.getMembers().size()+" members.");

更确切地说，此运行产生输出

调试：通过JoinConfig {multicastConfig = MulticastConfig [enabled =
false，multicastGroup = 224.2.2.3，multicastPort = 54327，multicastTimeToLive =
32，multicastTimeoutSeconds = 2，trustedInterfaces = []]，tcpIpConfig =
TcpIpConfig [enabled = true，connectionTimeoutSeconds = 5，成员=
[192.168.0.1、192.168.0.2、192.168.0.3、192.168.0.4、192.168.0.5、192.168.0.6、192.168.0.7、192.168.0.8、192.168.0.9、192.168.0.10、192.168.0.11]，requiredMember
= null]，awsConfig = AwsConfig {enabled = false，region =’us-
east-1’，securityGroupName =’null’，tagKey =’null’，tagValue =’null’，hostHeader
='ec2.amazonaws.com‘，connectionTimeoutSeconds = 5}}，具有1个成员。

我的非hazelcast实现使用UDP多播，效果很好。那么，防火墙真的是问题所在吗？

更新3，考虑了pveentjer有关检查网络的答案

由于我没有iptables的权限，也没有安装iperf的权限，因此我正在按照第2章“直接炫耀”中的Hazelcast入门中com.hazelcast.examples.TestApp所述检查网络是否正常工作：

我拨打java -cp hazelcast-3.1.2.jar com.hazelcast.examples.TestApp192.168.0.1并获取输出

...Dec 10, 2013 11:31:21 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Prefer IPv4 stack is true.
Dec 10, 2013 11:31:21 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Picked Address[192.168.0.1]:5701, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5701], bind any local is true
Dec 10, 2013 11:31:22 PM com.hazelcast.system
INFO: [192.168.0.1]:5701 [dev] Hazelcast Community Edition 3.1.2 (20131120) starting at Address[192.168.0.1]:5701
Dec 10, 2013 11:31:22 PM com.hazelcast.system
INFO: [192.168.0.1]:5701 [dev] Copyright (C) 2008-2013 Hazelcast.com
Dec 10, 2013 11:31:22 PM com.hazelcast.instance.Node
INFO: [192.168.0.1]:5701 [dev] Creating MulticastJoiner
Dec 10, 2013 11:31:22 PM com.hazelcast.core.LifecycleService
INFO: [192.168.0.1]:5701 [dev] Address[192.168.0.1]:5701 is STARTING
Dec 10, 2013 11:31:24 PM com.hazelcast.cluster.MulticastJoiner
INFO: [192.168.0.1]:5701 [dev]

Members [1] {
    Member [192.168.0.1]:5701 this
}

Dec 10, 2013 11:31:24 PM com.hazelcast.core.LifecycleService
INFO: [192.168.0.1]:5701 [dev] Address[192.168.0.1]:5701 is STARTED

然后我调用java -cp hazelcast-3.1.2.jar com.hazelcast.examples.TestApp192.168.0.2并获得输出

...Dec 10, 2013 9:50:22 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Prefer IPv4 stack is true.
Dec 10, 2013 9:50:22 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Picked Address[192.168.0.2]:5701, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5701], bind any local is true
Dec 10, 2013 9:50:23 PM com.hazelcast.system
INFO: [192.168.0.2]:5701 [dev] Hazelcast Community Edition 3.1.2 (20131120) starting at Address[192.168.0.2]:5701
Dec 10, 2013 9:50:23 PM com.hazelcast.system
INFO: [192.168.0.2]:5701 [dev] Copyright (C) 2008-2013 Hazelcast.com
Dec 10, 2013 9:50:23 PM com.hazelcast.instance.Node
INFO: [192.168.0.2]:5701 [dev] Creating MulticastJoiner
Dec 10, 2013 9:50:23 PM com.hazelcast.core.LifecycleService
INFO: [192.168.0.2]:5701 [dev] Address[192.168.0.2]:5701 is STARTING
Dec 10, 2013 9:50:23 PM com.hazelcast.nio.SocketConnector
INFO: [192.168.0.2]:5701 [dev] Connecting to /192.168.0.1:5701, timeout: 0, bind-any: true
Dec 10, 2013 9:50:23 PM com.hazelcast.nio.TcpIpConnectionManager
INFO: [192.168.0.2]:5701 [dev] 38476 accepted socket connection from /192.168.0.1:5701
Dec 10, 2013 9:50:28 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.0.2]:5701 [dev]

Members [2] {
    Member [192.168.0.1]:5701
    Member [192.168.0.2]:5701 this
}

Dec 10, 2013 9:50:30 PM com.hazelcast.core.LifecycleService
INFO: [192.168.0.2]:5701 [dev] Address[192.168.0.2]:5701 is STARTED

因此，多播发现通常在我的群集上起作用，对吗？5701还是发现端口吗？是38476在最后输出的ID或端口？

对于编程配置的我自己的代码，联接仍然不起作用:(

更新4，考虑了pveentjer关于使用默认配置的答案

修改后的TestApp提供输出

joinConfig{multicastConfig=MulticastConfig [enabled=true, multicastGroup=224.2.2.3, 
multicastPort=54327, multicastTimeToLive=32, multicastTimeoutSeconds=2, 
trustedInterfaces=[]], tcpIpConfig=TcpIpConfig [enabled=false, 
connectionTimeoutSeconds=5, members=[], requiredMember=null], 
awsConfig=AwsConfig{enabled=false, region='us-east-1', securityGroupName='null', 
tagKey='null', tagValue='null', hostHeader='ec2.amazonaws.com', connectionTimeoutSeconds=5}}

并在几秒钟后检测到其他成员（如果所有实例同时启动，则每个实例一次仅将自身列为成员），而

myProgram给出输出

joined via JoinConfig{multicastConfig=MulticastConfig [enabled=true, multicastGroup=224.2.2.3, multicastPort=54327, multica\
stTimeToLive=32, multicastTimeoutSeconds=2, trustedInterfaces=[]], tcpIpConfig=TcpIpConfig [enabled=false, connectionTimeoutSecond\
s=5, members=[], requiredMember=null], awsConfig=AwsConfig{enabled=false, region='us-east-1', securityGroupName='null', tagKey='nu\
ll', tagValue='null', hostHeader='ec2.amazonaws.com', connectionTimeoutSeconds=5}} with 1 members.

并且在大约1分钟的运行时间内未检测到成员（我大约每5秒计算一次成员）。

但是，如果至少一个TestApp实例在群集上同时运行，则将检测到所有TestApp实例和所有myProgram实例，并且我的程序可以正常运行。万一我一次启动TestApp，然后并行两次启动myProgram，TestApp给出以下输出：

java -cp ~/CaseStudy/jtorx-1.10.0-beta8/lib/hazelcast-3.1.2.jar:. TestApp
Dec 12, 2013 12:02:15 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Prefer IPv4 stack is true.
Dec 12, 2013 12:02:15 PM com.hazelcast.instance.DefaultAddressPicker
INFO: Picked Address[192.168.180.240]:5701, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5701], bind any local is true
Dec 12, 2013 12:02:15 PM com.hazelcast.system
INFO: [192.168.180.240]:5701 [dev] Hazelcast Community Edition 3.1.2 (20131120) starting at Address[192.168.180.240]:5701
Dec 12, 2013 12:02:15 PM com.hazelcast.system
INFO: [192.168.180.240]:5701 [dev] Copyright (C) 2008-2013 Hazelcast.com
Dec 12, 2013 12:02:15 PM com.hazelcast.instance.Node
INFO: [192.168.180.240]:5701 [dev] Creating MulticastJoiner
Dec 12, 2013 12:02:15 PM com.hazelcast.core.LifecycleService
INFO: [192.168.180.240]:5701 [dev] Address[192.168.180.240]:5701 is STARTING
Dec 12, 2013 12:02:21 PM com.hazelcast.cluster.MulticastJoiner
INFO: [192.168.180.240]:5701 [dev]


Members [1] {
    Member [192.168.180.240]:5701 this
}

Dec 12, 2013 12:02:22 PM com.hazelcast.core.LifecycleService
INFO: [192.168.180.240]:5701 [dev] Address[192.168.180.240]:5701 is STARTED
Dec 12, 2013 12:02:22 PM com.hazelcast.management.ManagementCenterService
INFO: [192.168.180.240]:5701 [dev] Hazelcast will connect to Management Center on address: http://localhost:8080/mancenter-3.1.2/
Join: JoinConfig{multicastConfig=MulticastConfig [enabled=true, multicastGroup=224.2.2.3, multicastPort=54327, multicastTimeToLive=32, multicastTimeoutSeconds=2, trustedInterfaces=[]], tcpIpConfig=TcpIpConfig [enabled=false, connectionTimeoutSeconds=5, members=[], requiredMember=null], awsConfig=AwsConfig{enabled=false, region='us-east-1', securityGroupName='null', tagKey='null', tagValue='null', hostHeader='ec2.amazonaws.com', connectionTimeoutSeconds=5}}
Dec 12, 2013 12:02:22 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] Initializing cluster partition table first arrangement...
hazelcast[default] > Dec 12, 2013 12:03:27 PM com.hazelcast.nio.SocketAcceptor
INFO: [192.168.180.240]:5701 [dev] Accepting socket connection from /192.168.0.8:38764
Dec 12, 2013 12:03:27 PM com.hazelcast.nio.TcpIpConnectionManager
INFO: [192.168.180.240]:5701 [dev] 5701 accepted socket connection from /192.168.0.8:38764
Dec 12, 2013 12:03:27 PM com.hazelcast.nio.SocketAcceptor
INFO: [192.168.180.240]:5701 [dev] Accepting socket connection from /192.168.0.7:54436
Dec 12, 2013 12:03:27 PM com.hazelcast.nio.TcpIpConnectionManager
INFO: [192.168.180.240]:5701 [dev] 5701 accepted socket connection from /192.168.0.7:54436
Dec 12, 2013 12:03:32 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] Re-partitioning cluster data... Migration queue size: 181
Dec 12, 2013 12:03:32 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.180.240]:5701 [dev]

Members [3] {
    Member [192.168.180.240]:5701 this
    Member [192.168.0.8]:5701
    Member [192.168.0.7]:5701
}

Dec 12, 2013 12:03:43 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] Re-partitioning cluster data... Migration queue size: 181
Dec 12, 2013 12:03:45 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] All migration tasks has been completed, queues are empty.
Dec 12, 2013 12:03:46 PM com.hazelcast.nio.TcpIpConnection
INFO: [192.168.180.240]:5701 [dev] Connection [Address[192.168.0.8]:5701] lost. Reason: Socket explicitly closed
Dec 12, 2013 12:03:46 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.180.240]:5701 [dev] Removing Member [192.168.0.8]:5701
Dec 12, 2013 12:03:46 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.180.240]:5701 [dev]

Members [2] {
    Member [192.168.180.240]:5701 this
    Member [192.168.0.7]:5701
}

Dec 12, 2013 12:03:48 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] Partition balance is ok, no need to re-partition cluster data... 
Dec 12, 2013 12:03:48 PM com.hazelcast.nio.TcpIpConnection
INFO: [192.168.180.240]:5701 [dev] Connection [Address[192.168.0.7]:5701] lost. Reason: Socket explicitly closed
Dec 12, 2013 12:03:48 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.180.240]:5701 [dev] Removing Member [192.168.0.7]:5701
Dec 12, 2013 12:03:48 PM com.hazelcast.cluster.ClusterService
INFO: [192.168.180.240]:5701 [dev]

Members [1] {
    Member [192.168.180.240]:5701 this
}

Dec 12, 2013 12:03:48 PM com.hazelcast.partition.PartitionService
INFO: [192.168.180.240]:5701 [dev] Partition balance is ok, no need to re-partition cluster data...

我在TestApp的配置中看到的唯一区别是

config.getManagementCenterConfig().setEnabled(true);
        config.getManagementCenterConfig().setUrl("http://localhost:8080/mancenter-"+version);

for(int k=1;k<= LOAD_EXECUTORS_COUNT;k++){
    config.addExecutorConfig(new ExecutorConfig("e"+k).setPoolSize(k));
}

所以我也拼命尝试将其添加到myProgram中。但这并不能解决问题-仍然每个实例在整个运行过程中仅将自身检测为成员。

关于myProgram运行多长时间的更新

程序运行时间是否可能不够长（如pveentjer所说）？

我的实验似乎证实了这一点：如果到初始化之间的时间 t
（即不再通过hazelcast通信并且不再检查成员数）为Hazelcast.newHazelcastInstance(cfg);``cleanUp()

  • 少于30秒，没有沟通， members: 1
  • 超过30秒：找到所有成员并进行通信（奇怪的是，发生时间比 t -30秒要长得多）。

30秒钟是hazelcast群集所需的实际时间跨度，还是发生一些奇怪的事情？这是来自同时运行的4个myPrograms的日志（对于实例1和实例3，寻找hazelcast成员重叠30秒）：

instance 1: 2013-12-19T12:39:16.553+0100 LOG 0 (START) engine started 
looking for members between 2013-12-19T12:39:21.973+0100 and 2013-12-19T12:40:27.863+0100  
2013-12-19T12:40:28.205+0100 LOG 35 (Torx-Explorer) Model  SymToSim is about to\  exit

instance 2: 2013-12-19T12:39:16.592+0100 LOG 0 (START) engine started 
looking for members between 2013-12-19T12:39:22.192+0100 and 2013-12-19T12:39:28.429+0100 
2013-12-19T12:39:28.711+0100 LOG 52 (Torx-Explorer) Model  SymToSim is about to\  exit

instance 3: 2013-12-19T12:39:16.593+0100 LOG 0 (START) engine started 
looking for members between 2013-12-19T12:39:22.145+0100 and 2013-12-19T12:39:52.425+0100  
2013-12-19T12:39:52.639+0100 LOG 54 (Torx-Explorer) Model  SymToSim is about to\  exit

INSTANCE 4: 2013-12-19T12:39:16.885+0100 LOG 0 (START) engine started 
looking for members between 2013-12-19T12:39:21.478+0100 and 2013-12-19T12:39:35.980+0100  
2013-12-19T12:39:36.024+0100 LOG 34 (Torx-Explorer) Model  SymToSim is about to\  exit

只有在hazelcast群集中存在足够的成员之后，如何才能最好地启动我的实际分布式算法？我可以通过hazelcast.initial.min.cluster.size编程设置吗？https://groups.google.com/forum/#!topic/hazelcast/sa-
lmpEDa6A这样的声音会阻塞，Hazelcast.newHazelcastInstance(cfg);直到达到initial.min.cluster.size。正确？不同实例将如何同步（在哪个时间段内）解锁？


问题答案：

显然，问题在于集群启动（和停止）并且没有等到集群中有足够的成员。您可以设置hazelcast.initial.min.cluster.size属性，以防止发生这种情况。

您可以使用以下方式以编程方式设置“ hazelcast.initial.min.cluster.size”：

Config config = new Config(); 
config.setProperty("hazelcast.initial.min.cluster.size","3");


 类似资料：
  • 如何以编程方式为多播发现机制配置hazelcast？

    如何以编程方式为多播发现机制配置hazelcast？ 详情： 该文档仅提供了TCP/IP的一个示例，并且已经过时：它使用Config。setPort（），它已不存在。 我的配置看起来像这样，但发现不工作（即。我得到输出： 如果我对多播超时进行了摸索，我要么得到，要么 12月05, 2013 8:50:42PMcom.hazelcast.nio.ReadHandler警告：[192.168.0.9]

  • 如何以编程方式正确配置log4j2？

    我正在尝试使用设置log4j2以写入日志。我希望以编程方式配置日志记录系统，而不是使用XML文件。 以下是我尝试过的内容（大部分与网站上的文档相同）https://logging.apache.org/log4j/2.x/manual/customconfig.html#Configurator): 我在main方法的开头调用方法。当我运行我的程序时，会创建一个名为的文件，但是所有日志输出都会转到

  • 如何在Android上以编程方式配置VPN？

    我需要实现一个Android应用程序，允许用户配置VPN连接，而无需访问Android设备的本机菜单。我有两个问题： > 在Android 4.0（api级别14及以上）中，我发现有一个名为VpnService的新组件，它提供了一个钩子来创建虚拟网络接口，配置它，并从它拦截/转发包到VPN服务器，但是有没有像PPTP或IPSec这样的内置vpn协议，只有实现它们的可能性。我的问题是PPTP和IPS

  • 以编程方式配置LogBack appender

    我在logback.xml中定义了一个logback appender，它是一个DB appender，但是我想知道是否有任何方法可以使用我自己定义为bean的连接池在java中配置appender。 我发现了类似的事情，但从来没有真正的答案。

  • 如何以编程方式触发ngClick

    问题内容： 我想在运行时触发一个元素，例如： 要么 如何才能做到这一点？ 问题答案： 语法如下： 有关Angular Extend方式的更多信息，请参见此处。 如果使用的是 旧版本的angular ，则应使用 trigger 而不是 triggerHandler 。 如果需要应用停止传播，则可以按以下方式使用此方法：

  • 如何以编程方式设置layout_gravity？

    问题内容： 我的问题很简单 如何以编程方式设置我的按钮layout_gravity？ 我在互联网上找到了它，但它只是抛出了一个Nullpointer异常： 有什么办法吗？ 问题答案： Java Kotlin 有关重力值以及如何设置重力，请检查“重力”。 基本上，您应该选择依赖于父项。可以是等等。

相关阅读

如何以编程方式触发Bootstrap模式？如何以编程方式将Android置于待机状态？是否可以以编程方式配置JAXB？以编程方式发现公共IP如何以编程方式设置-Dorg.apache.el.parser.COERCE_TO_ZERO = false

相关文章

发广播 --- 华为od刷题并发编程中的10个坑以及对应的解决方案Java并发编程教程Kafka为何要设计缓冲池机制？Java在远程方法中使用反射机制

相关问答

使用ConfigurationBuilder以编程方式配置Log4j2Spring Boot以编程方式设置配置文件以编程方式配置Spring Boot应用程序如何以编程方式圆角和设置随机背景色以编程方式将POJO转到@配置Spring

相关工具

iOS 多线程编程实例Mac 开发配置手册《函数式编程指南》C++ 并发编程指南瀑布效果，不同的实现方式

相关文档

积木编程官方开发手册Erlang 并发编程C++并发编程Java 并发编程学习计算机编程
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.