C# 观察者模式 以及 delegate 和 event

观察者模式

这里面综合了几本书的资料.

需求

有这么个项目: 

需求是这样的:

一个气象站, 有三个传感器(温度, 湿度, 气压), 有一个WeatherData对象, 它能从气象站获得这三个数据. 还有三种设备, 可以按要求展示气象站的最新数据.

WeatherData的结构如下:

有3个get方法, 分别获取最新的气温, 湿度和气压. 还有一个measurementsChanged()方法, 当任一传感器有变化的时候, 这个方法都会被调用.

总结一下项目的需求:

  • WeatherData类有三个get方法可以获取温度, 湿度和气压

  • 如果任何一个数据发生变化, 那么measureChanged()方法就会被调用

  • 我们需要实现这三种显示设备:

    •   当前天气

    •   数据统计

    •   天气预测

  • 系统必须可以扩展, 其他开发者可以创建自定义展示设备.

初版代码

这个地方有个"错误", xxxDisplay都是具体的实现, 而编程规则要求是应该对接口编程而不是对实现编程.

那么什么是观察者模式?

举一个例子:

  1. 报社发行报纸

  2. 你订阅报纸, 一旦有新一期的报纸发行, 新报纸就会送到你家里, 只要你一直订阅, 你就一直会收到新报纸

  3. 你不再订阅报纸的时候, 就收不到以后的新报纸了

  4. 报社运营的时候, 一直会有人去订阅或者取消订阅报纸.

发布者 + 订阅者 = 观察者模式
Publishers + Subscribers = Observer Pattern
在观察者模式里, 我们把报社叫做被观察对象(Subject), 把订阅者叫做观察者(Observers)

观察者模式是这样操作的:

  

观察者模式的定义就是:

一个目标物件管理所有相依于它的观察者物件,并且在它本身的状态改变时主动发出通知

类图如下:

 

谈一下松耦合

当两个对象是松耦合的时候, 他们可以进行交互, 但是却几乎不了解对方.
观察者模式下的被观察者(Subject)和观察者(Observers)就是松耦合设计的对象. 这是因为:

  • 被观察者(Subject)只知道观察者实现了某个接口

  • 可以随时添加观察者

  • 添加新类型观察者的时候不需要修改被观察者

  • 可以复用观察者或者被观察者

  • 如果被观察者或观察者发生变化了, 那么这些变化不会影响到对方.

一个设计原则:

交互的对象之间应尽量设计成松耦合的. Strive for loosely coupled designs between objects that interact.
松耦合设计可以让我们设计出这样的系统: 因为对象之间的相互依存减小了, 所以系统可以轻松处理变化.

重新设计:

代码:

OK, 上面是书中的内容, C#7.0里面对观察者模式是怎么实现的呢?

先只谈下面这个:

Event

谈到Event, 就得把delegate先细说一下

Delegate 委托

一个委托类型定义了某种类型的方法(方法的返回类型和参数类型), 然后这个委托的实例可以调用这些方法.

例如:

delegate int Transformer (int x);

这个委托就和返回类型是int, 参数是一个int的方法兼容.

例如:

static int Square (int x) { return x * x };//static int Square (int x) => x * x;

 

把一个方法赋值给委托变量的时候就创建了一个委托的实例:

Transformer t = Square;

 

然后就可以像方法一样进行调用:

int answer = t(3); // 9

 

所以说一个委托的实例就是调用者的委托: 调用者调用委托, 然后委托调用目标方法, 这样就把调用者和目标方法解耦了.

其中:

Transformer t = Square;// 是下面的简写Transformer t = new Transformer(Square);

 

t(3)// 是下面的简写t.Invoke(3)

 

多播委托

一个委托实例可以引用多个目标方法. 使用+=操作符.

SomeDelegate d = Method1;
d += Method2;// 第二行相当于:d = d + Method2;

 

调用d的时候就会调用Method1和Method2两个方法.

委托方法的调用顺序和它们被添加的顺序是一样的.

