Bu makalede, .NET C#'taki Observer Design Pattern'i bazı geliştirmelerle birlikte öğreneceksiniz. Tanımı Gözlemci Tasarım Modeli en önemli ve yaygın olarak kullanılan tasarım desenlerinden biridir. Gözlemci Tasarım Deseni, Öncelikle resmi tanımını kontrol edelim. Observer Design Pattern'in göre : Microsoft'un belgeleri Gözlemci tasarım modeli, bir abonenin bir sağlayıcıya kaydolmasını ve sağlayıcıdan bildirim almasını sağlar. Push tabanlı bildirim gerektiren her senaryo için uygundur. Desen, bir sağlayıcıyı (özne veya gözlemlenebilir olarak da bilinir) ve sıfır, bir veya daha fazla gözlemciyi tanımlar. Gözlemciler sağlayıcıya kaydolur ve önceden tanımlanmış bir durum, olay veya durum değişikliği meydana geldiğinde sağlayıcı, yöntemlerinden birini çağırarak tüm gözlemcileri otomatik olarak bilgilendirir. Bu yöntem çağrısında sağlayıcı aynı zamanda gözlemcilere mevcut durum bilgisini de sağlayabilir. .NET'te gözlemci tasarım modeli, genel ve arabirimlerinin uygulanmasıyla uygulanır. Genel tür parametresi, bildirim bilgilerini sağlayan türü temsil eder. System.IObservable<T> System.IObserver<T> Yani yukarıdaki tanımdan şunu anlayabiliriz: İki partimiz veya modülümüz var. Sağlanacak bazı bilgi akışını içeren modül. Bu modüle (bilgi sağladığı için) veya (bilgiyi dış dünyaya aktardığı için) veya (dış dünya tarafından gözlemlenebildiği için) adı verilir. Sağlayıcı Konu Gözlemlenebilir Başka bir yerden gelen bilgi akışıyla ilgilenen modül. Bu modüle adı verilir (bilgiyi gözlemlediği için). Gözlemci Gözlemci Tasarım Deseninin Avantajları Artık bildiğimiz gibi , ve modülleri arasındaki ilişkiyi formüle etmektedir. benzersiz kılan şey, onu kullanarak bunu sıkı bir bağ kurmadan başarabilmenizdir. Observer Tasarım Modeli Observable Observer Observer Design Pattern'i Desenin çalışma şeklini analiz ederek aşağıdakileri bulacaksınız: hakkında gereken minimum bilgiyi bilir. Observable, Observer hakkında gereken minimum bilgiyi bilir. Observer, Observable Ortak bilgi bile somut uygulamalarla değil, soyutlamalarla elde edilir. Sonuçta her iki modül de kendi işini yapabilir, yalnızca kendi işini yapabilir. Kullanılan Soyutlamalar Bunlar ta uygulamak için kullanılan . , .NET C#' Gözlemci Tasarım Desenini soyutlamalardır IGözlenebilir<out T> Bu, herhangi bir temsil eden bir arayüzüdür. .NET'te Variance hakkında daha fazla bilgi edinmek istiyorsanız makaleye göz atabilirsiniz. . Observable'ı Kovaryant .NET C#'ta Kovaryans ve Karşıtlık Bu arayüzde tanımlanan üyeler şunlardır: public IDisposable Subscribe (IObserver<out T> observer); Bazı bilgi akışıyla ilgilendiğini bildirmek için yöntemi çağrılmalıdır. Gözlemcilerin Gözlemlenebilire Subscribe yöntemi, arabirimini uygulayan bir nesneyi döndürür. Bu nesne daha sonra tarafından tarafından sağlanan bilgi akışından çıkmak için kullanılabilir. Bu yapıldıktan sonra bilgi akışındaki herhangi bir güncelleme hakkında bilgi verilmeyecektir. Subscribe IDisposable Observer Observable Gözlemciye IObserver<T> cinsinden Bu, herhangi bir temsil eden bir arayüzüdür. .NET'te Variance hakkında daha fazla bilgi edinmek istiyorsanız makaleye göz atabilirsiniz. . Observer'ı Contravariant .NET C#'ta Kovaryans ve Karşıtlık Bu arayüzde tanımlanan üyeler şunlardır: public void OnCompleted (); public void OnError (Exception error); public void OnNext (T value); bilgi akışının tamamlandığını ve daha fazla bilgi beklememesi gerektiğini bildirmek için yöntemi tarafından çağrılmalıdır. Observer'a Observer'ın OnCompleted Observable bir hata oluştuğunu bildirmek için tarafından yöntemi çağrılmalıdır. Observer'a Observable OnError yöntemi, yeni bir bilgi parçasının hazır olduğunu ve akışa eklendiğini bildirmek için tarafından çağrılmalıdır. OnNext Observer'a Observable Microsoft'un Uygulaması Şimdi C#'ta uygulanmasını nasıl önerdiğini görelim. Daha sonra size kendi uyguladığım bazı küçük geliştirmeleri göstereceğim. Microsoft'un Observer Design Pattern'in Basit bir oluşturacağız. Bu uygulamada modülümüz (Observable, Provider, Subject) ve modülümüz (Observer) olacak. Hava Tahmini Konsol Uygulaması WeatherForecast WeatherForecastObserver Öyleyse uygulamayı incelemeye başlayalım. Hava Durumu Bilgisi namespace Observable { public class WeatherInfo { internal WeatherInfo(double temperature) { Temperature = temperature; } public double Temperature { get; } } } Bu, bilgi akışında akacak bilgi parçasını temsil eden varlıktır. Hava Durumu tahmini using System; using System.Collections.Generic; namespace Observable { public class WeatherForecast : IObservable<WeatherInfo> { private readonly List<IObserver<WeatherInfo>> m_Observers; private readonly List<WeatherInfo> m_WeatherInfoList; public WeatherForecast() { m_Observers = new List<IObserver<WeatherInfo>>(); m_WeatherInfoList = new List<WeatherInfo>(); } public IDisposable Subscribe(IObserver<WeatherInfo> observer) { if (!m_Observers.Contains(observer)) { m_Observers.Add(observer); foreach (var item in m_WeatherInfoList) { observer.OnNext(item); } } return new WeatherForecastUnsubscriber(m_Observers, observer); } public void RegisterWeatherInfo(WeatherInfo weatherInfo) { m_WeatherInfoList.Add(weatherInfo); foreach (var observer in m_Observers) { observer.OnNext(weatherInfo); } } public void ClearWeatherInfo() { m_WeatherInfoList.Clear(); } } } Burada neyi fark edebiliriz: sınıfı uygulamasını uyguluyor. WeatherForecast IObservable<WeatherInfo> yönteminin uygulanmasında Observer'da aktarılanın daha önce kayıtlı olup olmadığını kontrol ediyoruz. Değilse, onu yerel gözlemcileri listesine ekliyoruz. Daha sonra yerel listesindeki tüm girişlerini tek tek döngüye alıyoruz ve Observer'ın metodunu çağırarak Observer'ı bu konuda bilgilendiriyoruz. Subscribe m_Observers m_WeatherInfoList WeatherInfo OnNext Son olarak, bilgi akışı aboneliğinden çıkmak için Observer tarafından kullanılacak sınıfının yeni bir örneğini döndürüyoruz. WeatherForecastUnsubscriber yöntemi, ana modülün yeni kaydedebilmesi için tanımlanır. Gerçek dünyada bu, dahili planlanmış bir veya yönelik bir dinleyiciyle veya bilgi kaynağı olarak görev yapacak başka bir şeyle değiştirilebilir. RegisterWeatherInfo WeatherInfo API çağrısıyla SignalR Hub'a Aboneliği iptal eden<T> using System; using System.Collections.Generic; namespace Observable { public class Unsubscriber<T> : IDisposable { private readonly List<IObserver<T>> m_Observers; private readonly IObserver<T> m_Observer; private bool m_IsDisposed; public Unsubscriber(List<IObserver<T>> observers, IObserver<T> observer) { m_Observers = observers; m_Observer = observer; } public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } protected virtual void Dispose(bool disposing) { if (m_IsDisposed) return; if (disposing && m_Observers.Contains(m_Observer)) { m_Observers.Remove(m_Observer); } m_IsDisposed = true; } ~Unsubscriber() { Dispose(false); } } } Burada neyi fark edebiliriz: Bu, abone olmayanlar için temel sınıftır. uygulayarak uygular. Disposable Design Pattern'i IDisposable Yapıcı aracılığıyla, Gözlemcilerin ve kendisi için oluşturulduğu Gözlemcinin tam listesini alır. İmha ederken, Observer'ın Observer'ların tam listesinde zaten mevcut olup olmadığını kontrol eder. Evet ise listeden çıkarır. Hava TahminiAboneliği İptal Et using System; using System.Collections.Generic; namespace Observable { public class WeatherForecastUnsubscriber : Unsubscriber<WeatherInfo> { public WeatherForecastUnsubscriber( List<IObserver<WeatherInfo>> observers, IObserver<WeatherInfo> observer) : base(observers, observer) { } } } Burada neyi fark edebiliriz: Bu, sınıfından miras alınır. Unsubscriber<T> Özel bir işlem gerçekleşmiyor. Hava Tahmini Gözlemcisi using System; namespace Observable { public class WeatherForecastObserver : IObserver<WeatherInfo> { private IDisposable m_Unsubscriber; public virtual void Subscribe(WeatherForecast provider) { m_Unsubscriber = provider.Subscribe(this); } public virtual void Unsubscribe() { m_Unsubscriber.Dispose(); } public void OnCompleted() { Console.WriteLine("Completed"); } public void OnError(Exception error) { Console.WriteLine("Error"); } public void OnNext(WeatherInfo value) { Console.WriteLine($"Temperature: {value.Temperature}"); } } } Burada neyi fark edebiliriz: sınıfı, uygulamasını uyguluyor. WeatherForecastObserver IObserver<WeatherInfo> yönteminde sıcaklığı konsola yazıyoruz. OnNext metodunda konsola “Completed” yazıyoruz. OnCompleted metodunda konsola “Error” yazıyoruz. OnError Ana modülün kayıt sürecini tetiklemesine izin vermek için yöntemini tanımladık. Döndürülen aboneliği iptal etme nesnesi, abonelikten çıkma durumunda kullanılmak üzere dahili olarak kaydedilir. void Subscribe(WeatherForecast provider) Aynı konsepti kullanarak yöntemi tanımlanır ve dahili olarak kaydedilen aboneliği iptal etme nesnesinden yararlanır. void Unsubscribe() programı using System; namespace Observable { class Program { static void Main(string[] args) { var provider = new WeatherForecast(); provider.RegisterWeatherInfo(new WeatherInfo(1)); provider.RegisterWeatherInfo(new WeatherInfo(2)); provider.RegisterWeatherInfo(new WeatherInfo(3)); var observer = new WeatherForecastObserver(); observer.Subscribe(provider); provider.RegisterWeatherInfo(new WeatherInfo(4)); provider.RegisterWeatherInfo(new WeatherInfo(5)); observer.Unsubscribe(); provider.RegisterWeatherInfo(new WeatherInfo(6)); observer.Subscribe(provider); provider.RegisterWeatherInfo(new WeatherInfo(7)); Console.ReadLine(); } } } Burada neyi fark edebiliriz: Sağlayıcının bir örneğini oluşturduk. Daha sonra 3 adet bilgi kaydedildi. Şu ana kadar hiçbir gözlemci tanımlanmadığından konsola hiçbir şeyin kaydedilmemesi gerekmektedir. Daha sonra gözlemcinin bir örneğini yarattık. Daha sonra gözlemciyi yayına abone etti. Şu anda konsolda kayıtlı 3 sıcaklık bulmamız gerekiyor. Çünkü gözlemci abone olduğunda zaten var olan bilgilerden haberdar oluyor ve bizim durumumuzda bunlar 3 parça bilgi. Daha sonra 2 adet bilgiyi kaydediyoruz. Böylece konsola kayıtlı 2 mesaj daha alıyoruz. Daha sonra abonelikten çıkıyoruz. Daha sonra 1 adet bilgiyi kaydediyoruz. Ancak gözlemci zaten abonelikten çıktığı için bu bilgi konsola kaydedilmeyecekti. Daha sonra gözlemci tekrar abone olur. Daha sonra 1 adet bilgiyi kaydediyoruz. Yani bu bilgi konsola kaydedilir. Son olarak, bunu çalıştırmak şu sonuçla sonuçlanmalıdır: Genişletilmiş Uygulamam Microsoft'un uygulamasını kontrol ettiğimde bazı endişeler buldum. Bu nedenle bazı küçük değişiklikler yapmaya karar verdim. IExtishedObservable<out T> using System; using System.Collections.Generic; namespace ExtendedObservable { public interface IExtendedObservable<out T> : IObservable<T> { IReadOnlyCollection<T> Snapshot { get; } IDisposable Subscribe(IObserver<T> observer, bool withHistory); } } Burada neyi fark edebiliriz: arabirimi, arabirimini genişletir. IExtendedObservable<out T> IObservable<T> . Bu konuda daha fazla bilgi edinmek istiyorsanız makaleye göz atabilirsiniz. . Kovaryanttır .NET C#'ta Kovaryans ve Karşıtlık Diğer modüllerin abone olmak zorunda kalmadan mevcut bilgi girişlerinin anında listesini almasına izin vermek için özelliğini tanımladık. IReadOnlyCollection<T> Snapshot Ayrıca yöntemini ekstra bir parametresiyle tanımladık, böylece Observer abone olma anında mevcut bilgi girişleri hakkında bildirim almak isteyip istemediğine karar verebilir. IDisposable Subscribe(IObserver<T> observer, bool withHistory) bool withHistory Aboneliği iptal eden using System; namespace ExtendedObservable { public class Unsubscriber : IDisposable { private readonly Action m_UnsubscribeAction; private bool m_IsDisposed; public Unsubscriber(Action unsubscribeAction) { m_UnsubscribeAction = unsubscribeAction; } public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } protected virtual void Dispose(bool disposing) { if (m_IsDisposed) return; if (disposing) { m_UnsubscribeAction(); } m_IsDisposed = true; } ~Unsubscriber() { Dispose(false); } } } Burada neyi fark edebiliriz: Abonelikten sınıfı genel bir sınıf değildir. Unsubscriber Bunun nedeni, bilgi varlığının türünü bilmek için daha fazla bilgiye ihtiyaç duymamasıdır. Observer'ların ve kendisi için oluşturulduğu Observer'ın tam listesine erişim sağlamak yerine, yalnızca imha edildiğinde Observable'a bildirimde bulunur ve Observable, kayıt silme işlemini kendi başına gerçekleştirir. Bu sayede eskisinden daha az iş yapıyor ve sadece işini yapıyor. Hava TahminiAboneliği İptal Et using System; using System.Collections.Generic; namespace ExtendedObservable { public class WeatherForecastUnsubscriber : Unsubscriber { public WeatherForecastUnsubscriber( Action unsubscribeAction) : base(unsubscribeAction) { } } } Burada neyi fark edebiliriz: den kısmını kaldırdık. Unsubscriber<T> <T> Ve şimdi yapıcı, elden çıkarma durumunda çağrılacak bir üstleniyor. Action Hava Durumu tahmini using System; using System.Collections.Generic; namespace ExtendedObservable { public class WeatherForecast : IExtendedObservable<WeatherInfo> { private readonly List<IObserver<WeatherInfo>> m_Observers; private readonly List<WeatherInfo> m_WeatherInfoList; public WeatherForecast() { m_Observers = new List<IObserver<WeatherInfo>>(); m_WeatherInfoList = new List<WeatherInfo>(); } public IReadOnlyCollection<WeatherInfo> Snapshot => m_WeatherInfoList; public IDisposable Subscribe(IObserver<WeatherInfo> observer) { return Subscribe(observer, false); } public IDisposable Subscribe(IObserver<WeatherInfo> observer, bool withHistory) { if (!m_Observers.Contains(observer)) { m_Observers.Add(observer); if (withHistory) { foreach (var item in m_WeatherInfoList) { observer.OnNext(item); } } } return new WeatherForecastUnsubscriber( () => { if (m_Observers.Contains(observer)) { m_Observers.Remove(observer); } }); } public void RegisterWeatherInfo(WeatherInfo weatherInfo) { m_WeatherInfoList.Add(weatherInfo); foreach (var observer in m_Observers) { observer.OnNext(weatherInfo); } } public void ClearWeatherInfo() { m_WeatherInfoList.Clear(); } } } Burada neyi fark edebiliriz: Dahili listesini döndüren ancak olarak döndüren özelliği dışında hemen hemen aynıdır. m_WeatherInfoList IReadOnlyCollection IReadOnlyCollection<WeatherInfo> Snapshot Ve parametresini kullanan yöntemi. withHistory IDisposable Subscribe(IObserver<WeatherInfo> observer, bool withHistory) Hava Tahmini Gözlemcisi using System; namespace ExtendedObservable { public class WeatherForecastObserver : IObserver<WeatherInfo> { private IDisposable m_Unsubscriber; public virtual void Subscribe(WeatherForecast provider) { m_Unsubscriber = provider.Subscribe(this, true); } public virtual void Unsubscribe() { m_Unsubscriber.Dispose(); } public void OnCompleted() { Console.WriteLine("Completed"); } public void OnError(Exception error) { Console.WriteLine("Error"); } public void OnNext(WeatherInfo value) { Console.WriteLine($"Temperature: {value.Temperature}"); } } } Burada fark edebileceğimiz şey, artık geçmişle olmayacağına karar veren dışında hemen hemen aynı olmasıdır. Subscribe Subscribe(WeatherForecast provider) programı using System; namespace ExtendedObservable { class Program { static void Main(string[] args) { var provider = new WeatherForecast(); provider.RegisterWeatherInfo(new WeatherInfo(1)); provider.RegisterWeatherInfo(new WeatherInfo(2)); provider.RegisterWeatherInfo(new WeatherInfo(3)); var observer = new WeatherForecastObserver(); observer.Subscribe(provider); provider.RegisterWeatherInfo(new WeatherInfo(4)); provider.RegisterWeatherInfo(new WeatherInfo(5)); observer.Unsubscribe(); provider.RegisterWeatherInfo(new WeatherInfo(6)); observer.Subscribe(provider); provider.RegisterWeatherInfo(new WeatherInfo(7)); Console.ReadLine(); } } } Öncekiyle aynı. Son olarak, bunu çalıştırmak daha önce olduğu gibi aynı sonucu vermelidir: Sıradaki ne Artık .NET C#'taki temellerini biliyorsunuz. Ancak bu hikayenin sonu değil. Gözlemci Tasarım Deseninin Yararlı bulabileceğiniz daha harika özellikler ve yetenekler sağlayan ve arayüzleri üzerine oluşturulmuş kütüphaneler vardır. IObservable<T> IObserver<T> Bu kütüphanelerden biri de kütüphane. Eşzamansız programlamayı desteklemek için bir dizi genişletme yönteminden ve LINQ standart dizi operatörlerinden oluşur. .NET için Reaktif Uzantılar (Rx) Bu nedenle bu kütüphaneleri keşfetmenizi ve denemenizi tavsiye ederim. Eminim bazılarını beğeneceksiniz. Burada da yayınlandı.

The code in this story is for educational purposes. The readers are solely responsible for whatever they build with it.

Check my links 😀

My HackerNoon Stories

My Medium Articles

Buy Me a Coffee

Buy Me a Gift

Check My Links

Hire Me

Bu ses hikayenin orijinal dilinde üretilmiştir!

.NET C#'ta Gözlemci Tasarım Deseni İçin Temel Bir Kılavuz

Çok uzun; Okumak

@ahmedtarekhasan

Credibility

İLGİLİ ÖYKÜLER