リモート処理

プログラム導入

動的に展開されているシステムを許可することも可能ですの配置構成が含まれる、: クラス: アクターを作成に使用される ' 小道具': この情報は、構成ファイルから展開部と同等と、両方がある場合外部構成が優先されます。

これらのインポート。

import akka.actor.ActorRef;
import akka.actor.Address;
import akka.actor.AddressFromURIString;
import akka.actor.Deploy;
import akka.actor.Props;
import akka.actor.ActorSystem;
import akka.remote.RemoteScope;

このようなリモート アドレス:

Address addr = new Address("akka.tcp", "sys", "host", 1234);
addr = AddressFromURIString.parse("akka.tcp://sys@host:1234"); // the same

リモート ノードに子を作成するシステムをお勧めすることができます次のよう。

ActorRef ref = system.actorOf(Props.create(SampleActor.class).withDeploy(
  new Deploy(new RemoteScope(addr))));

障害検出器

フードの下でリモート死の時計は、ネットワークの障害見た俳優の優雅な契約の終了に加えて、JVM クラッシュから '終了' のメッセージを生成するのにハートビート メッセージとエラー検出器を使用します。

ハートビートの到着時刻は、_ '、ピピ発生障害検出器 < http://www.jaist.ac.jp/~defago/files/pdf/IS_RR_2004_010.pdf >' の実装によって解釈されます。

障害の疑いレベルですと呼ばれる値で与えられた * ピピ *。ピピ障害検出器の基本的な考え方は、の値を表現する * ピピ * 動的に現在のネットワークの状態を反映するように調整はスケールで。

値 * ピピ * として計算されます。

phi = -log10(1 - F(timeSinceLastHeartbeat))

ここで F は平均と歴史的なハートビート相互到着時間から推定した標準偏差の正規分布の累積分布関数です。

: Ref:' 構成-java リモート '、' akka.remote.watch-障害-detector.threshold ' 時期を定義するを調整することができます、* ピピの値はエラーと見なされます。

低「しきい値」は多くの偽陽性を生成する傾向がある実際クラッシュが発生した場合迅速な検出を保証。逆に、高「しきい値」は、間違いを少なくを生成しますが、実際のクラッシュを検出するより多く時間必要があります。既定の「しきい値」10 を、ほとんどの状況に適したです。しかし Amazon EC2 のようなクラウド環境の値まで引き上げられるだろう 12 プラットフォームでこのような時に発生するネットワークの問題に対応するために。

次のグラフを示していますどのように * ピピ * 以前のハートビートから時間の増加とともに増加します。

ピピは平均から計算され、歴史の標準偏差間の到着時間。以前は 200 さんハートビート到着少ない偏差曲線の場合の標準偏差の例が急になる、すなわち障害をよりすばやく判断することが可能です。カーブは 100 ms の標準偏差を求めるようになります。

ガベージ コレクションの休止や障害検出器が、余裕を持って構成されている一時的なネットワーク エラーなどの突然の異常を生き残るためにできるように ' akka.remote.watch-障害-detector.acceptable-ハートビート-ポーズ」。調整したい場合があります、: ref:' リモート構成-java' この場合環境によって。これはどのようにカーブの「許容-ハートビート-一時停止 '' 3 秒に設定されているようです。

Java シリアライザーを無効にします。

リリース '2.4.11 ' 以降安家のデフォルト Java シリアル化機構を完全無効にすることが可能です。注意してください: ref:' 新しいリモート処理の実装 (コードネーム動脈) <remoting-artery-java>' 既定で内部メッセージの Java シリアル化は使用しません。互換性の理由から、まだ現在のリモート処理は、いくつかのクラスの Java シリアル化を使用するためしかし無効にできますそれこのリモート処理実装でも以下の手順で。

Java シリアル化は遅くなること知られているであり、さまざまな種類の攻撃を受けやすいそれ決して高スループット メッセージングすべての後。しかし、それは非常に使い便利、従ってそれ残った安家ユーザー メッセージだけでなく、いくつかの以前のバージョンでその内部メッセージをシリアル化するために使用する既定のシリアル化機構です。動脈のリリース以来安家内部 Java シリアル化もう (' java.lang.Throwable ' をされている 1 つの例外) に依存しないでください。

ユーザー メッセージの Java シリアル化を使用して実装されている既定のシリアライザーと動脈で有効なままになります。しかしそれを完全に無効にし、効果的に順序の代わりに適切なシリアル化ライブラリを利用をお勧めします利用パフォーマンスの向上と動脈を使用した展開を圧延のための能力を行います。使用するをお勧めしますライブラリなどがあなたのメッセージのスキーマの展開をより細かく制御したい場合に、'Kryo' _ _ 'Akka kryo-シリアル化' ライブラリを使用してまたは 'Google のプロトコルバッファー' _ に限定されません。

俳優システムで Java シリアル化を完全に無効にするために、'application.conf ' に次の構成を追加する必要があります。

akka {
  actor {
    serialization-bindings {
      "java.io.Serializable" = none
    }
  }
}

つまりは、すべてのリモート メッセージを処理することが異なるシリアライザーを構成する必要があるのでご注意ください。参照してください、: ref:' シリアル化スカラー座 ' ドキュメントと同様: ref: 'ByteBuffer ベース シリアル化 <remote-bytebuffer-serialization-scala>' これを行う方法を学習します。

Java のシリアル化を使用していない安家によって提供される追加のシリアルのバインドも簡単にできます。