使用-=操作符来移除目标方法:

d -= Method1;

 

这时调用d后只会执行Method2了.

注意: 委托是不可变的 +=/-=实际上是创建了新的委托.

多播委托返回类型

如果多播委托有返回值(非void), 那么调用者只会获得最后一个被调用方法的返回值.

委托也可以使用泛型:

public delegate T Transformer<T> (T arg);

 

Func 和 Action

记住Func有返回值, Action没有就行.

 

Event

使用委托的时候, 通常会有两个角色出现: 广播者(被观察者)和订阅者(观察者) [观察者模式]

广播者包含一个委托field, 广播者决定何时广播, 它通过调用委托进行广播.

订阅者就是方法的目标接收者.订阅者可以决定何时开始和结束监听, 是通过在广播者的委托上使用+=和-=操作符来实现的.

订阅者之间互相不了解, 不干扰.

event就是为上述模型所存在的, 它只把上述模型所必须的功能从委托里暴露出来. 它的主要目的就是防止订阅者之间相互干扰.

最简单声明event的方法就是在委托成员前面加上event关键字:

public delegate void SomeChangedHandler(decimal x);


public class Broadcaster

{

    public event SomeChangedHandler handler;

}

在Broadcaster类里面的代码, 可以把handler作为委托一样来用.

在Broadcaster类外边, 只能对这个event执行+=和-=操作.

 

Event 模式/ 观察者模式

这种模式在.net core里首先需要EventArgs.

EventArgs是一个基类, 它可以为event传递信息.

可以创造它的子类来传递自定义参数:

public class FallsIllEventArgs : EventArgs

    {

        public readonly string Address;


        public FallsIllEventArgs(string address)

        {

            this.Address = address;

        }

    }

然后就需要给这个event定义一个委托了, 这有三条规则:

  • 返回类型必须是void

  • 需要有两个参数, 第一个是object, 第二个是EventArgs的子类. 第一个参数代表着广播者, 第二个参数包含额外的需要传递的信息.

  • 名称必须以EventHandler结束.

.net core定义了System.EventHandler<>, 它满足这些要求.

public event EventHandler<FallsIllEventArgs> FallsIll;

 

最后, 需要写一个 protected virtual 方法可以触发event. 方法的名称必须和event匹配: 以On开头, 接受EventArgs类型的参数:

        public void OnFallsIll(){FallsIll?.Invoke(this, new FallsIllEventArgs("China Beijing"));}

 注意: 预定义的非泛型的EventHandler委托可以在没有数据需要传输的时候使用, 调用的时候可以使用EventArgs.Empty来避免不必要的初始化EventArgs.

 

用.net core 实现观察者模式的代码:

Person.cs

using System;


namespace ObserverPattern

{

    public class Person

    {

        public event EventHandler<FallsIllEventArgs> FallsIll;


        public void OnFallsIll()

        {

            FallsIll?.Invoke(this, new FallsIllEventArgs("China Beijing"));

        }


    }

}

FallsIllEventArgs.cs:

using System;


namespace ObserverPattern

{

    public class FallsIllEventArgs : EventArgs

    {

        public readonly string Address;


        public FallsIllEventArgs(string address)

        {

            this.Address = address;

        }

    }

}

Program.cs:


using System;


namespace ObserverPattern

{

    class Program

    {

        static void Main(string[] args)

        {

            var person = new Person();

            person.FallsIll += OnFallsIll;

            person.OnFallsIll();

            person.FallsIll -= OnFallsIll;

        }


        private static void OnFallsIll(object sender, FallsIllEventArgs eventArgs)

        {

            Console.WriteLine($"A doctor has been called to {eventArgs.Address}");

        }

    }

}

原文地址 https://www.cnblogs.com/cgzl/p/8688476.html


.NET社区新闻,深度好文,欢迎访问公众号文章汇总 http://www.csharpkit.com

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/321789.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

2、JAVA开发环境的搭建

