C# でオブザーバーパターンを実装する 3 つの方法-C#.Net チュートリアル-php.cn

観察者モードといえば、おそらく庭でたくさん見つけることができます。したがって、このブログを書く目的は 2 つあります:

1. オブザーバーパターンは、コードレベルに関係なく、パブリッシュ/サブスクライブパターンを採用するために必要なパターンです。自分の理解に基づいて利用シナリオを再設計し、その中でオブザーバーパターンを柔軟に使用したい
2. C# でオブザーバーパターンを実装するための 3 つのソリューションをまとめたい

ここで、そのようなシナリオを想定し、オブザーバーモードを使用してニーズを実現しましょう:

将来、スマートホームは各家庭に導入され、各家庭には顧客がカスタマイズして統合できる API が用意されているため、最初のスマート目覚まし時計 ( SmartClock) は、最初にこの目覚まし時計用の API セットを提供しており、アラーム時刻が設定されると、目覚まし時計がその時刻を通知します。この目覚まし時計のアラームメッセージは、飼い主のために牛乳、パン、歯磨き粉などを自動的に準備します。

このシナリオは非常に典型的なオブザーバーモードであり、スマート目覚まし時計の目覚まし時計が対象であり、ミルクウォーマー、パン焼き機、歯磨き粉絞り装置はこのトピックを実装するだけで済みます。疎結合コーディングモデル。 3 つのオプションを 1 つずつ使用して、この要件を実装してみましょう。

1. .net のイベントモデルを使用して実装します

.net のイベントモデルは、.net が誕生してからコードで広く使用されています。これをシナリオで使用するために、

まずスマート目覚まし時計を紹介します。メーカーは非常にシンプルな API のセットを提供しています

public void SetAlarmTime(TimeSpan timeSpan)
        {
            _alarmTime = _now().Add(timeSpan);
            RunBackgourndRunner(_now, _alarmTime);
        }

ログイン後にコピー

SetAlarmTime(TimeSpan)。 timeSpan) はタイミングに使用されます。ユーザーが時間を設定すると、目覚まし時計はバックグラウンドで while(true) と同様のループを実行し、アラーム時間が経過すると、通知イベントが送信されます

。

protected void RunBackgourndRunner(Func<DateTime> now,DateTime? alarmTime )
        {
            if (alarmTime.HasValue)
            {
                var cancelToken = new CancellationTokenSource();
                var task = new Task(() =>
                {
                    while (!cancelToken.IsCancellationRequested)
                    {
                        if (now.AreEquals(alarmTime.Value))
                        {
                            //闹铃时间到了
                            ItIsTimeToAlarm();
                            cancelToken.Cancel();
                        }
                        cancelToken.Token.WaitHandle.WaitOne(TimeSpan.FromSeconds(2));
                    }
                }, cancelToken.Token, TaskCreationOptions.LongRunning);
                task.Start();
            }
        }

ログイン後にコピー

他のコードは重要ではありません。重要な点は、アラーム時刻になったら ItIsTimeToAlarm() を実行することです。サブスクライバーに通知するためにここにイベントを送信します。.net でイベントモデルを実装するには、

1 というパブリックイベントのイベントを定義します。 Alarm;

2. サブジェクトの情報の EventArgs、つまりイベントのすべての情報を含む AlarmEventArgs を定義します

3. サブジェクトは次の方法でイベントを発行します

var args = new AlarmEventArgs(_alarmTime.Value, 0.92m);
 OnAlarmEvent(args);

ログイン後にコピー

OnAlarmEvent メソッドの定義

public virtual void OnAlarm(AlarmEventArgs e)
       {
           if(Alarm!=null)
               Alarm(this,e);
       }

ログイン後にコピー

