设计模式(行为模式)——观察者模式

1 定义

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

2 适用性

1)当一个抽象模型有两个方面,其中一个方面依赖于另一个方面。将二者封装在独立的对象中以使它们可以各自独立地改变和复用。

2)当对一个对象的改变需要同时改变其他对象,而不知道具体有多少对象有待改变时。

3)当一个对象必须通知其他对象,而它又不能假定其它对象是谁。换言之,你不希望这些对象是紧密耦合的。

3 结构

说明:

1)Subject(目标):目标知道它的观察者。可以有任意多个观察者观察同一个目标。提供注册和删除观察者对象的接口。

2)Observer(观察者):为那些在目标发生改变时需要获得通知的对象定义一个更新接口。

3)ConcreteSubject(具体目标):将有关状态存入各ConcreteObserver对象。当它的状态发生改变时,向它的各个观察者发出通知。

4)ConcreteObserver(具体观察者):维护一个指向ConcreteSubject对象的引用。存储有关状态,这些状态应与目标的状态保持一致。实现Observer的更新接口以使自身状态与目标的状态保持一致。

举例:

1消息广播

一个消息发布者,两个消息订阅者。发布者广播新的消息时,所有的订阅者都自动接收新的消息。

目标(发布者)

public interface ISubject
    {
        void SendMessage(string message);
    }

目标的实现

public class Subject : ISubject
{
        public Action<string> PublishMessage;

        public void SendMessage(string message)
        {
            PublishMessage(message);
        }
}

观察者(订阅者)

public interface IObserver
{
        void GetNewMessage(string message);
}
public class Person1 : IObserver
{
        public void GetNewMessage(string message)
        {
            Console.WriteLine("第一个人接收到新消息:" + message);
        }
}
public class Person2 : IObserver
{
        public void GetNewMessage(string message)
        {
            Console.WriteLine("第二个人接收到新消息:" + message);
        }
}

连接目标与观察者

static void Main(string[] args)
        {
            Person1 pf = new Person1();
            Person2 p2 = new Person2();
            Subject s = new Subject();
            s.PublishMessage += pf.GetNewMessage;
            s.PublishMessage += p2.GetNewMessage;
            while(true)
            {
   Console.WriteLine("广播消息:");
                s.SendMessage(Console.ReadLine()); 
            }
        }

运行结果:

2 模拟温度调控器

设置最高温与最低温,当输入温度大于最高温时,开始冷却器,关闭加热器;当输入温度小于最低温时,相反。

目标(发布者)

public interface ISubject
{
        float CurrentTemperature { get; set; }
}

目标实现

public class Subject:ISubject
{
        private float _CT;
        public Action<float> PublishMessage;
        public float CurrentTemperature
        {
            get
            {
                return _CT;
            }
            set
            {
                if (this._CT != value)
                {
                    PublishMessage(value);
                }
            }
        }
}

观察者(订阅者)

public interface IObserver
{
        float Temperature { get; set; }

        void TemperatureChanged(float newTemperature);
}

加热器:

public class Heater : IObserver
    {
        public float Temperature { set; get; }
        public Heater(float temperature)
        {
            Temperature = temperature;
            Console.WriteLine("温度最大值:" + temperature);
        }
        

        public void TemperatureChanged(float newTemperature)
        {
            if (newTemperature > Temperature)
            {
                Console.WriteLine("加热器关闭");
            }
            else if (newTemperature == Temperature)
            {
                Console.WriteLine("加热器关闭");
            }
            else
            {
                Console.WriteLine("加热器开启");
            }
        }
    }

制冷器:

public class Cooler : IObserver
    {
        public Cooler(float temperature)
        {
            Temperature = temperature;
            Console.WriteLine("温度最小值:" + temperature);
        }

        public float Temperature{set;get;}
        public void TemperatureChanged(float newTemperature)
        {
            if (newTemperature > Temperature)
            {
                Console.WriteLine("制冷器开启");
            }
            else if (newTemperature == Temperature)
            {
                Console.WriteLine("制冷器关闭");
            }
            else
            {
                Console.WriteLine("制冷器关闭");
            }
        }
    }

连接目标与观察者

static void Main(string[] args)
{
            Heater h = new Heater(60);
            Cooler c = new Cooler(50);
            Pattern.Observer.Subject sub = new Pattern.Observer.Subject();
            sub.PublishMessage += h.TemperatureChanged;
            sub.PublishMessage += c.TemperatureChanged;
            while (true)
            {
                Console.WriteLine("输入温度:");
                string temp = Console.ReadLine();
                sub.CurrentTemperature = float.Parse(temp);
            }
}

运行结果:

3 观察者模式在Winform中的应用

在PM模式中,视图没有向控制器暴露出任何接口,那么控制器如何更新视图UI呢?一种比较简单的方式就是利用观察者模式。控制器相当于目标,视图层相当于观察者,当控制器接收到视图层数据后,更新模型,然后向所有观察者广播这一消息,视图层接收到消息后,完成更新UI的任务。代码示例见表现层设计模式那一章。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏用户画像

3.3 差错控制

概括地说,传输中的差错都是由于噪声引起的。噪声有两大类:一类是信道中所固定的、持续存在的随机热噪声;另一类是由于外界特定个的短暂原因所造成的冲击噪声。前者可以通...

621
来自专栏Java技术分享

Java基础常见英语词汇

Java基础常见英语词汇(共70个) OO:object-oriented ,面向对象

2007
来自专栏我就是马云飞

Rxjava2最全面的解析

前言 由于公司重新规划的部门,我调到了另外一个部门,所以负责的项目也换了,仔细看了下整体的项目,rxjava+retrofit。整体的一套。众所周知,rxja...

2229
来自专栏余林丰

利用Java提供的Observer接口和Observable类实现观察者模式

对于观察者模式,其实Java已经为我们提供了已有的接口和类。对于订阅者(Subscribe,观察者)Java为我们提供了一个接口,JDK源码如下: 1 pack...

1818
来自专栏androidBlog

Android AIDL 传递对象(Parceable)

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/gdutxiaoxu/article/de...

252
来自专栏数据之美

BloomFilter 简介及在 Hadoop reduce side join 中的应用

1、BloomFilter能解决什么问题?      以少量的内存空间判断一个元素是否属于这个集合, 代价是有一定的错误率 2、工作原理 ...

1767
来自专栏wannshan(javaer,RPC)

dubbo监控机制之监控中心实现分析

这里的监控中心以dubbo-ops\dubbo-monitor-simple项目说 总的来说是监控中心启动一个sevlet容器,通过web页面向用户多维度的展...

3556
来自专栏翻译

路径查找器AI

问题源于我想建立一个游戏AI,它要能够定义一条从起点到终点的路径,同时避开路上的墙壁障碍物。为此,我写了一个C#库(path.dll),它允许定义一个二维空间(...

1947
来自专栏函数式编程语言及工具

FunDA(9)- Stream Source:reactive data streams

    上篇我们讨论了静态数据源(Static Source, snapshot)。这种方式只能在预知数据规模有限的情况下使用,对于超大型的数据库表也可以说是不...

18810
来自专栏智能大石头

8,协议序列化组件NewLife.Serialization

在开发某些需要跟第三方平台交互的项目时,往往需要解析或者构造符合对方协议要求的数据格式,该操作在.Net中有个很漂亮的名字——序列化! 在实际使用中,XML序列...

17110

扫描关注云+社区