Cosminexus アプリケーションサーバ V8 機能解説 基本・開発編(コンテナ共通機能)

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0PEIEN29 譌・譛ャ譛ェ逋コ螢イ 繝悶Λ繧ヲ繧ケ 繝ッ繧、繝 髟キ陲 邯ソ豺キ 辟。蝨ー 繝薙ャ繧ー繧キ繝ォ繧ィ繝繝 繧縺」縺溘j 繝翫メ繝・繝ゥ繝ォ 繧キ繝」繝繧キ繝ウ繝励Ν 繝懊Μvn0Omy8PNw繧オ繝ォ繝エ繧。繝医シ繝ャ繝輔ぉ繝ゥ繧ャ繝「 Salvatore Ferragamo 繝エ繧。繝ゥ 驥代懊ち繝ウ 繝九ャ繝医き繝シ繝繧」繧ャ繝ウ 繧ォ繝繝医た繝シ 繧ヲ繝シ繝ォ 繝舌う繧ォ繝ゥ繝シ 繝エ繧」繝ウ繝繝シ繧ク 繧「繝シ繧ォ繧、繝 轣ー 繧ー繝ャ繝シ M NVW 0605 繝ャ繝繧」繝シ繧ケ繝吶け繝医Ν 蜿、逹200605 繝吶け繝医Ν繝励Ξ繝溘い繝蠎佑tQshrxd譛譁ー菴 莉頑悄螟ァ莠コ豌 繝吶Ο繧「繝ッ繝ウ繝斐シ繧ケ遘句ャ繝ッ繝ウ繝斐シ繧ケV繝阪ャ繧ッ螟ァ莠コ繝ッ繝ウ繝斐シ繧ケ繝峨Ξ繧ケ蛻コ郢榊・繧晦繝ゥ繧、繝ウ髟キ陲悶Α繝繧」繝ッ繝ウ繝斐シ繧ケ騾壼共繝ッ繝ウ繝斐シ繧ケ蜿ッ諢帙>繝峨Ξ繧ケ 邨仙ゥ壼シ 繝ャ繝繧」繝シ繧ケ 縺阪l縺繧 繧ィ繝ャ繧ャ繝ウ繝 繝代シ繝繧」繝シ繝峨Ξ繧ケ 20莉」 30莉」 40莉」縺雁他縺ー繧卦F3uclK1J5繝翫Α繝ェ繧「 Namilia 繝ャ繝繧」繝シ繧ケ 繝吶い繝医ャ繝励サ繝√Η繝シ繝悶ヨ繝繝励サ繧ッ繝ュ繝繝励ラ 繝医ャ繝励せ extreme crop t shirtroQCBxEdWe

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

Pub/Subメッセージングモデルは,パブリッシュ・サブスクライブ(Publish-Subscribe)方式でメッセージを送受信するためのモデルです。

<この項の構成>
繝ヲ繝翫う繝繝繝峨い繝ュ繝シ繧コUNITED ARROWS 繧ウ繝シ繝 繧「繧ヲ繧ソ繝シ 繧ケ繧ソ繝ウ繝 逋ス繝帙Ρ繧、繝 繧オ繧、繧コ L USED蜿、逹doCBex
GERVE繧ク繧ァ繝ォ繝吶が繝ォ繧ャ繝ャ繝シ繧ケ繝弱シ繧ケ繝ェ繝√Η繝九ャ繧ッ 85161TPXiOkZwu
繧オ繝九シ繧ケ繝昴シ繝 SUNNY SPORTS 繧、繝シ繧ク繝シ繝代Φ繝 繧オ繧、繧コM 繝。繝ウ繧コ TRAIL 3D PANTS 繝医Ξ繧、繝ォ繝代Φ繝 繝悶Λ繝ウMVpqUzSG
LOUIS VUITTON 繝ォ繧、繝エ繧」繝医Φ 繝「繝弱げ繝ゥ繝 繧ス繝溘Η繝シ繝ォGM M42254 繝ャ繝繧」繝シ繧ケ 繧キ繝ァ繝ォ繝繝シ繝舌ャ繧ー 1騾ア髢謎ソ晁ィシb01b h02BCnOwk0P

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

Pub/Subメッセージングモデルでは,メッセージを作成して送信する送信側のクライアント(プロデューサー)をパブリッシャーといいます。また,メッセージを受信する側のクライアント(コンシューマー)をサブスクライバーといいます。

パブリッシャーから送信されたメッセージは,トピックという送信先に登録されます。トピックに登録されたメッセージは,そのトピックに対して配信を申し込んでいた一つまたは複数のサブスクライバーに配信されます。

Pub/Subメッセージングモデルでのメッセージの流れを次の図に示します。

繝溘Η繝シ繝九ャ繧ッ Munich 繧ヲ繧ゥ繝繧キ繝・繧ウ繝繝医Φ繝ュ繝シ繝ウ 繝弱シ繧ォ繝ゥ繝シ繧キ繝」繝繝悶Λ繧ヲ繧ケ MN201T55TKl1c35uFJ 図7-6 Pub/Subメッセージングモデルでのメッセージの流れ

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

メッセージは,パブリッシャーから送信され,トピックに登録されます。図の場合,トピック1にはサブスクライバー1,トピック2にはサブスクライバー2とサブスクライバー3が登録されています。このとき,トピック1に登録されたメッセージ1とメッセージ2はサブスクライバー1に配信されます。トピック2に登録されたメッセージ3はサブスクライバー2とサブスクライバー3に配信されます。

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