ここでの命名に注意してください、イベント内容-AlarmEventArgs、イベント-Alarm（KeyPressなどの動詞）、イベントをトリガーするメソッド void OnAlarm() では、これらの要素はイベントモデルの命名規則に準拠する必要があります。
スマート目覚まし時計 (SmartClock) が実装されました。ミルクヒーター (MilkSchedule) でこのアラームメッセージをサブスクライブします。 > {// 焙煎の時間ですブレッド}アラームメッセージを購読します。

この時点では、イベントモデルが導入されていますが、実装プロセスはまだ少し面倒で、イベントモデルを不適切に使用するとメモリが発生します。リークの問題は、オブザーバーがライフサイクルの長いトピック (トピックのライフサイクルがオブザーバーよりも長い) をサブスクライブすると、オブザーバーがメモリリサイクルされないことです (トピックへの参照がまだ存在するため)。「理解」を参照してください。詳細については、「イベントハンドラーによるメモリリークの回避」を参照してください。 Event Aggregator の場合、開発者はトピック (-=) を明示的に購読解除する必要があります。

庭の老人 A も、この問題を解決するために弱い参照を使用する方法に関するブログを書きました: イベントによって引き起こされるメモリリーク問題を解決する方法: 弱いイベントハンドラー。

2. .net で IObservable を使用する T>Observer パターンの実装

IObservable 名前が示すように、観察可能なもの、つまりサブジェクトは、明らかにオブザーバーです。

このシナリオでは、スマート目覚まし時計は IObservable です。このインターフェイスは 1 つのメソッド IDisposable Subscribe(IObserver; このメソッドの名前は少し紛らわしいですが、Subscribe はサブスクリプションを意味し、前述のサブジェクト (subject) をサブスクライブするオブザーバー (observer) とは異なります。ここで、サブジェクトはオブザーバーをサブスクライブします。実際、このモデルではサブジェクトがオブザーバーのリストを維持するため、サブジェクトがオブザーバーをサブスクライブするという言い方があります。目覚まし時計の IDisposable を見てみましょう。サブスクライブ (IObserver オブザーバー) の実装:

public void PrepareMilkInTheMorning()
        {
            _clock.Alarm += (clock, args) =>
            {
                Message =
                    "Prepraring milk for the owner, The time is {0}, the electric quantity is {1}%".FormatWith(
                        args.AlarmTime, args.ElectricQuantity*100);
 
                Console.WriteLine(Message);
            };
 
            _clock.SetAlarmTime(TimeSpan.FromSeconds(2));
 
        }

ログイン後にコピー

ここでは、オブザーバー list_observers が維持されていることがわかります。目覚まし時計が時刻に達すると、すべてのオブザーバーリストを調べて、オブザーバーに 1 つずつ通知します。メッセージの

public IDisposable Subscribe(IObserver<AlarmData> observer)
        {
            if (!_observers.Contains(observer))
            {
                _observers.Add(observer);
            }
            return new DisposedAction(() => _observers.Remove(observer));
        }

ログイン後にコピー

明らかに、オブザーバーには OnNext メソッドがあり、メソッドシグネチャは、通知されるメッセージデータを表す AlarmData です。次に、オブザーバーとしてのミルクヒーターの実装を見てみましょう。ヒーターはもちろん IObserver インターフェイスを実装する必要があります

public override void ItIsTimeToAlarm()
        {
            var alarm = new AlarmData(_alarmTime.Value, 0.92m);
            _observers.ForEach(o=>o.OnNext(alarm));
        }

ログイン後にコピー

さらに、パン焼き機の使用を容易にするために、Subscribe() と Unsubscribe() という 2 つのメソッドも追加しました。呼び出しプロセスを参照してください

public  void Subscribe(TimeSpan timeSpan)
       {
           _unSubscriber = _clock.Subscribe(this);
           _clock.SetAlarmTime(timeSpan);
       }
 
       public  void Unsubscribe()
       {
           _unSubscriber.Dispose();
       }
 
       public void OnNext(AlarmData value)
       {
                      Message =
                  "Prepraring milk for the owner, The time is {0}, the electric quantity is {1}%".FormatWith(
                      value.AlarmTime, value.ElectricQuantity * 100);
           Console.WriteLine(Message);
       }

ログイン後にコピー

3. アクション関数ソリューション

ソリューションを紹介する前に、このソリューションはオブザーバーモデルではないことを説明する必要がありますが、同じ機能を実現でき、より簡単に使用でき、これも私のお気に入りの用途の 1 つです。

这种方案中，智能闹钟(smartClock)提供的API需要设计成这样：

public void SetAlarmTime(TimeSpan timeSpan,Action<AlarmData> alarmAction)
       {
           _alarmTime = _now().Add(timeSpan);
           _alarmAction = alarmAction;
           RunBackgourndRunner(_now, _alarmTime);
       }

ログイン後にコピー

方法签名中要接受一个Action,闹钟在到点后直接执行该Action即可:

public override void ItIsTimeToAlarm()
       {
           if (_alarmAction != null)
           {
               var alarmData = new AlarmData(_alarmTime.Value, 0.92m);
               _alarmAction(alarmData);    
           }
       }

ログイン後にコピー

牛奶加热器中使用这种API也很简单：

_clock.SetAlarmTime(TimeSpan.FromSeconds(1), (data) =>
            {
                Message =
                   "Prepraring milk for the owner, The time is {0}, the electric quantity is {1}%".FormatWith(
                       data.AlarmTime, data.ElectricQuantity * 100);
            });

ログイン後にコピー

在实际使用过程中我会把这种API设计成fluent模型，调用起来代码更清晰：

智能闹钟(smartClock)中的API:

public Clock SetAlarmTime(TimeSpan timeSpan)
        {
            _alarmTime = _now().Add(timeSpan);
            RunBackgourndRunner(_now, _alarmTime);
            return this;
        }
 
        public void OnAlarm(Action<AlarmData> alarmAction)
        {
            _alarmAction = alarmAction;
        }

ログイン後にコピー

牛奶加热器中进行调用：

_clock.SetAlarmTime(TimeSpan.FromSeconds(2))
      .OnAlarm((data) =>
                {
                    Message =
                    "Prepraring milk for the owner, The time is {0}, the electric quantity is {1}%".FormatWith(
                        data.AlarmTime, data.ElectricQuantity * 100);
                });

ログイン後にコピー

显然改进后的写法语义更好：闹钟.设置闹铃时间().当报警时(()=>{执行以下功能})

这种函数式写法更简练，但是也有明显的缺点，该模型不支持多个观察者,当面包烘烤机使用这样的API时，会覆盖牛奶加热器的函数,即每次只支持一个观察者使用。

结束语，本文总结了.net下的三种观察者模型实现方案，能在编程场景下选择最合适的模型当然是我们的最终目标。