問題タブ [akka-cluster]

Akka を使用して Dynamo のようなデータベースを構築しようとしています。

ヒントは、こちらの Akka Cluster 仕様に記載されていますhttp://doc.akka.io/docs/akka/2.0/cluster/cluster.html

読み取り書き込みレプリカを実装する方法は?

Single System データ ブローカーを実装しました。レポはこちらですhttps://github.com/pamu/AkkaDynoDB

メッセージ ブローカー サーバーからそのストリーミングにアクセスしたいユーザーにデータをストリーミングする方法について、ガイダンスまたは手がかりが欲しいです。

このストリーミングは json データに基づいています。scala の play フレームワークを使用しています。

使用するには何を考慮する必要がありますか？あか？サブスクライブ パターンを公開しますか? Websocket を使用する必要がありますか?

解決策を見つけるのに苦労していますが、まだプレイ コミュニティのドキュメントに慣れていません。どんな助けや手がかりも大歓迎です。

https://stackoverflow.com/questions/29076584/streaming-jsons-objects-from-apache-spark-streaming-to-play-frameworkでこのシナリオについて以前に質問し ましたが、これまでのところ回答がありません。

app1 と app2 という 2 つのアプリケーションがあります。マシン 1 では app1 と app2 の両方が実行されますが、ほとんどの作業は app2 によって行われるため、マシン 2 では app2 のみが実行されます。アプリは Akka を使用します。

akka remoting を使用して、マシン 1 の app1 からマシン 2 の app2 にメッセージを渡すことができるようにしたいと考えています。 app1 と 2 は、同じマシン上にある場合に相互に対話できます。

ただし、マシン 1 のアプリ 1 がマシン 2 のアプリ 2 に接続しようとすると、エラーが発生します...

EndpointWriter - AssociationError [akka.tcp://deal-rest@127.0.0.1:4242] -> [akka.tcp://deal@:4241]: エラー [無効なアドレス: akka.tcp://deal@:4241] ] [ akka.remote.InvalidAssociation: 無効なアドレス: akka.tcp://deal@:4241 原因: akka.remote.transport.Transport$InvalidAssociationException: 接続が拒否されました: /:4241

netstat -a | を実行すると マシン 2 で egrep 'Proto|LISTEN' を実行すると、応答 tcp6 0 0 localhost:4241 [::]:* LISTEN を下回りました。

これは、app2 が実行中であり、4241 でリッスンできることを示しています。

また、ポート 4241 はマシン 1 と 2 で開いています。

どんな提案も役に立ちます。ありがとう。

私は akka クラスターを使用していますが、Terminated メッセージを使用してメンバーがクラスターを離れたことを確認するタイミングと、UnreachableMember/MemberRemoved メッセージを使用するタイミングがわかりません。2 つのメッセージと使用例の違いは何ですか?