jgroups

0热度

1回答

有时我需要发送消息到频道，我不在乎频道是否有任何成员，并且消息会丢失。是否可以发送消息到频道而无需加入？

0热度

1回答

最近我尝试使用JGroup创建一个集群，以便连接到同一个集群的不同机器能够在彼此之间交换消息。我试过我的本地主机（2个Java应用程序）之间的简单聊天应用程序，它的工作原理没有问题，即它们能够在彼此之间接收和发送消息。这里是场景 PC 1：由一java的模块（接收器）服务器2（模块使用jgroup驻留在此服务器）的：发件人我的下一步骤是移动所述发送者（的创建者群集）到另一个子网，但仍然在同

0热度

1回答

协调器状态在Infinispan群集中不可用

我们在我们的一个设置中使用带有jgroups-tcp配置的Inifinispan群集。有时候我们注意到jconsole中的协调器状态显示为不可用，但这不影响任何功能。然而，我只是好奇，为什么状态显示为不可用。任何指针将不胜感激。

1热度

1回答

JGroups与TCPPING（静态对等列表）

我想有我的Java应用程序的一些实例互相合作。我尝试过使用JGroups，但没有成功。我没有使用JBoss，只是简单的JGroups库4.0.3。我试图做两个实例互相连接的'最小工作示例'。我按照单台机器进行测试。一旦我运行了我的应用程序的两个实例，我期望的是他们将打印他们自己和对方的地址。我得到的是他们只是打印他们自己的地址。看起来他们没有设法连接到另一个。这才是我的Java代码： imp

0热度

1回答

jGroups没有找到其他电脑

我正在使用jGroups来确定我的应用程序的多个实例的主人，但是，所有人都在同一台计算机上工作得很好，但同一子网上的其他计算机没有得到收到通知。我尝试了很多我在网上找到的选项，例如以-Djgroups.bind.addr = 开头我还在不同的机器（Windows）上启动了两个实例，而另一台机器未收到通知： java -cp jgroups- 4.0.3.Final.jar -Djgroups.bi

0热度

2回答

将CommandGateway的所有事件路由到单个事件处理程序

我正在使用AxonFramework实现JGroups，我指的是this链接。我在代码中做了一些更改，并在没有Docker的情况下运行该项目。以下是我的代码 - 主类 - public class ClusterRunner { public static void main(String[] args) { Thread t1 = new Thread(new Prim

0热度

3回答

如何在Inifinispan下为Jgroup编写健康检查？

所以我们有一个问题，渗透检查器运行12小时之类的东西导致Jgroups断开连接，然后它不能恢复。显然我们需要fix Jgroups so that it does recover，但是如果Jgroups关闭，我也不希望负载平衡器将它视为服务器已启动。我已经想出了如何与负载平衡器进行通信，但我在解决如何实际检查通道通信的健康状况方面存在问题，特别是因为它是Infininispan，它负责创建它们（

0热度

1回答

警告：JGRP000014：Discovery.timeout已被弃用：应该使用GMS.join_timeout

WARNING: JGRP000014: Discovery.timeout has been deprecated: GMS.join_timeout should be used instead 为什么我得到这个，如果它没有直接由我定义？至少我不认为它是，看起来我们正在使用的GMS.join_timeout 这里的这个人是如何配置的 log().info( "Starting

0热度

1回答

JGroups互联网配置

我已经成功地通过不同的机器使用TCP在本地网络上工作的JGroups，我无法使用多播。我需要两个节点通过互联网进行通信的能力。将地址更改为公共地址似乎不起作用，并且需要额外的配置。我看过http://www.jgroups.org/manual-3.x/html/protlist.html 并设置external_addr，但也许有更多的设置。如何设置它以通过公共地址进行通信？配置： <co

0热度

1回答

JGroups状态转移地址键映射

我正在将使用JGroups 3.6.6的应用程序迁移到JGroups 4.0.2。 JGroups 3.6.6中的'Address'类型是可序列化的，但由于安全原因，它已在JGroups 4.0.2中进行了Streamable。由于这个原因，我在国家转移期间遇到了问题。这是我用来进行国家转移的班级。 public class State implements Streamable { /**