c# 實現(xiàn)觀察者模式
更新時間：2021年01月07日 16:54:28 作者：xhubobo
這篇文章主要介紹了c# 實現(xiàn)觀察者模式的步驟，幫助大家更好的理解和使用c#實現(xiàn)設計模式，感興趣的朋友可以了解下
說明：主要參考《Head First設計模式(中文版)》，使用C#代碼實現(xiàn)。
代碼：Github
1、觀察者模式UML圖
2、氣象監(jiān)測類圖
3、氣象監(jiān)測代碼(書中C#版)
3.1 Observer
public interface IObserver
{
void Update(float temperature, float humidity, float pressure);
}
public interface IDisplayElement
{
void Display();
}
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
public interface ISubject
{
void RegisterObserver(IObserver o);
void RemoveObserver(IObserver o);
void NotifyObservers();
}
public class WeatherData : ISubject
{
//觀察者列表
private readonly List<IObserver> _observerList;
//天氣數(shù)據(jù)
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>
/// 發(fā)布數(shù)據(jù)
/// </summary>
public void NotifyObservers()
{
foreach (var observer in _observerList)
{
observer.Update(_temperature, _humidity, _pressure);
}
}
/// <summary>
/// 數(shù)據(jù)發(fā)生改變
/// </summary>
private void MeasurementChanged()
{
NotifyObservers();
}
/// <summary>
/// 更新數(shù)據(jù)
/// </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 測試代碼
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接口實現(xiàn)氣象監(jiān)測
4.1 輔助類/結構體
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具體實現(xiàn)
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具體實現(xiàn)
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 測試代碼
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# 實現(xiàn)觀察者模式的詳細內容，更多關于c# 觀察者模式的資料請關注腳本之家其它相關文章！
相關文章
C#中Html.RenderPartial與Html.RenderAction的區(qū)別分析
這篇文章主要介紹了C#中Html.RenderPartial與Html.RenderAction的區(qū)別分析,需要的朋友可以參考下2014-07-07
這篇文章主要為大家詳細介紹了C#在winform中的表格操作CSV格式文件的相關實例,文中的示例代碼講解詳細,感興趣的小伙伴可以參考一下2025-03-03
這篇文章主要為大家詳細介紹了C#實現(xiàn)汽車租賃系統(tǒng)的具體實現(xiàn)代碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-05-05
這篇文章主要為大家詳細介紹了C#利用ZXing.Net生成條形碼和二維碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-03-03
這篇文章主要介紹了C#全局熱鍵設置與窗體熱鍵設置實例,對C#全局熱鍵設置與窗體熱鍵設置的實現(xiàn)方法與具體代碼進行了詳細的介紹,需要的朋友可以參考下2014-10-10
這篇文章主要介紹了C#WinFrom導出Excel過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
C#中的multipart/form-data提交文件和參數(shù)
這篇文章主要介紹了C#中的multipart/form-data提交文件和參數(shù)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
本文詳細講解了C#新特性之可空引用類型，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-02-02
這篇文章主要介紹了C#圖像對比度調整的方法,涉及C#實現(xiàn)圖像對比度操作的相關技巧,需要的朋友可以參考下2015-04-04
這篇文章介紹了C#中的文件路徑Path類，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-05-05