问题标签 [gossip]

我正在阅读 akka 文档，并在理解他们实现Gossip的方式时遇到了一些麻烦。（此处的文档）。让我感到困惑的部分，（强调我的）：

周期性地，默认是每 1 秒，每个节点选择另一个随机节点来发起一轮八卦。如果少于 1/2 的 节点驻留在已看到的集合中（已看到新状态），则 集群会闲聊 3 次，而不是每秒一次。这种调整后的八卦间隔是在状态变化后的早期传播阶段加速收敛过程的一种方式。

因此，如果八卦轮处于开始阶段（少于 1/2 个节点已经看到当前状态），则来自所见集合的节点开始每秒发送 3 个八卦，而不是一个。但是，如果八卦收敛发生了，他们怎么知道（他们仍然保持每秒发送 3 次八卦）。或者，可能会像任何其他“集群事件”一样在整个集群中传播收敛？

我正在阅读gossip akka cluster文档，但对 gossip 仍有一点误解。

正如在这个答案中所说，两个节点正在八卦这个值，然后谁看到了这个值。但这带来了一些关于收敛的问题。这是我的看法：

S - 是一个可见集。

问题是在某个时候，只有节点 4知道发生了收敛。节点 1、2 和 3 仍然认为没有。我对节点 4 应该如何处理收敛很感兴趣？

它是否应该发起新一轮的流言蜚语，说收敛已经发生了？或者其他节点怎么知道呢？

当前设置，cassandra 2.2.5，gossip 默认为 1 秒，phi 阈值为 8。我面临的问题是提示中的尖峰。提示上升的原因之一是节点被标记为关闭（八卦尚未传达 phi 阈值）。

我读过一篇文章，它说 phi 阈值 8 对应于 18 秒，这里或那里将是几秒钟。现在我需要了解是什么原因，是什么阻止了八卦交流 18 秒。八卦沟通需要满足哪些清单？

我对使用 Akka 的分布式发布订阅集群功能来发布通过集群发送的消息很感兴趣。使用 DistributedPubSubMediator.Publish 时，消息是使用全网状网络拓扑广播到所有主题订阅者，还是使用 gossip 优化使用部分网络网格的已发布消息的传播？提前谢谢你

集群中的分布式发布订阅

http://doc.akka.io/docs/akka/current/java/distributed-pub-sub.html

我构建了一个分布式系统，其中不同的节点可以是领导者或跟随者。在大多数用例中，我只有一个领导者和几个追随者。领导者通常在其服务器上是单一的，而追随者则在其他服务器上运行（其中一些在同一个 JVM 中）。

追随者节点永远不必相互发送消息，它们只会与领导者节点通信。目前，我使用tcpgossip协议来发现集群的成员。我的 GossipRouter 在与领导节点相同的 JVM 中运行。它实际上工作得很好，我的集群似乎足够稳定。

据我了解tcpgossip协议，每个节点都伸出 GossipRouter 并从中获取信息。所以在我的例子中，所有的追随者节点都会联系运行领导者节点的服务器。但是，当我关闭其中一个追随者节点时，我可以看到来自其他追随者节点的警告消息：

警告：thread=TransferQueueBundler、myCluster、ROCKET-21632 Fri Nov 18 10:22:11 CET 2016 org.jgroups.protocols.BaseBundler sendSingleMessage JGRP000029：ROCKET-21632：向 zeus-10187（102 字节）发送消息失败：java.net .SocketTimeoutException：连接超时，标头：VERIFY_SUSPECT：[VERIFY_SUSPECT：ARE_YOU_DEAD]，TP：[cluster_name=myCluster]

警告：thread=TransferQueueBundler，myCluster，ROCKET-21632 Fri Nov 18 10:21:19 CET 2016 org.jgroups.protocols.TP sendToMembers JGRP000034：ROCKET-21632：向 zeus-10187 发送消息失败：java.net.SocketTimeoutException：connect时间到

哪里ROCKET-21632和zeus-10187是两个追随者。我预计追随者不会互相交谈，因为使用了 GossipRouter，但似乎并非如此。

有没有办法建立一个集群，其中一些节点永远不会相互通信？

PeerAwareInstanceRegistryImpl会在注册发生变化时同步到其他peer，代码如下：

我对多个 eureka 服务器的分布式一致性感到困惑。当复制操作失败时。它只是捕获了 throwable。为什么不使用 gossip、paxos 等一致性算法来保证更高的一致性呢？

我看到了wiki的描述，知道 eureka 只是让它暂时不一致。服务器试图尽可能有弹性。啊哈上限理论！

我在运行时使用akka集群我收到这样的日志

如何禁用此日志？

我想在两个系统上设置复制。所以，需要相同的建议。我有以下疑问：-

1）是否可以在两台物理机上设置复制？
2）如果是，键空间模式应该是什么？
3) 创建密钥空间 ums_db WITH replication = {'class': 'NetworkTopologyStrategy', 'DC1': '3', 'DC2': '3'} ;

上述模式是什么意味着我需要 6 台物理机或仅 2 台物理机，其中 3 个节点在逻辑上创建以在每个物理数据中心上存储数据副本？

4) 使用 2 台物理机创建复制的最佳模式是什么，所有文件需要更改以及如何更改？

谢谢，

我知道一个快速的谷歌拥有大量的结果，关于这个主题的文献非常丰富，这正是问题所在。在众多可能的解决方案中，我不确定哪个具体是满足我特定需求的最佳、最新选择。

我正在尝试在互联网上实现一个 p2p 网络，它具有向在线节点广播消息的唯一和一个功能。为了连接到网络，您必须能够指向现有 IP。当你这样做时，你会发现一些对等点并与他们保持积极的联系。然后，您可以将消息发送到每个其他节点。没有直接的沟通，发送的每条消息都会被其他人接收。我希望这个网络尽可能高效，并在 UDP 之上工作。

在此处指定的形状上解决此问题的一些最先进算法的名称是什么？

我正在阅读有关八卦式故障检测的信息。

在我正在阅读的笔记中指出：a single heartbeat takes O(log(N)) time to propagate但未解释此声明

知道这是为什么吗？