java - Apache 点燃: caching ClusterGroup

Question

我想向服务器节点发送消息。缓存 ClusterGroup 是否正确，即建议使用什么选项:

1. ignite.message(ignite.cluster().forServers()).send(...)
2. ignite.message(cachedCluster.forServers()).send(...)
3. ignite.message(cachedClusterGroup).send(...)
4. cachedMessaging.send(...)

？

Answer 1

您可以选择任何您觉得舒服的选项。您可以轻松检查:启动 N 个节点的集群并检查这些组的内容，设置这两个变量:

IgniteCluster cluster = ignite.cluster();
ClusterGroup clusterGroup = cluster.forServers();

此后，关闭一个节点并检查以下内容:

ignite.cluster().forServers().nodes()
cluster.forServers().nodes()
clusterGroup.nodes()

它们中的每一个都将包含输出中列出的 N-1 个节点，因此您可以开始了。