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

About Author

YORUMLAR

ETİKETLERİ ASIN

BU YAZI

Related Stories

Bu 18 Geliştirici Aracıyla Üretkenliğinizi Artırın 🚀🔥

Yapay Zekanın Gücünü Ortaya Çıkarıyoruz. En Son Tekniklerin Sistematik Bir İncelemesi: Özet ve Giriş

HackerNoon Yazma Yarışmasını mı Kazanmak İstiyorsunuz? İşte #crypto-api Yarışması Kazananlarının Önerileri

Sulara Yelken Açmak: Data Lakes ile Üretim Sınıfında RAG Uygulamaları Geliştirme

Bu 18 Geliştirici Aracıyla Üretkenliğinizi Artırın 🚀🔥

Yapay Zekanın Gücünü Ortaya Çıkarıyoruz. En Son Tekniklerin Sistematik Bir İncelemesi: Özet ve Giriş

HackerNoon Yazma Yarışmasını mı Kazanmak İstiyorsunuz? İşte #crypto-api Yarışması Kazananlarının Önerileri

Sulara Yelken Açmak: Data Lakes ile Üretim Sınıfında RAG Uygulamaları Geliştirme

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps