当前位置:
首页 > 编程开发 > Objective-C编程 >
-
C# IObservable与IObserver观察者模式
C#中提供了IObservable<T>接口和IObserver<T>接口来实现观察者模式,IObservable<T>相当于Subject(主题)接口,下面我们就以代吗来说明下如何利用.net框架提供的观察者模式接口。
WeatherData类包含气温,湿度,气压等属性。
class WeatherData { /// <summary> /// 气温 /// </summary> public string temperature { get; set; } /// <summary> /// 湿度 /// </summary> public string humility { get; set; } /// <summary> /// 气压 /// </summary> public string pressure { get; set; } }
WeatherDataPublisher类实现了IObservable接口,实现了Subscribe订阅方法。
class WeatherDataPublisher : IObservable<WeatherData> { List<IObserver<WeatherData>> observers = new List<IObserver<WeatherData>>(); /// <summary> /// 订阅主题,将观察者添加到列表中 /// </summary> /// <param name="observer"></param> /// <returns></returns> public IDisposable Subscribe(IObserver<WeatherData> observer) { observers.Add(observer); return new Unsubscribe(this.observers, observer); } /// <summary> /// 取消订阅类 /// </summary> private class Unsubscribe : IDisposable { List<IObserver<WeatherData>> observers; IObserver<WeatherData> observer; public Unsubscribe(List<IObserver<WeatherData>> observers , IObserver<WeatherData> observer) { this.observer = observer; this.observers = observers; } public void Dispose() { if (this.observers != null) { this.observers.Remove(observer); } } } /// <summary> /// 通知已订阅的观察者 /// </summary> /// <param name="weatherData"></param> private void Notify(WeatherData weatherData) { foreach (var observer in observers) { observer.OnNext(weatherData); } } /// <summary> /// 接收最新的天气数据 /// </summary> /// <param name="weatherData"></param> public void ReciveNewData(WeatherData weatherData) { Notify(weatherData); } }
下面我们建立一个抽象类WeatherDisplayBase实现了IObserver接口,所有的天气展示板(观察者)继承这个抽象类,需实现OnNext方法,即接收到新数据推送后要进行的数据处理展示工作,并且可重写OnCompleted,OnError方法。
abstract class WeatherDisplayBase : IObserver<WeatherData> { public virtual void OnCompleted() { } public virtual void OnError(Exception error) { } public abstract void OnNext(WeatherData value); }
CurrentConditionDisplay类为当前天气状况展示板,继承WeatherDisplayBase抽象类,展示最新的天气数据。
class CurrentConditionDisplay : WeatherDisplayBase { public override void OnNext(WeatherData value) { Console.WriteLine("------------------"); Console.WriteLine("当前天气状况板"); Console.WriteLine(string.Format("温度:{0}\n湿度:{1}\n气压:{2}", value.temperature, value.humility, value.pressure)); } }
StatisticsConditionDisplay类为气温统计展示板,继承WeatherDisplayBase抽象类,展示历史最高温度,最低温度,平均温度。
class StatisticsConditionDisplay : WeatherDisplayBase { List<float> temperatures = new List<float>(); public override void OnNext(WeatherData value) { float temperature; if (float.TryParse(value.temperature, out temperature)) { temperatures.Add(temperature); } Console.WriteLine("------------------"); Console.WriteLine("温度统计板"); Console.WriteLine(string.Format("平均温度:{0}\n最高温度:{1}\n最低温度:{2}", temperatures.Average(), temperatures.Max(), temperatures.Min())); } }
使用方法
class Program { static void Main(string[] args) { WeatherDataPublisher publisher = new WeatherDataPublisher(); CurrentConditionDisplay currentDisplay=new CurrentConditionDisplay(); StatisticsConditionDisplay statisticsDisplay = new StatisticsConditionDisplay(); //订阅当前天气展示板 IDisposable currentDisplayUnsubscriber= publisher.Subscribe(currentDisplay); //订阅气温统计展示板 IDisposable statisticsDisplayUnsubscriber = publisher.Subscribe(statisticsDisplay); for (int i = 0; ; i++) { WeatherData weatherData = new WeatherData(); Console.WriteLine("请输入温度,湿度,压力"); string input = Console.ReadLine(); var array= input.Split(','); weatherData.temperature = array[0]; weatherData.humility = array[1]; weatherData.pressure = array[2]; Console.WriteLine(""); //将输入的新的天气数据传给天气数据发布器 publisher.ReciveNewData(weatherData); Console.WriteLine("============================="); } } }
文章出处:https://www.cnblogs.com/chenyishi/p/13530026.html
最新更新
nodejs爬虫
Python正则表达式完全指南
爬取豆瓣Top250图书数据
shp 地图文件批量添加字段
爬虫小试牛刀(爬取学校通知公告)
【python基础】函数-初识函数
【python基础】函数-返回值
HTTP请求:requests模块基础使用必知必会
Python初学者友好丨详解参数传递类型
如何有效管理爬虫流量?
2个场景实例讲解GaussDB(DWS)基表统计信息估
常用的 SQL Server 关键字及其含义
动手分析SQL Server中的事务中使用的锁
openGauss内核分析:SQL by pass & 经典执行
一招教你如何高效批量导入与更新数据
天天写SQL,这些神奇的特性你知道吗?
openGauss内核分析:执行计划生成
[IM002]Navicat ODBC驱动器管理器 未发现数据
初入Sql Server 之 存储过程的简单使用
SQL Server -- 解决存储过程传入参数作为s
JavaScript判断两个数组相等的四类方法
js如何操作video标签
React实战--利用甘特图和看板,强化Paas平
【记录】正则替换的偏方
前端下载 Blob 类型整理
抽象语法树AST必知必会
关于JS定时器的整理
JS中使用Promise.all控制所有的异步请求都完
js中字符串的方法
import-local执行流程与node模块路径解析流程