Pub/Subメッセージングモデルの特徴を次に示します。

メッセージの送信〜処理実行までの特徴

システムの特徴
  • パブリッシャーとサブスクライバーは動的に追加・削除できます。これによって,使用状況に応じてシステムを拡張,縮小できます。
  • Cosminexus JMSプロバイダとの接続で使用するコネクションは,複数のプロデューサーで共有できます。なお,コネクションを共有しているかどうかに関係なく,複数のプロデューサーから同じのトピックにメッセージを送信できます。
  • Cosminexus JMSプロバイダとの接続で使用するコネクションは,複数のサブスクライバーで共有できます。なお,コネクションを共有しているかどうかに関係なく,複数のサブスクライバーから同じトピックに接続できます。

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

トピックに登録されたメッセージは,メッセージ登録時に開始されていたサブスクライバーだけが受信できます。通常のサブスクライバーは,停止していた期間に登録されたメッセージは受信できません。

これに対して,サブスクライバーを永続化することで,停止していた期間に登録されたメッセージも受信できるようになります。永続化したサブスクライバーを永続化サブスクライバーといいます。

永続化サブスクライバーが登録されたトピックのメッセージは,次のどちらかの状態になるまで削除されません。

永続化サブスクライバーを利用する場合,そのサブスクライバーに固有の識別子と名称を登録します。登録した情報は,CJMSPブローカーによって保持されます。永続化サブスクライバーが停止しているときに登録されたメッセージは,登録した識別子および名称のサブスクライバーが再開されたときに,そのサブスクライバーに配信されます。

永続化サブスクライバーを利用した場合のメッセージの送受信の流れを次の図に示します。

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P 繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

図7-7 永続化サブスクライバーを利用した場合のメッセージの送受信の流れ

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

永続化サブスクライバーを利用した場合のメッセージの送受信の流れについて説明します。なお,説明の番号は図中の番号と対応しています。

  1. サブスクライバー1を永続化サブスクライバーとしてトピックに登録します。
    識別子(ClientID)は,「1」とします。
  2. パブリッシャー1が,メッセージ1をトピックに登録します。
  3. サブスクライバー1は,メッセージ1をトピックから受信します。
  4. サブスクライバー1を停止します。
    停止した状態になると,トピックに登録されたメッセージは受信できません。
  5. パブリッシャー2が,メッセージ2をトピックに登録します。サブスクライバー1は停止中のため,メッセージ2を受信できません。ただし,サブスクライバー1は永続化サブスクライバーとして登録されているため,このメッセージは登録された永続化サブスクライバーがメッセージを受信するまでトピックで保管されます。
  6. サブスクライバー2を永続化サブスクライバーとしてトピックに登録します。このとき,識別子(ClientID)を「1」として,サブスクライバーの名称はサブスクライバー1と同じ値にします。
    永続化サブスクライバーの情報を保持しているCJMSPブローカーは,識別子と名称からサブスクライバー2は登録済みの永続化サブスクライバーが再開したものと判断します。
  7. 繝ォ繝シ繧ケ103 譛鬮伜刀雉ェ髑大ョ壽嶌莉 鮟定攜逵溽匠 繝ォ繝シ繧ケ 繝壹い 繝ゥ繧ヲ繝ウ繝 11 2mm 繝斐い繧ケ 繧、繝、繝ェ繝ウ繧ー 繝上Φ繝峨Γ繧、繝 繝悶Λ繝繧ッ繝代シ繝ォ 繧ソ繝偵メ繧「繝ウ繝代シ繝ォ 蜊玲エ狗悄迴 繝悶Λ繝繧ッ逵溽匠繝ォ繝シ繧ケtdsrhQ
  8. トピックに保管されていたメッセージ2がサブスクライバー2に配信されます。

永続化サブスクライバーの指定を解除する場合は,次のどちらかの方法で解除してください。

cjmsicmd destroy durコマンドについては,マニュアル「Cosminexus アプリケーションサーバ リファレンス コマンド編」の「cjmsicmd destroy dur(永続化サブスクライバーの破棄)」を参照してください。

繝「繧ケ繧ュ繝シ繝 繧ケ繝九シ繧ォ繝シ 繧キ繝・繝シ繧コ 髱エ 繝ャ繝繧」繝シ繧ケ Moschino logo print sneakers Black8wnOk0P

unsubscribeメソッドを使用すると,サブスクライバーのために保持されたトピックの状態を解除できます。ただし,このメソッドは,次のタイミングでは使用しないでください。

なお,確認応答モードが「CLIENT_ACKNOWLEDGE」のセッションによって永続化サブスクライバーが作成された場合に,メッセージ受信が確認されていない状態でunsubscribeメソッドが実行されたときには,メッセージは送信先に残ってしまいます。この状況を避けるため,unsubscribeメソッドを使用する場合,事前にcjmsicmd purge durコマンドを実行して,永続化サブスクライバーに関連づけられているすべてのメッセージを削除してください。

注意
一時的な送信先として作成したトピックに対して,永続化サブスクライバーは登録できません。作成しようとすると,例外がスローされます。

[目次][前へ][次へ]


[他社商品名称に関する表示]

All Rights Reserved. Copyright (C) 2008, 2011, Hitachi, Ltd.