問題タブ [jgroups]

JGroupsを使用するInfinispanを使用しています

Windows プラットフォームでコードを実行すると、問題なく動作します。

しかし、Linux で実行すると、次の例外が発生します。

java.net.PlainDatagramSocketImpl.send(Native Method)[:1.7.0_17] での検出要求の送信に失敗しましたMPING.sendMcastDiscoveryRequest(MPING.java:300)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.Discovery.sendDiscoveryRequest(Discovery.java:259)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.Discovery.sendDiscoveryRequest(Discovery.java:259)[143:xxxx:2.0.0.SNAPSHOT] org.jgroups.protocols.Discovery.findMembers(Discovery.java:216)[143:xxxx:2.0] .0.SNAPSHOT] at org.jgroups.protocols.Discovery.findAllViews(Discovery.java:203)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.Discovery.down(Discovery.java:527) [143:xxxx:2.0.0.SNAPSHOT] org.jgroups.protocols.MERGE2$FindSubgroupsTask.findAllViews(MERGE2.java:326)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.MERGE2$FindSubgroupsTask._findAndNotify(MERGE2.java:261)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.MERGE2$FindSubgroupsTask.findAndNotify(MERGE2.java:249) )[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.protocols.MERGE2$FindSubkgroupsTask$1.run(MERGE2.java:226)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.util. TimeScheduler2$RecurringTask.run(TimeScheduler2.java:603)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.util.TimeScheduler2$MyTask.run(TimeScheduler2.java:535)[143:xxxx:2.0.0 .SNAPSHOT] at org.jgroups.util.TimeScheduler2$Entry.execute(TimeScheduler2.java:440)[143:xxxx:2.0.0.SNAPSHOT] at org.jgroups.util.TimeScheduler2$1.run(TimeScheduler2.java:297) )[143:xxxxx:2.0.0.SNAPSHOT] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_17] java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_17]

どうすればこれを達成できますか

JBoss アプリケーション サーバーで Jgroups を使用するためのコードの基本的な例はどこにありますか。Jboss アプリケーション サーバー (バージョン 7 または 6) には、JGroups (カスタリングに使用) が同梱されています。サーバーからサーバーへのメッセージングを行うために、この jgroups モジュールを再利用したいだけです。

多数のノードを持つ JVM で分散アプリケーションを作成したいと考えており、次のことを可能にするライブラリが必要です。

• クラスター/グリッド メンバーシップを管理します。つまり、脱退/参加時に通知を受け取りたい
• クラスタ メンバー間のメッセージを管理する

私は2つの解決策を見つけました：

• JGroups - 機能しますが、日付のように見え、広く使用されていません
• Akka - Scala ベースであり、そのクラスター モジュールは成熟していないように見えます

同じことができる他のライブラリはありますか？

次のことを行う Java クライアント/サーバー アプリケーションを作成したいと考えています。

• クライアントは 2 つのサーバーのうちの 1 つに接続します
• サーバーがテキスト ファイルまたはそのコンテンツをクライアントに送信する
• ユーザーがファイルを編集する
• クライアントはファイルを両方のサーバーに同時に確実に送り返します
• クライアントがアプリケーションを閉じる

おまけ: これらのサーバーの 1 つが送信時にダウンしている可能性があるため、起動時にファイルを受信する必要があります。

これを可能にするには、どのアーキテクチャまたはフレームワークが適切で軽量ですか? JGroups は良いスタートですか?

編集:次の最小限のネットワークを想定する必要があります。

• 1 つ以上のクライアントがアプリケーションを開始しますが、同時にファイルを編集することは許可されていません。
• 1 つ以上のサーバーがあり、そのうち少なくとも 1 つが常にアクティブです (どれがランダムか)。
• クライアントには、すべてのサーバー アドレスを含む .xml ファイルがあります。

こんにちは、デフォルトの Jgroups-UDP 構成を使用して infinispan サーバー 6.0.0.CR1 の 2 つのインスタンスを実行しましたが、クラスター形成が見られません。デフォルトの Jgroups UDP 構成インターフェイスを更新して、ループ バック アドレスではなくマシン IP を指すようにしました。

Machine1 からのログ:

マシン 2 からのログ:

最初のマシンからの ifconfig:

コマンドが見つかりません

2 台目のマシンからの ifconfig:

そのため、apache の背後に 2 つの jboss ノードをセットアップし、クラスタリングを有効にして、ehcache 同期をセットアップしました。両方のノードが実行されている状態で、リクエストを受信しなかったノードで次の例外が発生します。

以下は、私のehcache.xmlがどのように見えるかです:

最後に、これは私が両方のノードを実行する方法です:

./run.sh -c all -g myCluster -Djboss.default.jgroups.stack=tcp -Djgroups.tcpping.initial_hosts=10.166.17.52[7600],10.166.17.53[7600] -Djboss.messaging.ServicePeerId=1 - Djgroups.bind_addr=10.166.17.52 -Djboss.node.name=node1 -b 0.0.0.0

と

./run.sh -c すべて -g myCluster-Djboss.default.jgroups.stack=tcp -Djgroups.tcpping.initial_hosts=10.166.17.52[7600],10.166.17.53[7600] -Djboss.messaging.ServicePeerId=2 - Djgroups.bind_addr=10.166.17.53 -Djboss.node.name=node2 -b 0.0.0.0

サーバーは互いに通信しようとしています。それらが同じクラスターにあるかどうかはわかりません。どんな助けでも大歓迎です。

JGroups の使用を検討しており、目的に適した構成を評価しようとしているときに、標準の udp.xml 構成 (およびそのバリエーション) に FD_SOCK と FD_ALL の両方が指定されていることに気付きました。標準の UDP ベースのクラスター メッセージング構成には、両方が本当に必要ですか?

FD_SOCK を使用すると、より迅速に障害を検出できると思いますが、それが唯一の利点ですか? そう仮定すると、なぜ FD_ALL が必要なのですか? (FD_SOCK は隣接ノードが停止している場合にのみ通知しますが、FD_ALL はクラスター全体を対象としているのでしょうか?)

基本的に、私はそれぞれの長所/短所を理解しようとしているだけで、プロトコルの1つを削除して物事をできるだけシンプルにすることが理にかなっている.

前もって感謝します！スコット

jgroups プログラムで TCP プロトコルを使用しており、FD_ALL.timeout を 12000ms FD_ALL.interval=4000ms に設定しています。のようなコードを送信する

次のような RequestHandler コード:

メッセージの処理に 12000 ミリ秒以上かかる場合があります。私の質問は、タイムアウトになるまでハートビートパケットをブロックするのはいつですか? viewAccepted イベントがそのピアの左側を示すようにしますか?