ヘッダーをスキップ
Oracle Coherenceクライアント・ガイド
リリース3.5
B56041-01
  目次
目次
戻る
戻る 		 次へ
次へ		  

18 .NETクライアント用連続問合せキャッシュ

Coherence for .NETキャッシュからポイント・イン・タイムの問合せ結果を取得でき、その問合せ結果を変更するイベントを受信できる一方、Coherence for .NETでは、問合せ結果と連続的な関連するイベント・ストリームとを組み合せて、最新の問合せ結果をリアルタイムに維持できます。目的の問合せの待機時間が0である場合と同じ効果を持ち、問合せがミリ秒ごとに数回繰り返されるため、この機能は連続問合せと呼ばれています。

Coherence for .NETでは、問合せ結果をマテリアライズして連続問合せキャッシュに格納し、問合せに対するイベント・リスナーを使用してそのキャッシュをリアルタイムに最新の状態に維持することで、連続問合せ機能を実装します。つまり、Coherence for .NETの連続問合せでは、キャッシュされた問合せ結果が古くなることはありません。

連続問合せキャッシュの用途

連続問合せキャッシュには、いくつかの異なる一般的な用途があります。

使用例の1つにトレーディング・システム・デスクトップがあります。このデスクトップには、トレーダーの未処理の注文とすべての関連情報が常に最新の状態で保持されている必要があります。Coherence*Extend機能を連続問合せキャッシュと組み合せることにより、アプリケーションで文字どおり何万もの同時ユーザーをサポートできます。


注意:

連続問合せキャッシュは、分散される可能性のあるより大きなキャッシュ・データセットの特定のサブセットについて、その最新のローカル・コピーを非常に簡単かつ効果的に維持する機能を提供します。そのため、クライアントベースおよびサーバーベースのアプリケーションを含め、ほとんどすべてのタイプのアプリケーションに有用です。

連続問合せキャッシュ

Coherence for .NETの連続問合せの実装には、Tangosol.Net.Cache.ContinuousQueryCacheクラスを使用します。このクラスは、Coherence for .NETのすべてのキャッシュ同様、次の機能を備えた標準のINamedCacheインタフェースを実装します。

ContinuousQueryCacheは、Coherence for .NETのすべてのキャッシュで提供されるAPIであるINamedCacheインタフェースを実装しているため、非常に使いやすく、その機能が必要になった場合に別のキャッシュと簡単に置き換えることができます。

連続問合せキャッシュの構成

連続問合せキャッシュは、次の2つの項目で定義されます。

基礎となるキャッシュには、別の連続問合せキャッシュを含めた任意のCoherence for .NETキャッシュを使用できます。キャッシュは一般にCacheFactoryで取得されます。これにより開発者は、次の例に示すように、キャッシュの名前を指定するだけでアプリケーションのキャッシュ・コンフィギュレーション情報に基づいて自動的にキャッシュを構成できます。

INamedCache cache = CacheFactory.GetCache("orders");

この問合せは、他のキャッシュの問合せに使用される問合せと同じタイプです。次に例を示します。

Filter filter = new AndFilter(new EqualsFilter("getTrader", traderid),
                              new EqualsFilter("getStatus", Status.OPEN));

通常、キャッシュを問い合せるには、IQueryCacheのいずれかのメソッドを使用します。たとえば、このトレーダーの未決済ポジションすべてのスナップショットを取得するには、次のコードを使用します。

ICollection setOpenTrades = cache.GetEntries(filter);

同様に、連続問合せキャッシュは、次に示す同じ2つの要素で構成されます。

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter);

連続問合せキャッシュに関連付けられたリソースのクリーンアップ

すべてのINamedCache実装のインスタンスは、ContinuousQueryCacheを含め、不要になった時点でINamedCache.Release()メソッドをコールして明示的に解放し、これらのインスタンスで保持されているリソースをすべて解放する必要があります。

特定のINamedCacheがアプリケーションの継続期間を通して使用される場合、リソースはそのアプリケーションがシャットダウンされたとき、または停止したときにクリーンアップされます。ただし、わずかの間だけ使用される場合は、使い終わった時点でアプリケーションからRelease()メソッドをコールする必要があります。

または、INamedCacheがIDisposableを拡張し、すべてのキャッシュ実装がIDisposable.Dispose()のコールをINamedCache.Release()に委任しているという事実を利用する方法もあります。つまり単一メソッド内でキャッシュ・インスタンスを取得および解放する必要がある場合、次のusingブロックを使用してそれを実現できます。

例18-1 連続問合せキャッシュへの参照の取得と解放

using (INamedCache cache = CacheFactory.GetCache("my-cache"))
{
   // use cache as usual
}

usingブロックが終了すると、INamedCacheインスタンスでIDisposable.Dispose()がコールされ、そのインスタンスに関連付けられているすべてのリソースが解放されます。

データの一部を格納するマテリアライズド・ビューと完全なマテリアライズド・ビュー

