1. 程式人生 > >觀察者模式(Publish/Subscribe)(C#實現)

觀察者模式(Publish/Subscribe)(C#實現)

轉載自 

1. 概述

  有時被稱作釋出/訂閱模式,觀察者模式定義了一種一對多的依賴關係,讓多個觀察者物件同時監聽某一個主題物件。這個主題物件在狀態發生變化時,會通知所有觀察者物件,使它們能夠自動更新自己。

2. 解決的問題

  將一個系統分割成一個一些類相互協作的類有一個不好的副作用,那就是需要維護相關物件間的一致性。我們不希望為了維持一致性而使各類緊密耦合,這樣會給維護、擴充套件和重用都帶來不便。觀察者就是解決這類的耦合關係的。

3. 模式中的角色

  3.1 抽象主題(Subject):它把所有觀察者物件的引用儲存到一個聚集裡,每個主題都可以有任何數量的觀察者。抽象主題提供一個介面,可以增加和刪除觀察者物件。

  3.2 具體主題(ConcreteSubject):將有關狀態存入具體觀察者物件;在具體主題內部狀態改變時,給所有登記過的觀察者發出通知。

  3.3 抽象觀察者(Observer):為所有的具體觀察者定義一個介面,在得到主題通知時更新自己。

  3.4 具體觀察者(ConcreteObserver):實現抽象觀察者角色所要求的更新介面,以便使本身的狀態與主題狀態協調。

4. 模式解讀

  4.1 觀察者模式的類圖  

  

  4.2 觀察者模式的程式碼

複製程式碼
    /// <summary>
    /// 抽象主題類
    /// </summary>
    public abstract
class Subject { private IList<Observer> observers = new List<Observer>(); /// <summary> /// 增加觀察者 /// </summary> /// <param name="observer"></param> public void Attach(Observer observer) { observers.Add(observer); }
/// <summary> /// 移除觀察者 /// </summary> /// <param name="observer"></param> public void Detach(Observer observer) { observers.Remove(observer); } /// <summary> /// 向觀察者(們)發出通知 /// </summary> public void Notify() { foreach (Observer o in observers) { o.Update(); } } } /// <summary> /// 抽象觀察者類,為所有具體觀察者定義一個介面,在得到通知時更新自己 /// </summary> public abstract class Observer { public abstract void Update(); } /// <summary> /// 具體觀察者或具體通知者,將有關狀態存入具體觀察者物件;在具體主題的內部狀態改變時,給所有登記過的觀察者發出通知。具體主題角色通常用一個具體子類實現。 /// </summary> public class ConcreteSubject : Subject { private string subjectState; /// <summary> /// 具體觀察者的狀態 /// </summary> public string SubjectState { get { return subjectState; } set { subjectState = value; } } } /// <summary> /// 具體觀察者,實現抽象觀察者角色所要求的更新介面,已是本身狀態與主題狀態相協調 /// </summary> public class ConcreteObserver : Observer { private string observerState; private string name; private ConcreteSubject subject; /// <summary> /// 具體觀察者用一個具體主題來實現 /// </summary> public ConcreteSubject Subject { get { return subject; } set { subject = value; } } public ConcreteObserver(ConcreteSubject subject, string name) { this.subject = subject; this.name = name; } /// <summary> /// 實現抽象觀察者中的更新操作 /// </summary> public override void Update() { observerState = subject.SubjectState; Console.WriteLine("The observer's state of {0} is {1}", name, observerState); } }
複製程式碼

  4.3 客戶端程式碼

複製程式碼
    class Program
    {
        static void Main(string[] args)
        {
            // 具體主題角色通常用具體自來來實現
            ConcreteSubject subject = new ConcreteSubject();

            subject.Attach(new ConcreteObserver(subject, "Observer A"));
            subject.Attach(new ConcreteObserver(subject, "Observer B"));
            subject.Attach(new ConcreteObserver(subject, "Observer C"));

            subject.SubjectState = "Ready";
            subject.Notify();

            Console.Read();
        }
    }
複製程式碼

  執行結果

  

5. 模式總結

  5.1 優點

    5.1.1 觀察者模式解除了主題和具體觀察者的耦合,讓耦合的雙方都依賴於抽象,而不是依賴具體。從而使得各自的變化都不會影響另一邊的變化。

  5.2 缺點

    5.2.1 依賴關係並未完全解除,抽象通知者依舊依賴抽象的觀察者。

  5.3 適用場景

    5.3.1 當一個物件的改變需要給變其它物件時,而且它不知道具體有多少個物件有待改變時。

    5.3.2 一個抽象某型有兩個方面,當其中一個方面依賴於另一個方面,這時用觀察者模式可以將這兩者封裝在獨立的物件中使它們各自獨立地改變和複用。

6. 模式引申,應用C#中的事件委託來徹底解除通知者和觀察者之間的耦合。

   6.1 關於委託的定義:委託是一種引用方法的型別。一旦為委託分配了方法,委託將與該方法有相同的行為。委託方法可以像其它任何方法一樣,具有引數和返回值。委託可以看作是對函式(方法)的的抽象,是函式的“類”,委託的例項代表一個(或多個)具體的函式,它可以是多播的。

   6.2 關於事件:事件基於委託,為委託提供了一種釋出/訂閱機制。事件的訂閱與取消與我們剛才講的觀察者模式中的訂閱與取消類似,只是表現形式有所不同。在觀察者模式中,訂閱使用方法Attach()來進行;在事件的訂閱中使用“+=”。類似地,取消訂閱在觀察者模式中用Dettach(),而事件的取消用“-=”。

7. 下面例子分別用觀察者模式,事件機制來實現

  7.1 例項描述:客戶支付了訂單款項,這時財務需要開具發票,出納需要記賬,配送員需要配貨。

  7.2 觀察者模式的實現

    7.2.1 類圖

    

    7.2.2 程式碼實現

複製程式碼
    /// <summary>
    /// 抽象觀察者
    /// </summary>
    public interface ISubject
    {
        void Notify();
    }

    /// <summary>
    /// 工作崗位,作為這裡的觀察者的抽象
    /// </summary>
    public abstract class JobStation
    {
        public abstract void Update();
    }

    /// <summary>
    /// 具體主題,這裡是客戶
    /// </summary>
    public class Customer : ISubject
    {
        private string customerState;

        private IList<JobStation> observers = new List<JobStation>();

        /// <summary>
        /// 增加觀察者
        /// </summary>
        /// <param name="observer"></param>
        public void Attach(JobStation observer)
        {
            this.observers.Add(observer);
        }

        /// <summary>
        /// 移除觀察者
        /// </summary>
        /// <param name="observer"></param>
        public void Detach(JobStation observer)
        {
            this.observers.Remove(observer);
        }

        /// <summary>
        /// 客戶狀態
        /// </summary>
        public string CustomerState
        {
            get { return customerState; }
            set { customerState = value; }
        }

        public void Notify()
        {
            foreach (JobStation o in observers)
            {
                o.Update();
            }
        }
    }

    /// <summary>
    /// 會計
    /// </summary>
    public class Accountant : JobStation
    {
        private string accountantState;
        private Customer customer;

        public Accountant(Customer customer)
        {
            this.customer = customer;
        }

        /// <summary>
        /// 更新狀態
        /// </summary>
        public override void Update()
        {
            if (customer.CustomerState == "已付款")
            {
                Console.WriteLine("我是會計,我來開具發票。");
                accountantState = "已開發票";
            }
        }
    }

    /// <summary>
    /// 出納
    /// </summary>
    public class Cashier : JobStation
    {
        private string cashierState;
        private Customer customer;

        public Cashier(Customer customer)
        {
            this.customer = customer;
        }

        public override void Update()
        {
            if (customer.CustomerState == "已付款")
            {
                Console.WriteLine("我是出納員,我給登記入賬。");
                cashierState = "已入賬";
            }
        }
    }

    /// <summary>
    /// 配送員
    /// </summary>
    public class Dilliveryman : JobStation
    {
        private string dillivierymanState;
        private Customer customer;

        public Dilliveryman(Customer customer)
        {
            this.customer = customer;
        }

        public override void Update()
        {
            if (customer.CustomerState == "已付款")
            {
                Console.WriteLine("我是配送員,我來發貨。");
                dillivierymanState = "已發貨";
            }
        }
    }
複製程式碼

    7.2.3 客戶端程式碼

複製程式碼
    class Program
    {
        static void Main(string[] args)
        {

            Customer subject = new Customer();

            subject.Attach(new Accountant(subject));
            subject.Attach(new Cashier(subject));
            subject.Attach(new Dilliveryman(subject));

            subject.CustomerState = "已付款";
            subject.Notify();

            Console.Read();
        }
    }
複製程式碼

    執行結果:

    我是會計,我來開具發票。
    我是出納員,我給登記入賬。
    我是配送員,我來發貨。

  7.3 事件實現

    7.3.1 類圖

    

    通過類圖來看,觀察者和主題之間已經不存在任何依賴關係了。

    7.3.2 程式碼實現

複製程式碼
    /// <summary>
    /// 抽象主題
    /// </summary>
    public interface ISubject
    {
        void Notify();
    }

    /// <summary>
    /// 宣告委託
    /// </summary>
    public delegate void CustomerEventHandler();

    /// <summary>
    /// 具體主題
    /// </summary>
    public class Customer : ISubject
    {
        private string customerState;

        // 宣告一個委託事件,型別為 CustomerEventHandler
        public event CustomerEventHandler Update;

        public void Notify()
        {
            if (Update != null)
            {
                // 使用事件來通知給訂閱者
                Update();
            }
        }

        public string CustomerState
        {
            get { return customerState; }
            set { customerState = value; }
        }
    }

    /// <summary>
    /// 財務,已經不需要實現抽象的觀察者類,並且不用引用具體的主題
    /// </summary>
    public class Accountant
    {
        private string accountantState;

        public Accountant()
        { }

        /// <summary>
        /// 開發票
        /// </summary>
        public void GiveInvoice()
        {
            Console.WriteLine("我是會計,我來開具發票。");
            accountantState = "已開發票";
        }
    }

    /// <summary>
    /// 出納,已經不需要實現抽象的觀察者類,並且不用引用具體的主題
    /// </summary>
    public class Cashier
    {
        private string cashierState;

        public void Recoded()
        {
            Console.WriteLine("我是出納員,我給登記入賬。");
            cashierState = "已入賬";
        }
    }

    /// <summary>
    /// 配送員,已經不需要實現抽象的觀察者類,並且不用引用具體的主題
    /// </summary>
    public class Dilliveryman
    {
        private string dillivierymanState;

        public void Dilliver()
        {
            Console.WriteLine("我是配送員,我來發貨。");
            dillivierymanState = "已發貨";
        }
    }
複製程式碼

    7.3.3 客戶端程式碼

複製程式碼
    class Program
    {
        static void Main(string[] args)
        {

            Customer subject = new Customer();

            Accountant accountant = new Accountant();
            Cashier cashier = new Cashier();
            Dilliveryman dilliveryman = new Dilliveryman();

            // 註冊事件
            subject.Update += accountant.GiveInvoice;
            subject.Update += cashier.Recoded;
            subject.Update += dilliveryman.Dilliver;

            /*
             * 以上寫法也可以用下面程式碼來替換
            subject.Update += new CustomerEventHandler(accountant.GiveInvoice);
            subject.Update += new CustomerEventHandler(cashier.Recoded);
            subject.Update += new CustomerEventHandler(dilliveryman.Dilliver);
             */

            subject.CustomerState = "已付款";
            subject.Notify();

            Console.Read();
        }
    }
複製程式碼

相關推薦

觀察模式詳解包含觀察模式JDK的漏洞以及事件驅動模型

import java.util.Vector; //被觀察者類 public class Observable { //這是一個改變標識,來標記該被觀察者有沒有改變 private boolean changed = false; //持有一個觀察者列表 private

觀察模式Observer Pattern,物件行為型模式,釋出-訂閱模式 Publish/Subscribe Pattern

意圖 通知狀態變化 定義物件間的一對多的依賴關係,當一個物件的狀態發生變化時,所有依賴它的物件都得到通知並被自動更新,由抽象類或介面實現。 推模式:目標角色複雜,並且觀察者角色進行更行時必須得到一些具體的變化資訊 拉模式:目標角色簡單 適用性 在

觀察模式Observer和釋出Publish/訂閱模式Subscribe的區別

觀察者模式(Observer)和釋出(Publish/訂閱模式(Subscribe)的區別 在翻閱資料的時候,有人把觀察者(Observer)模式等同於釋出(Publish)/訂閱(Subscribe)模式,也有人認為這兩種模式還是存在差異,而我認為確實是存在差異的,本質上的區別是排程的地方不同。

觀察模式Publish/SubscribeC#實現

轉載自  1. 概述   有時被稱作釋出/訂閱模式,觀察者模式定義了一種一對多的依賴關係,讓多個觀察者物件同時監聽某一個主題物件。這個主題物件在狀態發生變化時,會通知所有觀察者物件,使它們能夠自動更新自己。 2. 解決的問題   將一個系統分割成一個一些類相互協作的

觀察模式Observer和發布Publish/訂閱模式Subscribe的區別

enc can 處理 ted cas clas script prot add 源地址:https://blog.csdn.net/qq_39877296/article/details/79103206 觀察者模式(Observer)和發布(Publish/訂閱模式(S

觀察模式C#實現實例

upd 添加 add mov user remove 定義 更新 鬧鐘 1.用例情景   1)定義一個鬧鐘(目標類),裏面我們感興趣的是時間值times,當times大於9.15時,通知觀察者。   2)定義兩個觀察者,userA,userB,當收到times值時,作出判斷

設計模式——觀察模式C++實現

ace mes des ret rtu cto pattern virt date 1 #include <iostream> 2 #include <vector> 3 #include <algorithm>

C#設計模式--觀察模式發布-訂閱模式

工廠方法 設計 解決 line strac itl names spa ret 0.C#設計模式--簡單工廠模式 1.C#設計模式--工廠方法模式 2.C#設計模式--抽象工廠模式 3.C#設計模式--單例模式 4.C#設計模式--建造者模式 5.C#設計模式--

設計模式觀察模式

針對 ray 需求 als bool 模式 null rri 主動 觀察者模式 定義了對象之間的一對多的依賴,這樣一來,當一個對象狀態改變時,他的 多有依賴都會受到通知並自動更新。 本例為一個溫度基站,和三個終端。溫度基站為廣播類WeatherData,三個終端監聽者類分別

Java設計模式補充:回調模式、事件監聽器模式觀察模式

應該 hand 關閉 lan china 關註 update 使用 event 一、回調函數 為什麽首先會講回調函數呢?因為這個是理解監聽器、觀察者模式的關鍵。 什麽是回調函數 所謂的回調,用於回調的函數。 回調函數只是一個功能片段,由用戶按照回調函數調用約定來實現的

事件_觀察模式

collect cti threading 發布 adk names [] 委托 mouse 一個類如果聲明一個Public的委托讓其他方法註冊,同樣也會存在外部直接調用此委托,這樣是有會出現莫名的調用風險的。因此就有了事件,事件無法在外部直接調用。外部只有註冊(定閱)。內

觀察模式監護

系統 對象 nbsp 依賴 之間 建立 bsp 觀察 觀察者模式 建立一種對象與對象之間的依賴關系,一個對象發生改變時將自動通知其他對象,其他對象將相應的作出反應。 在此發生改變的對象稱之為觀察目標(被觀察者),而被通知的對象稱為觀察者,

設計模式學習觀察模式C#

original pan 學習筆記 pri 接口 program date contain 兩個 《深入淺出設計模式》學習筆記第二章 需求: 開發一套氣象監測應用,如圖: 氣象站,目前有三種裝置,溫度、濕度和氣壓感應裝置。 WeatherData對象追蹤氣象站的數據,並更

觀察模式(Observer Pattern):HeadFirst中的氣象站的實現

att dex mov min first return 狀態 size sdi 1 觀察者模式的原理,首先由一個主題,當主題發送變化的時候,通知該主題的訂閱者 按照上面的分析我們來進行設計 1.抽象主題Subject public interface Subject {

設計模式4代理模式觀察模式

代理 bject body border 策略 解決 設計模式 server 觀察者 代理模式 本質是控制對主題對象的訪問 功能 目的 代理模式 但是代理對象則提供與目標對象相同的接口 控制對象的訪問 適配器模式 解決接口

C#設計模式(17)——觀察模式Observer Pattern

oid tar 自然 img info handler 這不 自身 dash 原文:C#設計模式(17)——觀察者模式(Observer Pattern)一、引言   在現實生活中,處處可見觀察者模式,例如,微信中的訂閱號,訂閱博客和QQ微博中關註好友,這些都屬於觀察者

觀察模式Observer

urn 保持 com highlight notify () inter pattern import 觀察者模式主要用於 1:N的通知。當一個對象(目標對象Subject或Objservable)的狀態變化時,他需要及時告知一系列對象(觀察者對象Observer),令它

GOF23設計模式觀察模式observer

hang 事件監聽器 rgs str arr public pda import lob 一、觀察者模式概述   觀察者模式主要用於 1 :N 的通知。當一個對象(目標對象 Subject 或 Observable)的狀態變化時,它需要通知一系列對象(觀察者對象 Obser

C#設計模式之十六觀察模式Observer Pattern【行為型】

ngx 現實生活 松耦合 mon html 機制 account current 很好 原文:C#設計模式之十六觀察者模式(Observer Pattern)【行為型】一、引言 今天是2017年11月份的最後一天,也就是2017年11月30日,利用今天再寫一個模式,爭取

【pattern】設計模式3 - Observer觀察模式

獨立 使用 數據 技術 很多 調用 edi 基於 ace 源碼地址:https://github.com/vergilyn/design-patterns 另外一個大神很全的Github:https://github.com/iluwatar/java-design-pat