C＃观察者的超简单示例/可与委托人一起观察

Question

我最近开始研究C＃，但是我一辈子都无法弄清楚在用语言实现观察者/可观察模式时委托的工作方式。

有人可以给我一个超简单的例子吗？我已经用谷歌搜索了，但是我发现的所有例子要么太过特定于问题，要么太“ blo肿”。

Answer 1

观察者模式通常通过事件来实现。这是一个例子：using System;class Observable{    public event EventHandler SomethingHappened;    public void DoSomething() =>        SomethingHappened?.Invoke(this, EventArgs.Empty);}class Observer{    public void HandleEvent(object sender, EventArgs args)    {        Console.WriteLine("Something happened to " + sender);    }}class Test{    static void Main()    {        Observable observable = new Observable();        Observer observer = new Observer();        observable.SomethingHappened += observer.HandleEvent;        observable.DoSomething();    }}有关更多详细信息，请参见链接的文章。请注意，上面的示例使用C＃6 空条件运算符来DoSomething安全地实现以处理SomethingHappened尚未订阅的情况，因此为null。如果您使用的是旧版本的C＃，则需要这样的代码：public void DoSomething(){    var handler = SomethingHappened;    if (handler != null)    {        handler(this, EventArgs.Empty);    }}

Answer 2

这是一个简单的示例：public class ObservableClass{    private Int32 _Value;    public Int32 Value    {        get { return _Value; }        set        {            if (_Value != value)            {                _Value = value;                OnValueChanged();            }        }    }    public event EventHandler ValueChanged;    protected void OnValueChanged()    {        if (ValueChanged != null)            ValueChanged(this, EventArgs.Empty);    }}public class ObserverClass{    public ObserverClass(ObservableClass observable)    {        observable.ValueChanged += TheValueChanged;    }    private void TheValueChanged(Object sender, EventArgs e)    {        Console.Out.WriteLine("Value changed to " +            ((ObservableClass)sender).Value);    }}public class Program{    public static void Main()    {        ObservableClass observable = new ObservableClass();        ObserverClass observer = new ObserverClass(observable);        observable.Value = 10;    }}注意：这违反了一个规则，即我不将观察者从可观察对象中解脱出来，对于这个简单的示例来说，这也许就足够了，但是请确保您不要让观察者脱离这样的事件。解决此问题的一种方法是使ObserverClass IDisposable，并让.Dispose方法执行与构造函数中的代码相反的操作不执行错误检查，至少应在ObserverClass的构造函数中进行空检查

Answer 3

在此模型中，您有一些发布者，他们将做一些逻辑并发布一个“事件”。然后，发布者将仅向已订阅接收特定事件的订阅者发送事件。在C＃中，任何对象都可以发布其他应用程序可以订阅的一组事件。当发布类引发事件时，将通知所有订阅的应用程序。下图显示了这种机制。在此处输入图片说明关于C＃中事件和委托的最简单示例：代码是不言自明的，此外，我还添加了注释以清除代码。  using System;public class Publisher //main publisher class which will invoke methods of all subscriber classes{    public delegate void TickHandler(Publisher m, EventArgs e); //declaring a delegate    public TickHandler Tick;     //creating an object of delegate    public EventArgs e = null;   //set 2nd paramter empty    public void Start()     //starting point of thread    {        while (true)        {            System.Threading.Thread.Sleep(300);            if (Tick != null)   //check if delegate object points to any listener classes method            {                Tick(this, e);  //if it points i.e. not null then invoke that method!            }        }    }}public class Subscriber1                //1st subscriber class{    public void Subscribe(Publisher m)  //get the object of pubisher class    {        m.Tick += HeardIt;              //attach listener class method to publisher class delegate object    }    private void HeardIt(Publisher m, EventArgs e)   //subscriber class method    {        System.Console.WriteLine("Heard It by Listener");    }}public class Subscriber2                   //2nd subscriber class{    public void Subscribe2(Publisher m)    //get the object of pubisher class    {        m.Tick += HeardIt;               //attach listener class method to publisher class delegate object    }    private void HeardIt(Publisher m, EventArgs e)   //subscriber class method    {        System.Console.WriteLine("Heard It by Listener2");    }}class Test{    static void Main()    {        Publisher m = new Publisher();      //create an object of publisher class which will later be passed on subscriber classes        Subscriber1 l = new Subscriber1();  //create object of 1st subscriber class        Subscriber2 l2 = new Subscriber2(); //create object of 2nd subscriber class        l.Subscribe(m);     //we pass object of publisher class to access delegate of publisher class        l2.Subscribe2(m);   //we pass object of publisher class to access delegate of publisher class        m.Start();          //starting point of publisher class    }}输出：听众听到Listener2听到了听众听到Listener2听到了听众听到。。。（无限次）