服务器之家：专注于VPS、云服务器配置技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - C# - c# 实现观察者模式

c# 实现观察者模式

2022-10-26 13:35xhubobo C#

这篇文章主要介绍了c# 实现观察者模式的步骤，帮助大家更好的理解和使用c#实现设计模式，感兴趣的朋友可以了解下

说明：主要参考《Head First设计模式(中文版)》，使用C#代码实现。

代码：Github

1、观察者模式UML图

c# 实现观察者模式

2、气象监测类图

c# 实现观察者模式

3、气象监测代码(书中C#版)

3.1 Observer

?
1
2
3
4
public interface IObserver
{
    void Update(float temperature, float humidity, float pressure);
}
?
1
2
3
4
public interface IDisplayElement
{
    void Display();
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public class CurrentConditionDisplay : IObserver, IDisplayElement
{
    private readonly ISubject _weatherData;
 
    private float _temperature;
    private float _humidity;
 
    public CurrentConditionDisplay(ISubject weatherData)
    {
        _weatherData = weatherData;
        _weatherData?.RegisterObserver(this);
    }
 
    public void Update(float temperature, float humidity, float pressure)
    {
        _temperature = temperature;
        _humidity = humidity;
        Display();
    }
 
    public void Display()
    {
        Console.WriteLine($"Current Conditions: {_temperature}F degress and {_humidity}% humidity");
    }
}

3.2 Subject

?
1
2
3
4
5
6
public interface ISubject
{
    void RegisterObserver(IObserver o);
    void RemoveObserver(IObserver o);
    void NotifyObservers();
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
public class WeatherData : ISubject
{
    //观察者列表
    private readonly List<IObserver> _observerList;
 
    //天气数据
    private float _temperature;
    private float _humidity;
    private float _pressure;
 
    public WeatherData()
    {
        _observerList = new List<IObserver>();
    }
 
    /// <summary>
    /// 订阅观察者
    /// </summary>
    /// <param name="o">观察者对象</param>
    public void RegisterObserver(IObserver o)
    {
        _observerList.Add(o);
    }
 
    /// <summary>
    /// 移除观察者
    /// </summary>
    /// <param name="o">观察者对象</param>
    public void RemoveObserver(IObserver o)
    {
        if (_observerList.Contains(o))
        {
            _observerList.Remove(o);
        }
    }
 
    /// <summary>
    /// 发布数据
    /// </summary>
    public void NotifyObservers()
    {
        foreach (var observer in _observerList)
        {
            observer.Update(_temperature, _humidity, _pressure);
        }
    }
 
    /// <summary>
    /// 数据发生改变
    /// </summary>
    private void MeasurementChanged()
    {
        NotifyObservers();
    }
 
    /// <summary>
    /// 更新数据
    /// </summary>
    /// <param name="temperature">温度</param>
    /// <param name="humidity">湿度</param>
    /// <param name="pressure">气压</param>
    public void SetMeasurements(float temperature, float humidity, float pressure)
    {
        _temperature = temperature;
        _humidity = humidity;
        _pressure = pressure;
        MeasurementChanged();
    }
}

3.3 测试代码

?
1
2
3
4
5
6
7
8
9
private static void TestWeatherData()
{
    var weatherData = new WeatherData();
    var currentConditionDisplay = new CurrentConditionDisplay(weatherData);
 
    weatherData.SetMeasurements(80, 65, 30.4f);
    weatherData.SetMeasurements(82, 70, 29.2f);
    weatherData.SetMeasurements(78, 90, 29.2f);
}

4、使用C#中IObservable接口实现气象监测

4.1 辅助类/结构体

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
public struct WeatherMessage
{
    public float Temperature { get; set; }
    public float Humidity { get; set; }
    public float Pressure { get; set; }
}
 
public class MessageUnknownException : Exception
{
    internal MessageUnknownException()
    {
 
    }
}

4.2 IObserver具体实现

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
class CurrentConditionDisplayX : IObserver<WeatherMessage>, IDisplayElement
{
    private IDisposable _unsubscribe;
 
    private float _temperature;
    private float _humidity;
 
    public void Subscribe(IObservable<WeatherMessage> provider)
    {
        if (provider != null)
        {
            _unsubscribe = provider.Subscribe(this);
        }
    }
 
    public void Unsubscribe()
    {
        _unsubscribe?.Dispose();
        _unsubscribe = null;
    }
 
    public void OnCompleted()
    {
        Console.WriteLine("CurrentConditionDisplayX: OnCompleted");
        Unsubscribe();
    }
 
    public void OnError(Exception error)
    {
        Console.WriteLine("CurrentConditionDisplayX: OnError");
    }
 
    public void OnNext(WeatherMessage value)
    {
        _temperature = value.Temperature;
        _humidity = value.Humidity;
        Display();
    }
 
    public void Display()
    {
        Console.WriteLine($"Current Conditions: {_temperature}F degress and {_humidity}% humidity");
    }
}

4.3 IObservable具体实现

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
public class WeatherDataX : IObservable<WeatherMessage>
{
    private readonly List<IObserver<WeatherMessage>> _observerList;
 
    public WeatherDataX()
    {
        _observerList = new List<IObserver<WeatherMessage>>();
    }
 
    /// <summary>
    /// 通知提供程序：某观察程序将要接收通知。
    /// </summary>
    /// <param name="observer">要接收通知的对象。</param>
    /// <returns>使资源释放的观察程序的接口。</returns>
    public IDisposable Subscribe(IObserver<WeatherMessage> observer)
    {
        if(!_observerList.Contains(observer))
        {
            _observerList.Add(observer);
        }
        return new Unsubcriber(_observerList, observer);
    }
 
    public void SetMeasurements(Nullable<WeatherMessage> message)
    {
        foreach (var observer in _observerList)
        {
            if (!message.HasValue)
            {
                observer.OnError(new MessageUnknownException());
            }
            else
            {
                observer.OnNext(message.Value);
            }
        }
    }
 
    public void EndTransmission()
    {
        foreach (var observer in _observerList.ToArray())
        {
            if (_observerList.Contains(observer))
            {
                observer.OnCompleted();
            }
        }
        _observerList.Clear();
    }
 
    private class Unsubcriber : IDisposable
    {
        private List<IObserver<WeatherMessage>> _observerList;
        private IObserver<WeatherMessage> _observer;
 
        public Unsubcriber(List<IObserver<WeatherMessage>> observerList, IObserver<WeatherMessage> observer)
        {
            _observerList = observerList;
            _observer = observer;
        }
 
        public void Dispose()
        {
            if (_observerList != null && _observerList.Contains(_observer))
            {
                _observerList.Remove(_observer);
            }
        }
    }
}

4.4 测试代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
private static void TestWeatherDataX()
{
    var weatherData = new WeatherDataX();
    var currentConditionDisplay = new CurrentConditionDisplayX();
 
    currentConditionDisplay.Subscribe(weatherData);
 
    weatherData.SetMeasurements(new WeatherMessage()
    {
        Temperature = 80,
        Humidity = 65,
        Pressure = 30.4f
    });
    weatherData.SetMeasurements(new WeatherMessage()
    {
        Temperature = 82,
        Humidity = 70,
        Pressure = 29.2f
    });
    weatherData.SetMeasurements(new WeatherMessage()
    {
        Temperature = 78,
        Humidity = 90,
        Pressure = 29.2f
    });
    weatherData.EndTransmission();
}

以上就是c# 实现观察者模式的详细内容，更多关于c# 观察者模式的资料请关注服务器之家其它相关文章！

原文链接：https://www.cnblogs.com/xhubobo/p/11886301.html

  • C#
  • 观察者模式

    • 延伸 · 阅读

    精彩推荐
    • C#Unity3D实现相机跟随控制

      Unity3D实现相机跟随控制

      这篇文章主要为大家详细介绍了Unity3D实现相机跟随控制，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...

      c罗天下第一10612022-09-22
    • C#C#实现XML文档的增删改查功能示例

      C#实现XML文档的增删改查功能示例

      这篇文章主要介绍了C#实现XML文档的增删改查功能,结合实例形式分析了xml文档的创建及C#针对xml文档的加载及增删改查等操作技巧,需要的朋友可以参考下...

      pan_junbiao7192021-12-21
    • C#C#的Excel导入、导出

      C#的Excel导入、导出

      这篇文章主要为大家详细介绍了C#的Excel导入、导出的相关资料,需要的朋友可以参考下...

      polk65252021-11-22
    • C#C#制作多线程处理强化版网络爬虫

      C#制作多线程处理强化版网络爬虫

      这篇文章主要介绍了C#制作多线程处理强化版网络爬虫的相关代码，有想学习C#多线程编程的小伙伴可以参考下...

      魇7692021-12-06
    • C#C#微信开发之接收 / 返回文本消息

      C#微信开发之接收 / 返回文本消息

      本文主要介绍了C#微信开发之接收 / 返回文本消息原理与实现方法，具有一定的参考价值，下面跟着小编一起来看下吧...

      likar11222021-12-22
    • C#C# 基础入门--变量

      C# 基础入门--变量

      本文主要介绍了C#中变量的基础知识，具有很好的参考价值。下面跟着小编一起来看下吧...

      辰星crystal4952021-12-28
    • C#C#与PHP的md5计算结果不同的解决方法

      C#与PHP的md5计算结果不同的解决方法

      今天在用C#接入我的登录api发现了一个问题，登陆的时候无论如何都会出现用户名和密码错误的问题，后来通过查找排除找的了问题的原因是因为C#与PHP的...

      ifengge3702021-12-15
    • C#VS2019配置OpenCV4.1.0详细教程与测试代码(推荐)

      VS2019配置OpenCV4.1.0详细教程与测试代码(推荐)

      这篇文章主要介绍了VS2019配置OpenCV4.1.0详细教程与测试代码,本文通过截图实例代码相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴...

      Kratze-Jayue3302022-08-30
    最近更新
    编辑推荐
    阅读排行
    热门标签
    Server-sent 　 osg 　 刷新桌面 　 nancy 　 TaskManager 　 网站授权 　 下拉式 　 DirectoryEntry 　 C#编程 　 网站功能 　 通知窗口 　 相互关系 　 语句顺序 　 编程错误 　 悬浮框 　 Dispose 　 滚动新闻 　 HttpPost 　 静态构造函数 　 焦点 　 类型派生 　 深度拷贝 　 小写转大写金额 　 任务并行库 　 众数 　 更新数据库 　 统计字数 　 二乘法 　 IComparer 　 DataBinding 　
    © 2019-2022 服务器之家(www.tuohang.net) 版权所有关于我们联系我们版权申明网站地图