19 Coherenceトピックの概要

ここでは、Oracle Coherence 14.1.1.0.0でのパブリッシュおよびサブスクライブ・メッセージング機能について説明します。

この章の内容は次のとおりです。

• トピックの概要
  トピックAPIを使用すると、疎結合プロデューサとコンシューマ間にデータ・パイプラインを構築できます。

トピックの概要

トピックAPIを使用すると、疎結合プロデューサとコンシューマ間にデータ・パイプラインを構築できます。

1つ以上のパブリッシャがトピックに値のストリームをパブリッシュします。1対多サブスクライバは、トピックへの値のストリームを消費します。トピック値はすべてのOracle Coherenceデータ・サーバーに均等に分散されており、分散形式およびフォルト・トレラント形式での高スループット処理が可能です。トピックに対する各直接サブスクライバは、トピックにパブリッシュされたすべての値を受信します。

図19-1 トピック値

「図19-1 トピック値」の説明

パブリッシュおよびサブスクライブ・メッセージングでは、メッセージはトピックのアクティブ・サブスクライバにのみ配信されます。サブスクライバ・グループは、キュー処理機能をトピックに追加します。あるトピックでサブスクライバ・グループを作成すると、そのトピックに送信される値はすべてサブスクライバ・グループに蓄積されます。1つ以上のサブスクライバがサブスクライバ・グループをサブスクライブできます。サブスクライバ・グループによって蓄積された値のストリームの場合、各値はサブスクライバ・グループ・メンバーの1つに対してのみ配信されるので、これらの値の分散パラレル処理が可能になります。

ノート:

基本的なトピック操作の例は、「基本的なトピック・パブリッシュおよびサブスクライブ操作の実行」を参照してください。

図19-2 サブスクライバ・グループ内のトピック値

「図19-2 サブスクライバ・グループ内のトピック値」の説明