これらは既定で有効になっていない理由は、2.4.x 俳優システム間線レベルの互換性です。新しいクラスターを展開する場合すべてこれらのシリアライザーを有効にすることができます同じ安家バージョンがお勧めこの設定を有効にします。使用する場合: ref:' リモート処理-動脈スカラー ' これらのシリアライザーが既定で有効になっています。

リモートのイベント

購読/購読解除これらのイベントに、単に登録するリスナーとして、安家リモートで発生するイベントをリッスンすることが可能だ、下 'ActorSystem.eventStream ' の型を説明します。

既定では、イベント リスナーが登録されているすべての下記イベントのログします。この既定値は、システムの設定に役立つに選ばれたが、プロジェクトのフェーズが終了したら、このログ出力をオフにすることは珍しくありません。

とき、協会に通知するには、が (「切断」) の上に耳を傾ける 'DisassociatedEvent ' 方向 (受信または送信) の協会および関係者のアドレスを保持します。

関連付けが正常に確立されたときに通知するには、(「接続される」) 'AssociatedEvent ' 方向 (受信または送信) の協会および関係者のアドレスを保持するに耳を傾けます。

直接の関連付けに関連するエラーを傍受するには、関係者と「Throwable '' 原因アドレス協会の方向 (受信または発信) を保持している '' AssociationErrorEvent '' を聞きます。

リモート処理サブシステムはアソシエーションを受け入れる準備ができてとき通知を受ける、remoting がリッスンするアドレスを含む、'RemotingListenEvent ' に耳を傾けます。

リモート処理サブシステムのシャット ダウンされているときに通知する、'RemotingShutdownEvent ' に耳を傾けます。

現在のシステムは、リモート システムで検疫されたときに通知される、'ThisActorSystemQuarantinedEvent ' は、ローカルおよびリモートの ActorSystems のアドレスを含むに耳を傾けます。

ジェネリックのリモート処理をインターセプトするには、関連のエラー、'RemotingErrorEvent '' Throwable ' 原因を保持しているに耳を傾けるのです。

非信頼関係モード

俳優システムは別にリモート接続することができますとすぐにそれが原則として可能にメッセージを送ってそのリモート システム内に含まれる任意の俳優。1 つの例を送信する可能性があります、: クラス: システムのシャット ダウン、システム保護者に ' PoisonPill'。これは常に必要がないし、それを次の設定で無効にできます。

akka.remote.untrusted-mode = on

これはシステム ・ メッセージの送信を禁止 (俳優ライフ サイクル コマンド、デス ・ フロント等) および任意のメッセージ拡張: クラス: このフラグが設定されているシステムに ' PossiblyHarmful'。クライアントは、それらを送信する必要がありますそれにもかかわらず彼らは削除され (サービス攻撃の拒否の可能性を減らすためにデバッグ レベル) で記録されます。: クラス: 'PossiblyHarmful' をカバーするような定義済みメッセージ: クラス: 'PoisonPill' と: クラス: '殺す'、しかし、それも追加できますマーカーの特性としてユーザー定義のメッセージを。

俳優の選択によって送信されたメッセージは、既定で信頼関係のないモードで破棄されますが、構成で定義されている特定の俳優に俳優の選択メッセージを受信するアクセス許可を付与できます。

akka.remote.trusted-selection-paths = ["/user/receptionist", "/user/namingService"]

型の実際のメッセージする必要がありますされませんがまだ: クラス: 'PossiblyHarmful'。

要約すると、次の操作はリモート処理層を介して受信信頼関係のないモードで構成されているシステムによって無視されます。

• リモート ・ デプロイメント (これも遠隔で監視を含みません)

• リモート デス ・ フロント

• ' system.stop() ': クラス: 'PoisonPill': クラス: '殺す'

• メッセージを送信する、: クラス: 含まれています 'PossiblyHarmful' マーカー インターフェイス: クラス: '終了'

• 俳優の選択 '信頼できる選択パス' のターゲットが定義されていない場合に送信されるメッセージ。

SSL

SSL は、' akka.remote.netty.ssl 'を' 有効なトランスポート ' 構成セクションに追加することによってリモート トランスポートとして使用できます。設定の説明を参照してください、: ref:"リモート-構成-java"セクション。

網状の既定の設定の例ベースの既定値として SSL ドライバー。

akka {
  remote {
    enabled-transports = [akka.remote.netty.ssl]

    netty.ssl.security {
      key-store = "mykeystore"
      trust-store = "mytruststore"
      key-store-password = "changeme"
      key-password = "changeme"
      trust-store-password = "changeme"
      protocol = "TLSv1.2"
      random-number-generator = "AES128CounterSecureRNG"
      enabled-algorithms = [TLS_RSA_WITH_AES_128_CBC_SHA]
    }
  }
}

SSL のサポートは、Java セキュリティで保護されたソケット拡張機能で実装、トラブルシューティングの公式 'Java セキュリティで保護されたソケット拡張機能ドキュメント < http://docs.oracle.com/javase/7/docs/technotes/guides/security/jsse/JSSERefGuide.html >' _ および関連リソースを参照してください。

安家に港湾労働者コンテナー、または NAT の後ろです。

設定でネットワーク アドレス変換 (NAT)、ロード バランサーまたは港湾労働者コンテナー安家のバインド先のホスト名とポートのペアを含む「論理的な」ホスト名とは異なること、外からシステムへの接続に使用されるペアをポートします。論理とリモート処理のバインドのペアを設定する特別な構成が必要です。

akka {
  remote {
    netty.tcp {
      hostname = my.domain.com      # external (logical) hostname
      port = 8000                   # external (logical) port

      bind-hostname = local.address # internal (bind) hostname
      bind-port = 2552              # internal (bind) port
    }
 }
}