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 { /**