這篇文章將為大家詳細(xì)講解有關(guān)怎么在c#項(xiàng)目中實(shí)現(xiàn)一個(gè)觀察者模式,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個(gè)參考,希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

1、觀察者模式UML圖


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">觀察者對(duì)象</param>
public void RegisterObserver(IObserver o)
{
_observerList.Add(o);
}
/// <summary>
/// 移除觀察者
/// </summary>
/// <param name="o">觀察者對(duì)象</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 測(cè)試代碼
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.1 輔助類(lèi)/結(jié)構(gòu)體
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具體實(shí)現(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具體實(shí)現(xiàn)
public class WeatherDataX : IObservable<WeatherMessage>
{
private readonly List<IObserver<WeatherMessage>> _observerList;
public WeatherDataX()
{
_observerList = new List<IObserver<WeatherMessage>>();
}
/// <summary>
/// 通知提供程序:某觀察程序?qū)⒁邮胀ㄖ? /// </summary>
/// <param name="observer">要接收通知的對(duì)象。</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 測(cè)試代碼
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();
}關(guān)于怎么在c#項(xiàng)目中實(shí)現(xiàn)一個(gè)觀察者模式就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò),可以把它分享出去讓更多的人看到。
分享題目:怎么在c#項(xiàng)目中實(shí)現(xiàn)一個(gè)觀察者模式-創(chuàng)新互聯(lián)
本文鏈接:http://www.chinadenli.net/article46/deeihg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計(jì)公司、全網(wǎng)營(yíng)銷(xiāo)推廣、營(yíng)銷(xiāo)型網(wǎng)站建設(shè)、虛擬主機(jī)、微信公眾號(hào)、企業(yè)建站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容
網(wǎng)頁(yè)設(shè)計(jì)公司知識(shí)