上次说到java应用之所以做到跨平台&#xff0c;是因为其依赖于java虚拟机&#xff0c;java想要运行需要依赖于特定的运行环境&#xff0c;称为JRE&#xff0c;如果想要开发java应用&#xff0c;则需要用到开发工具包&#xff0c;也就是JDK&#xff0c;所以这里就要说一下这几者…

Serilog Tutorial

在过去的几年中&#xff0c;结构化日志已经大受欢迎。而Serilog是 .NET 中最著名的结构化日志类库 ,我们提供了这份的精简指南来帮助你快速了解并运用它。0. 内容设定目标认识Serilog事件和级别触发和收集结构化数据为过滤和关联添加事件标记大海捞针 [Finding needles in the …

使用DDD、事件风暴和Actor来设计反应式系统

领域驱动设计&#xff08;domain-driven design&#xff0c;DDD&#xff09;通常在微服务领域用于查找边界&#xff08;限界上下文&#xff09;。同样来自DDD的聚合&#xff08;aggregate&#xff09;对于定义持久化和一致性的范围来讲也是很重要的。 但是&#xff0c;并不是领…

站在巨人肩上的.NET Core 2.1

.NET Core 1.0自发布两年以来&#xff0c;得到了开发者群体相当高地认可。 下图来自Stack overflow survey 2018的统计&#xff1a;.NET Core已经成为前五的主流框架工具&#xff0c;现今借鉴了优秀的设计原则和开发体验可谓站在巨人肩上。这一切归功于.NET团队认识和总结了大量…

5、java中的数组

1、简介 数组是一种具有随机存取特性的数据结构&#xff0c;是内存上一段连续区域的表示&#xff0c;是实现顺序存储的基础&#xff0c;数组只能用于存储同一类型的数据。数组的长度在初始化时定义之后就不可更改&#xff0c;并且在初始化数组时必须指定数组的长度。 2、数组…

动态规划训练19、最短路 [Help Jimmy POJ - 1661 ]

Help Jimmy POJ - 1661 题意&#xff1a;大致是一个人从某个点开始下落&#xff0c;下落的速度是1m/s&#xff0c;然后在平台上的时候可以左右移动&#xff0c;移动的速度也是1m/s&#xff0c;但是这里有一个限制&#xff0c;就是说每次下落的距离不能超过一个给定的数值。问你…

【活动(北京)】Global Azure Bootcamp

活动议程活动内容08:30-08:50报到08:50-09:10活動开场Study4 - 陈科融(MVP)STB Chain Foundation - 劉海峰(MVP)MVP Program - Christina Liang(MVP CPM)09:10-10:00区块链让软件资产化成为现实刘海峰(MVP) - STBChain Foundation主席10:10-11:00基于Azure PaaS的网站应用刘元纶…

6、java中的排序算法

1、简介 排序是将元素按着指定关键字的大小递增或递减进行数据的排列&#xff0c;排序可以提高查找的效率 2、排序算法的分类 排序算法可大致分为四类七种&#xff0c;具体分类如下&#xff1a; 插入排序&#xff1a;直接插入排序、希尔排序 交换排序&#xff1a;冒泡排序、…

用.NET Core实现装饰模式和.NET Core的Stream简介

该文章综合了几本书的内容.某咖啡店项目的解决方案某咖啡店供应咖啡, 客户买咖啡的时候可以添加若干调味料, 最后要求算出总价钱.Beverage是所有咖啡饮料的抽象类, 里面的cost方法是抽象的. description变量在每个子类里面都需要设置(表示对咖啡的描述).每个子类实现cost方法, …

这个拖后腿的“in”

问题之源C# 7.2推出了全新的参数修饰符in&#xff0c;据说是能提升一定的性能&#xff0c;官方MSDN文档描述是&#xff1a;Add the in modifier to pass an argument by reference and declare your design intent to pass arguments by reference to avoid unnecessary copyin…

Surging 微服务框架使用入门

