深入了解C#設計模式之訂閱發(fā)布模式

更新時間：2020年06月24日 14:46:14 作者：HueiFeng

這篇文章主要介紹了C#設計模式之訂閱發(fā)布模式的的相關資料，文中示例代碼非常詳細，供大家參考和學習，感興趣的朋友可以了解下

什么是Pub-Sub

發(fā)布訂閱是一種設計模式，它允許應用程序組件之間進行松散耦合。
其實訂閱發(fā)布設計中主要是發(fā)布者生成事件通道，用于在不了解任何訂閱者存在的情況下通知訂閱者。

當然委托EventHandlers和Event關鍵字在此事件處理機制中擔任著重要的角色。下面我們來看看如何使用它們。

Pub和Sub的使用

首先我們看一個簡單地訂閱發(fā)布模式.

定義一個Action委托，無返回值.

namespace PubSubPattern
{
  public class Pub
  {
    public Action OnChange { get; set; }

    public void Raise()
    {
      if (OnChange != null)
      {
        //Invoke OnChange Action
        OnChange();
      }
    }
  }

  class Program
  {
    static void Main(string[] args)
    {
      var p = new Pub();
      p.OnChange += () => Console.WriteLine("Sub 1");

      p.OnChange += () => Console.WriteLine("Sub 2");

      p.Raise();

      Console.WriteLine("Press enter !");
      Console.ReadLine();

    }
  }
}

如上代碼我們創(chuàng)建了一個發(fā)布者，并且我們調(diào)用委托進行創(chuàng)建我們匿名方法來訂閱。由于委托提供了多播功能，因此我們可以OnChange屬性上使用+=.

雖然說我們看著如上代碼執(zhí)行無誤，但是程序中仍然存在一些問題，如果使用=而不是+=,那么OnChange屬性中將會刪除第一個訂閱者。
由于OnChange是公共屬性，因此該類的任何外部用戶都可以進行調(diào)用p.OnChange().

使用Event關鍵字的發(fā)布訂閱

下面我們來看看使用event關鍵字后的代碼

  public class Pub
  {
    public event Action OnChange = delegate { };

    public void Raise()
    {
      OnChange();
    }
  }

  class Program
  {
    static void Main(string[] args)
    {
      Pub p = new Pub();
      p.OnChange += () => Console.WriteLine("Sub 1");
      p.OnChange += () => Console.WriteLine("Sub 2");
      p.Raise();
      Console.WriteLine("Press enter !");
      Console.ReadLine();
    }
  }

通過如上代碼我們試著去解決我們第一處所說的問題，我們會發(fā)現(xiàn)使用event關鍵字后可以保護我們OnChange免受不必要的訪問。它不允許使用=也就是說他不允許直接進行分配委托，因此我們現(xiàn)在可以避免使用=，從而避免應用程序不必要的麻煩。

可能大家也會發(fā)現(xiàn)OnChange初始化為空委托delegate{}。這樣可以確保我們的OnChange永遠不會為空。因為當我們其他進行對他調(diào)用的時候我們可以在代碼中進行刪除對他的非空檢查.

使用EventHandlers的發(fā)布訂閱

其實在訂閱發(fā)布中，發(fā)布者和訂閱者都不知道彼此的存在。有個EventHandler，它被稱為消息代理或者說事件總線，發(fā)布者和訂閱者都應該知道它，它接收所有傳入的消息并且將它們進行轉發(fā).

因此呢，在如下片段中我們使用EventHandler而不是用Action.

public delegate void EventHandler(
  object sender,
  EventArgs e
)

默認情況下，EventHandler將發(fā)送對象和一些事件參數(shù)作為參數(shù)。

 public class MyEventArgs : EventArgs
    {
      public int Value { get; set; }

      public MyEventArgs(int value)
      {
        Value = value;
      }
    }

    public class Pub
    {
      public event EventHandler<MyEventArgs> OnChange = delegate { };
      public void Raise()
      {
        OnChange(this, new MyEventArgs(1));
      }
    }
    class Program
    {
      static void Main(string[] args)
      {
        Pub p = new Pub();
        p.OnChange += (sender, e) => Console.WriteLine("Sub 1.Value:" + e.Value);
        p.OnChange += (sender, e) => Console.WriteLine("Sub 2.Value:" + e.Value);
        p.Raise();
        Console.WriteLine("Press enter !");
        Console.ReadLine();
      }
    }

如上代碼中通過pub類使用通用的EventHandler，它觸發(fā)EventHandler OnChange時需要傳遞的事件參數(shù)類型，在上面代碼片段中為MyArgs

事件中的異常

我們繼續(xù)說一種情況.大家看如下代碼片段

  public class MyEventArgs : EventArgs
  {
    public int Value { get; set; }

    public MyEventArgs(int value)
    {
      Value = value;
    }
  }

  public class Pub
  {
    public event EventHandler<MyEventArgs> OnChange = delegate { };
    public void Raise()
    {
      OnChange(this, new MyEventArgs(1));
    }
  }
  class Program
  {
    static void Main(string[] args)
    {
      Pub p = new Pub();
      p.OnChange += (sender, e) => Console.WriteLine("Sub 1.Value:" + e.Value);
      p.OnChange += (sender, e) => { throw new Exception(); };
      p.OnChange += (sender, e) => Console.WriteLine("Sub 2.Value:" + e.Value);
      p.Raise();
      Console.WriteLine("Press enter !");
      Console.ReadLine();
    }
  }

運行如上代碼后，大家會發(fā)現(xiàn)第一個訂閱者已經(jīng)執(zhí)行成功了，第二個訂閱者引發(fā)了異常，而第三個訂閱者未被調(diào)用.這是一個很尷尬的事情.

如果說我們覺得如上的過程不是我們預期的，我們需要手動引發(fā)事件并處理異常，這時候我們可以使用Delegate基類中定義的GetInvoctionList來幫助我們實現(xiàn)這些。

我們繼續(xù)看如下代碼

public class MyEventArgs : EventArgs
    {
      public int Value { get; set; }

      public MyEventArgs(int value)
      {
        Value = value;
      }
    }

    public class Pub
    {

      public event EventHandler<MyEventArgs> OnChange = delegate { };

      public void Raise()
      {
        MyEventArgs eventArgs = new MyEventArgs(1);

        List<Exception> exceptions = new List<Exception>();

        foreach (Delegate handler in OnChange.GetInvocationList())
        {
          try
          {
            handler.DynamicInvoke(this, eventArgs);
          }
          catch (Exception e)
          {
            exceptions.Add(e);
          }
        }

        if (exceptions.Any())
        {
          throw new AggregateException(exceptions);
        }
      }
    }
    class Program
    {
      static void Main(string[] args)
      {
        Pub p = new Pub();
        p.OnChange += (sender, e) => Console.WriteLine("Sub 1.Value:" + e.Value);
        p.OnChange += (sender, e) => { throw new Exception(); };
        p.OnChange += (sender, e) => Console.WriteLine("Sub 2.Value:" + e.Value);
        p.Raise();
        Console.WriteLine("Press enter !");
        Console.ReadLine();
      }
    }

Reference

https://github.com/hueifeng/DesignPatterns-Samples/tree/master/PubSubPattern

https://hackernoon.com/observer-vs-pub-sub-pattern-50d3b27f838c

以上就是深入了解C#設計模式之訂閱發(fā)布模式的詳細內(nèi)容，更多關于c# 訂閱發(fā)布模式的資料請關注腳本之家其它相關文章！

您可能感興趣的文章: