アクティビティのポーリングサービス

Question

私は、継続的に計算タスクを実行するWindowsサービスを持っています。 1つの計算タスクの一部として実行される複数の計算ステップがあります。

このサービスは、複数のクライアントがポーリングしてその動作を観察できるように、計算タスクと手順を記録/追跡するために必要です。

この要件を満たすために、アクティビティメッセージを収集するサービスに簡単なDictionary<Guid, List<string>>（_activity）を追加しました。キーはCalculationTask.Idを表すGuidであり、値は個々の計算ステップからのメッセージを保持するList<string>です。

私は、（wcfを介して）クライアントから呼び出されたサービスに、動作メッセージをポーリングするためのメソッドを単純に追加しました。

：クライアントは、ここで

private readonly Dictionary<Guid, List<string>> _activity = new Dictionary<Guid, List<string>>(); 
public List<string> GetActivity(DateTime lastPolledTimeStamp) 
{ 
    var snapshot = _activity.ToList(); 

    return snapshot.SelectMany(x => x.Value) 
     .Where(x => x.TimeStamp > lastPolledTimeStamp) 
     .OrderBy(x => x.TimeStamp) 
     .ToList(); 
} 

は私の問題と質問されている...「私は最後のをポーリングするので、私にあなたのメッセージのすべてを与える」、サービスを伝えるための試みでlastPolledTimeStampに渡します（1）クライアントとサービスが異なるマシン上にある場合、日時比較による結果のフィルタリングは機能しません。そして、私はGetActivityが呼び出されるたびに、すべてを_activityに返すことはできません。あまりにも多くのデータがあります。何らかのフィルタリングが必要です。その他の選択肢は何ですか？

（2）別の「問題」は、_activity辞書のキーと値のペアをいつ削除できるかを知っていることです。クライアントは5秒ごとにポーリングしています。私はクライアントがそれを拾うチャンスを持っているように、キー/値のペアを十分に長くしておきたいと思います。おそらく、_activityの古いエントリを定期的にクリーンアップするために実行する別のタイマーを含めるべきです。思考？

Answer 1

最初の問題については、各応答でサーバーの時刻を返し、要求を行うときに、自分の時刻ではなくこのタイムスタンプを送信するようクライアントに依頼してください。

第2の問題点：計算/ステップが、更新のセットごとに固定サイズのバッファを用意するのではなく、異なるレートでメッセージを生成している場合、私は頻繁にクリーンアップジョブを実行し、 [クライアントのping間隔の小さい倍数]より古いメッセージ。

Answer 2

2番目の問題として、古いエントリを自動的に上書きする循環配列構造を実装します。メッセージが書き込まれる割合が一定であれば、これは簡単であるはずです。可変であれば、5秒間に予想される最大メッセージ数に基づいて配列を作成するためのサイズを把握する必要があります。