前言本文非 Surging 官方教程&#xff0c;只是自己学习的总结。如有哪里不对&#xff0c;还望指正。 我对 surging 的看法我目前所在的公司采用架构就是类似与Surging的RPC框架&#xff0c;在.NET 4.0框架上搭建Socket RPC&#xff0c;通过分组轮询的方式调度RPC&#xff0c;经…

RabbitMQ教程C#版 - 工作队列

先决条件本教程假定RabbitMQ已经安装&#xff0c;并运行在localhost标准端口&#xff08;5672&#xff09;。如果你使用不同的主机、端口或证书&#xff0c;则需要调整连接设置。从哪里获得帮助如果您在阅读本教程时遇到困难&#xff0c;可以通过邮件列表联系我们。1.工作队列&…

IdentityServer4实战 - 基于角色的权限控制及Claim详解

一.前言大家好&#xff0c;许久没有更新博客了&#xff0c;最近从重庆来到了成都&#xff0c;换了个工作环境&#xff0c;前面都比较忙没有什么时间&#xff0c;这次趁着清明假期有时间&#xff0c;又可以分享一些知识给大家。在QQ群里有许多人都问过IdentityServer4怎么用Role…

11、java中的I/O流(1)

我对于流的理解是这样的&#xff0c;计算机的本质本来就是对输入的数据进行操作&#xff0c;然后将结果输出的一种工具&#xff0c;数据在各个数据源节点之间进行流动&#xff0c;感觉流就是对这种状态的一种抽象&#xff0c;一个数据流表示的就是一系列数据序列&#xff0c;ja…

ASP.NET Core 集成测试

集成测试集成测试&#xff0c;也叫组装测试或联合测试。在单元测试的基础上&#xff0c;将所有模块按照设计要求&#xff08;如根据结构图&#xff09;组装成为子系统或系统&#xff0c;进行集成测试。实践表明&#xff0c;一些模块虽然能够单独地工作&#xff0c;但并不能保证…

使用C#开发Android应用之WebApp

近段时间了解了一下VS2017开发安卓应用的一些技术&#xff0c;特地把C#开发WebApp的一些过程记录下来&#xff0c;欢迎大家一起指教、讨论&#xff0c;废话少说&#xff0c;是时候开始表演真正的技术了。。1、新建空白Android应用2、拖一个WebView控件进来3、打开模拟器Genymot…

ASP.NET Core依赖注入深入讨论

这篇文章我们来深入探讨ASP.NET Core、MVC Core中的依赖注入&#xff0c;我们将示范几乎所有可能的操作把依赖项注入到组件中。依赖注入是ASP.NET Core的核心&#xff0c;它能让您应用程序中的组件增强可测试性&#xff0c;还使您的组件只依赖于能够提供所需服务的某些组件。举…

使用静态基类方案让 ASP.NET Core 实现遵循 HATEOAS Restful Web API

Hypermedia As The Engine Of Application State (HATEOAS)HATEOAS&#xff08;Hypermedia as the engine of application state&#xff09;是 REST 架构风格中最复杂的约束&#xff0c;也是构建成熟 REST 服务的核心。它的重要性在于打破了客户端和服务器之间严格的契约&…

【招聘(北京)】.NETCORE开发工程师(微服务方向)

组织&#xff1a;华汽集团北京研发中心位置&#xff1a;北京市朝阳区焦奥中心官网&#xff1a;www.sinoauto.com邮箱&#xff1a;taoxu.weisinoauto.com 项目&#xff1a;打造面向国内汽车后市场用户的一站式云服务平台&#xff08;华汽云&#xff09;&#xff0c;形态包括B2B、…

确保线程安全下使用Queue的Enqueue和Dequeue

场景是这样&#xff0c;假设有一台设备会触发类型为Alarm的告警信号&#xff0c;并把信号添加到一个Queue结构中&#xff0c;每隔一段时间这个Queue会被遍历检查&#xff0c;其中的每个Alarm都会调用一个相应的处理方法。问题在于&#xff0c;检查机制是基于多线程的&#xff0…