連続問合せキャッシュを構成する際、問合せで取得されたキーだけをキャッシュで追跡し、要求された場合にのみ、その値を基礎となるキャッシュから取得するように指定することができます。この機能は、問合せの結果セットが非常に膨大になる連続問合せキャッシュを作成する場合、または値をリクエストされることがないか、ほとんどない場合に役立ちます。キーのみをキャッシュするように指定するには、次の例に示すように、IsCacheValuesプロパティを構成できるコンストラクタを使用します。

例18-2 連続問合せキャッシュへのキーのみのキャッシュ

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter, false);

次の例に示すように、必要に応じて、キャッシュがインスタンス化された後にIsCacheValuesプロパティを変更することもできます。

cacheOpenTrades.IsCacheValues = true;

IsCacheValuesプロパティとイベント・リスナー

連続問合せキャッシュに標準の（非Lite）イベント・リスナーがある場合、またはイベント・リスナーのいずれかがフィルタリングされる場合は、IsCacheValuesプロパティが自動的にtrueに設定されます。これは、イベントをフィルタリングする際、および発生させたイベントに古い値と新しい値を提供する際に、ローカルにキャッシュされた値を連続問合せキャッシュが使用するためです。

連続問合せキャッシュのリスニング

連続問合せキャッシュ自体は監視可能であるため、クライアントが連続問合せキャッシュに1つ以上のイベント・リスナーを配置することが可能です。次に例を示します。

例18-3 連続問合せキャッシュでのリスナーの配置

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter);
cacheOpenTrades.AddCacheListener(listener);

すでにキャッシュに格納されているすべてのアイテムとキャッシュに追加されるすべてのアイテムに対してなんらかの処理を実行する必要がある場合、その方法は2つあります。1つは、処理を実行した後、以降の追加に対処するリスナーを追加する方法です。

例18-4 データを処理してからリスナーを配置する場合

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter);
foreach (ICacheEntry entry in cacheOpenTrades.Entries)
    {
    // .. process the cache entry
    }
cacheOpenTrades.AddCacheListener(listener);

ただし、このコードは正しくありません。これでは、反復処理が終了してリスナーが追加されるまでのわずかの時間に発生したイベントを見逃すことになります。別の方法では、イベントを見逃さないように、まずリスナーを追加し、その後で処理を実行します。

例18-5 リスナーを配置してからデータを処理する場合

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter);
cacheOpenTrades.AddCacheListener(listener);
foreach (ICacheEntry entry in cacheOpenTrades.Entries)
    {
    // .. process the cache entry
    }

ただし、イベントとIEnumeratorの両方に同じエントリが出現する可能性があります。また、イベントは非同期の可能性があるため、操作の順序は保証されません。

これを解決するには、構成時にリスナーを提供します。これで、連続問合せキャッシュ内のアイテムが（問合せに含まれていたため）最初から存在していたか、キャッシュの作成中または作成後に追加されたかに関係なく、連続問合せキャッシュはアイテムごとに1つのイベントを受信します。

例18-6 連続問合せキャッシュの構成時にリスナーを提供する場合

ContinuousQueryCache cacheOpenTrades = new ContinuousQueryCache(cache, filter, listener);

安定したマテリアライズド・ビューの実現

連続問合せキャッシュの実装でも同じ課題に直面していました。その課題とは、基礎となるキャッシュから変更イベント・ストリームを受信しながら、その同じキャッシュの正確なポイント・イン・タイム・スナップショットを組み立てる方法です。その解決法は、いくつかの部分に分かれています。第1に、Coherence for .NETでは同期イベントのオプションがサポートされ、それによって一連の順序保証が実現します。第2に、連続問合せキャッシュでは、その初期移入の実装が2つのフェーズに分かれているため、まず基礎となるキャッシュに対して問合せを実行し、その後、最初のフェーズ中に発生したイベントをすべて解決できます。このようにイベントを見逃したり重複させたりすることなくデータの可視性を保証する操作はかなり複雑であるため、連続問合せキャッシュでは、アプリケーション開発者が作成時にリスナーを渡すことで、この複雑さに対処しなくても済むようにしています。

同期リスナーおよび非同期リスナーのサポート

デフォルトでは、連続問合せキャッシュに対するリスナーによって、リスナーのイベントが非同期に配信されます。ただし連続問合せキャッシュでは、CacheListenerSupport.ISynchronousListenerインタフェースで規定されているとおり、同期イベントのオプションが考慮されます。

連続問合せキャッシュを読取り専用にする

連続問合せキャッシュは、次の例のように、読取り専用キャッシュにすることができます。

例18-7 連続問合せキャッシュを読取り専用にする

cacheOpenTrades.IsReadOnly = true;

読取り専用の連続問合せキャッシュでは、オブジェクトの追加、変更、削除またはロックができません。

連続問合せキャッシュを読取り専用に設定した後は、読取り/書込みに戻すことはできません。

  戻る
戻る 		 次へ
次へ
  目次
目次