观察者模式

C#设计模式】16.观察者模式（Observer Pattern）【行为型】

介绍

  “观察者模式”在现实生活中，实例其实是很多的，比如：八九十年代我们订阅的报纸，我们会定期收到报纸，因为我们订阅了。银行可以给储户发手机短信，也是“观察者模式”很好的使用的例子，因为我们订阅了银行的短信业务，当我们账户余额发生变化就会收到通知等等。

  意图：定义对象间的一种一对多的依赖关系，以便当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并自动更新。

模式的组成

可以看出，在观察者模式的结构图有以下角色：

（1）抽象主题角色（Subject）：抽象主题把所有观察者对象的引用保存在一个列表中，并提供增加和删除观察者对象的操作，抽象主题角色又叫做抽象被观察者角色，一般由抽象类或接口实现。

（2）抽象观察者角色（Observer）：为所有具体观察者定义一个接口，在得到主题通知时更新自己，一般由抽象类或接口实现。

（3）具体主题角色（ConcreteSubject）：实现抽象主题接口，具体主题角色又叫做具体被观察者角色。

（4）具体观察者角色（ConcreteObserver）：实现抽象观察者角色所要求的接口，以便使自身状态与主题的状态相协调。

例程

  用邮局订报做例子。

两个接口

PostOfficeSystem：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DesignPattern.观察者模式.测试
{
    /// <summary>
    /// 抽象主题角色，邮局接口
    /// </summary>
    internal interface PostOfficeSystem
    {
        /// <summary>
        /// 用户订阅
        /// </summary>
        void Add(UserSystem user);

        /// <summary>
        /// 取消订阅
        /// </summary>
        void Remove(UserSystem user);

        /// <summary>
        /// 通知用户
        /// </summary>
        void Notify();
    }
}

UserSystem：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DesignPattern.观察者模式.测试
{
    /// <summary>
    /// 抽象观察者角色，用户
    /// </summary>
    internal interface UserSystem
    {
        void Update();
    }
}

两个实现类：

邮局PostOffice:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DesignPattern.观察者模式.测试
{
    /// <summary>
    /// 具体主题角色，邮局
    /// </summary>
    internal class PostOffice : PostOfficeSystem
    {
        public List<UserSystem> users;

        public PostOffice()
        {
            users = new List<UserSystem>();
        }

        /// <summary>
        /// 用户订阅
        /// </summary>
        /// <param name="user"></param>
        public void Add(UserSystem user)
        {
            users.Add(user);
        }

        /// <summary>
        /// 通知用户
        /// </summary>
        public void Notify()
        {
            foreach (var user in users)
            {
                user.Update();
            }
        }

        /// <summary>
        /// 用户取消订阅
        /// </summary>
        /// <param name="user"></param>
        public void Remove(UserSystem user)
        {
            users.Remove(user);
        }
    }
}

 用户类User:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DesignPattern.观察者模式.测试
{
    internal class User : UserSystem
    {
        public string UserName, Newspaper;
        public User(string UserName, string Newspaper)
        {
            this.UserName = UserName;
            this.Newspaper = Newspaper;
        }
        public void Update()
        {
            Console.WriteLine($"用户{UserName}购买的{Newspaper}已到货......");
        }
    }
}

输出:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DesignPattern.观察者模式.测试
{
    internal class Program
    {
        private static void Main(string[] args)
        {
            UserSystem user1 = new User("小明", "《三国演义》");
            UserSystem user2 = new User("小华", "《水浒传》");
            UserSystem user3 = new User("小亮", "《红楼梦》");

            PostOfficeSystem postOffice = new PostOffice();
            postOffice.Add(user1);
            postOffice.Add(user2);
            postOffice.Add(user3);

            postOffice.Notify();

            Console.ReadLine();
        }
    }
}

结果：