Wzorzec projektowy obserwatora
Wzorzec projektowania obserwatora umożliwia subskrybentowi rejestrowanie się i odbieranie powiadomień od dostawcy. Jest odpowiedni dla każdego scenariusza, który wymaga powiadomień wypychanych. Wzorzec definiuje dostawcę (znanego również jako temat lub obserwowalny) i zero, jeden lub więcej obserwatorów. Obserwatorzy rejestrują się u dostawcy, a za każdym razem, gdy wystąpi wstępnie zdefiniowany warunek, zdarzenie lub zmiana stanu, dostawca automatycznie powiadamia wszystkich obserwatorów, wywołując jedną z ich metod. W tym wywołaniu metody dostawca może również udostępniać bieżące informacje o stanie obserwatorom. Na platformie .NET wzorzec projektowania obserwatora jest stosowany przez zaimplementowanie ogólnych System.IObservable<T> i System.IObserver<T> interfejsów. Ogólny parametr typu reprezentuje typ, który dostarcza informacje o powiadomieniach.
Stosowanie wzorca
Wzorzec projektowania obserwatora jest odpowiedni dla rozproszonych powiadomień wypychanych, ponieważ obsługuje czystą separację między dwoma różnymi składnikami lub warstwami aplikacji, takimi jak warstwa źródła danych (logika biznesowa) i warstwa interfejsu użytkownika (wyświetlanie). Wzorzec można zaimplementować za każdym razem, gdy dostawca używa wywołań zwrotnych w celu dostarczenia klientom bieżących informacji.
Implementacja wzorca wymaga podania następujących elementów:
Dostawca lub podmiot, który jest obiektem, który wysyła powiadomienia do obserwatorów. Dostawca to klasa lub struktura, która implementuje IObservable<T> interfejs. Dostawca musi zaimplementować jedną metodę , IObservable<T>.Subscribektóra jest wywoływana przez obserwatorów, którzy chcą otrzymywać powiadomienia od dostawcy.
Obserwator, który jest obiektem, który odbiera powiadomienia od dostawcy. Obserwator jest klasą lub strukturą, która implementuje IObserver<T> interfejs. Obserwator musi zaimplementować trzy metody, z których wszystkie są wywoływane przez dostawcę:
IObserver<T>.OnNext, który dostarcza obserwatorowi nowe lub bieżące informacje.
IObserver<T>.OnError, który informuje obserwatora o wystąpieniu błędu.
IObserver<T>.OnCompleted, co wskazuje, że dostawca zakończył wysyłanie powiadomień.
Mechanizm, który umożliwia dostawcy śledzenie obserwatorów. Zazwyczaj dostawca używa obiektu kontenera, takiego jak System.Collections.Generic.List<T> obiekt, do przechowywania odwołań do IObserver<T> implementacji, które zasubskrybowały powiadomienia. Użycie kontenera magazynu w tym celu umożliwia dostawcy obsługę zera do nieograniczonej liczby obserwatorów. Kolejność odbierania powiadomień przez obserwatorów nie jest zdefiniowana; dostawca jest bezpłatny, aby użyć dowolnej metody do określenia zamówienia.
Implementacja umożliwiająca IDisposable dostawcy usuwanie obserwatorów po zakończeniu powiadamiania. Obserwatorzy otrzymują odwołanie do IDisposable implementacji z Subscribe metody, aby mogli również wywołać IDisposable.Dispose metodę anulowania subskrypcji przed zakończeniem wysyłania powiadomień przez dostawcę.
Obiekt zawierający dane wysyłane przez dostawcę do obserwatorów. Typ tego obiektu odpowiada ogólnemu parametrowi IObservable<T> typu interfejsów i IObserver<T> . Chociaż ten obiekt może być taki sam jak implementacja IObservable<T> , najczęściej jest to oddzielny typ.
Uwaga
Oprócz zaimplementowania wzorca projektowego obserwatora warto eksplorować biblioteki utworzone przy użyciu IObservable<T> interfejsów i .IObserver<T> Na przykład reaktywne rozszerzenia dla platformy .NET (Rx) składają się z zestawu metod rozszerzeń i standardowych operatorów sekwencji LINQ do obsługi programowania asynchronicznego.
Implementowanie wzorca
W poniższym przykładzie użyto wzorca projektowania obserwatora w celu zaimplementowania systemu informacyjnego dotyczącego bagażu lotniczego. Klasa BaggageInfo zawiera informacje o przylotach i karuzelach, w których bagaż z każdego lotu jest dostępny do odbioru. Pokazano go w poniższym przykładzie.
using System;
using System.Collections.Generic;
public class BaggageInfo
{
private int flightNo;
private string origin;
private int location;
internal BaggageInfo(int flight, string from, int carousel)
{
this.flightNo = flight;
this.origin = from;
this.location = carousel;
}
public int FlightNumber {
get { return this.flightNo; }
}
public string From {
get { return this.origin; }
}
public int Carousel {
get { return this.location; }
}
}
Public Class BaggageInfo
Private flightNo As Integer
Private origin As String
Private location As Integer
Friend Sub New(ByVal flight As Integer, ByVal from As String, ByVal carousel As Integer)
Me.flightNo = flight
Me.origin = from
Me.location = carousel
End Sub
Public ReadOnly Property FlightNumber As Integer
Get
Return Me.flightNo
End Get
End Property
Public ReadOnly Property From As String
Get
Return Me.origin
End Get
End Property
Public ReadOnly Property Carousel As Integer
Get
Return Me.location
End Get
End Property
End Class
Klasa BaggageHandler jest odpowiedzialna za otrzymywanie informacji o przybywających lotach i bagażu karuzelach. Wewnętrznie utrzymuje dwie kolekcje:
observers— Kolekcja klientów, którzy otrzymają zaktualizowane informacje.flights- Kolekcja lotów i przypisanych karuzel.
Obie kolekcje są reprezentowane przez obiekty ogólne List<T> , które są tworzone w konstruktorze BaggageHandler klasy. Kod BaggageHandler źródłowy klasy jest pokazany w poniższym przykładzie.
public class BaggageHandler : IObservable<BaggageInfo>
{
private List<IObserver<BaggageInfo>> observers;
private List<BaggageInfo> flights;
public BaggageHandler()
{
observers = new List<IObserver<BaggageInfo>>();
flights = new List<BaggageInfo>();
}
public IDisposable Subscribe(IObserver<BaggageInfo> observer)
{
// Check whether observer is already registered. If not, add it
if (! observers.Contains(observer)) {
observers.Add(observer);
// Provide observer with existing data.
foreach (var item in flights)
observer.OnNext(item);
}
return new Unsubscriber<BaggageInfo>(observers, observer);
}
// Called to indicate all baggage is now unloaded.
public void BaggageStatus(int flightNo)
{
BaggageStatus(flightNo, String.Empty, 0);
}
public void BaggageStatus(int flightNo, string from, int carousel)
{
var info = new BaggageInfo(flightNo, from, carousel);
// Carousel is assigned, so add new info object to list.
if (carousel > 0 && ! flights.Contains(info)) {
flights.Add(info);
foreach (var observer in observers)
observer.OnNext(info);
}
else if (carousel == 0) {
// Baggage claim for flight is done
var flightsToRemove = new List<BaggageInfo>();
foreach (var flight in flights) {
if (info.FlightNumber == flight.FlightNumber) {
flightsToRemove.Add(flight);
foreach (var observer in observers)
observer.OnNext(info);
}
}
foreach (var flightToRemove in flightsToRemove)
flights.Remove(flightToRemove);
flightsToRemove.Clear();
}
}
public void LastBaggageClaimed()
{
foreach (var observer in observers)
observer.OnCompleted();
observers.Clear();
}
}
Public Class BaggageHandler : Implements IObservable(Of BaggageInfo)
Private observers As List(Of IObserver(Of BaggageInfo))
Private flights As List(Of BaggageInfo)
Public Sub New()
observers = New List(Of IObserver(Of BaggageInfo))
flights = New List(Of BaggageInfo)
End Sub
Public Function Subscribe(ByVal observer As IObserver(Of BaggageInfo)) As IDisposable _
Implements IObservable(Of BaggageInfo).Subscribe
' Check whether observer is already registered. If not, add it
If Not observers.Contains(observer) Then
observers.Add(observer)
' Provide observer with existing data.
For Each item In flights
observer.OnNext(item)
Next
End If
Return New Unsubscriber(Of BaggageInfo)(observers, observer)
End Function
' Called to indicate all baggage is now unloaded.
Public Sub BaggageStatus(ByVal flightNo As Integer)
BaggageStatus(flightNo, String.Empty, 0)
End Sub
Public Sub BaggageStatus(ByVal flightNo As Integer, ByVal from As String, ByVal carousel As Integer)
Dim info As New BaggageInfo(flightNo, from, carousel)
' Carousel is assigned, so add new info object to list.
If carousel > 0 And Not flights.Contains(info) Then
flights.Add(info)
For Each observer In observers
observer.OnNext(info)
Next
ElseIf carousel = 0 Then
' Baggage claim for flight is done
Dim flightsToRemove As New List(Of BaggageInfo)
For Each flight In flights
If info.FlightNumber = flight.FlightNumber Then
flightsToRemove.Add(flight)
For Each observer In observers
observer.OnNext(info)
Next
End If
Next
For Each flightToRemove In flightsToRemove
flights.Remove(flightToRemove)
Next
flightsToRemove.Clear()
End If
End Sub
Public Sub LastBaggageClaimed()
For Each observer In observers
observer.OnCompleted()
Next
observers.Clear()
End Sub
End Class
Klienci, którzy chcą otrzymywać zaktualizowane informacje, wywołają metodę BaggageHandler.Subscribe . Jeśli klient nie zasubskrybował wcześniej powiadomień, do kolekcji zostanie dodane odwołanie do observers implementacji klientaIObserver<T>.
Przeciążona BaggageHandler.BaggageStatus metoda może być wywoływana, aby wskazać, że bagaż z lotu jest zwalniany lub nie jest już zwalniany. W pierwszym przypadku metoda jest przekazywana numer lotu, lotnisko, z którego pochodzi lot, oraz karuzelę, w której jest zwalniany bagaż. W drugim przypadku metoda jest przekazywana tylko jako numer lotu. W przypadku bagażu, który jest zwalniany, metoda sprawdza, czy BaggageInfo informacje przekazane do metody istnieją w kolekcji flights . Jeśli tak nie jest, metoda dodaje informacje i wywołuje metodę każdego obserwatora OnNext . W przypadku lotów, których bagaż nie jest już rozładowany, metoda sprawdza, czy informacje o tym locie są przechowywane w kolekcji flights . Jeśli tak jest, metoda wywołuje metodę każdego obserwatora OnNext i usuwa BaggageInfo obiekt z flights kolekcji.
Gdy ostatni lot dnia wylądował i jego bagaż został przetworzony, metoda jest wywoływana BaggageHandler.LastBaggageClaimed . Ta metoda wywołuje metodę każdego obserwatora OnCompleted , aby wskazać, że wszystkie powiadomienia zostały ukończone observers , a następnie czyści kolekcję.
Metoda dostawcy Subscribe zwraca implementację IDisposable , która umożliwia obserwatorom zatrzymywanie odbierania powiadomień przed OnCompleted wywołaniem metody. Kod źródłowy tej Unsubscriber(Of BaggageInfo) klasy jest pokazany w poniższym przykładzie. Po utworzeniu wystąpienia klasy w metodzie BaggageHandler.Subscribe przekazuje odwołanie do kolekcji i odwołanie do observers obserwatora dodanego do kolekcji. Te odwołania są przypisywane do zmiennych lokalnych. Gdy metoda obiektu jest wywoływana Dispose , sprawdza, czy obserwator nadal istnieje w observers kolekcji, a jeśli tak, usuwa obserwatora.
internal class Unsubscriber<BaggageInfo> : IDisposable
{
private List<IObserver<BaggageInfo>> _observers;
private IObserver<BaggageInfo> _observer;
internal Unsubscriber(List<IObserver<BaggageInfo>> observers, IObserver<BaggageInfo> observer)
{
this._observers = observers;
this._observer = observer;
}
public void Dispose()
{
if (_observers.Contains(_observer))
_observers.Remove(_observer);
}
}
Friend Class Unsubscriber(Of BaggageInfo) : Implements IDisposable
Private _observers As List(Of IObserver(Of BaggageInfo))
Private _observer As IObserver(Of BaggageInfo)
Friend Sub New(ByVal observers As List(Of IObserver(Of BaggageInfo)), ByVal observer As IObserver(Of BaggageInfo))
Me._observers = observers
Me._observer = observer
End Sub
Public Sub Dispose() Implements IDisposable.Dispose
If _observers.Contains(_observer) Then
_observers.Remove(_observer)
End If
End Sub
End Class
W poniższym przykładzie przedstawiono implementację o nazwie ArrivalsMonitor, która jest klasą IObserver<T> bazową, która wyświetla informacje o roszczeniach bagażowych. Informacje są wyświetlane alfabetycznie według nazwy źródłowego miasta. Metody ArrivalsMonitor są oznaczone jako overridable (w Visual Basic) lub virtual (w języku C#), dzięki czemu wszystkie mogą być zastępowane przez klasę pochodną.
using System;
using System.Collections.Generic;
public class ArrivalsMonitor : IObserver<BaggageInfo>
{
private string name;
private List<string> flightInfos = new List<string>();
private IDisposable cancellation;
private string fmt = "{0,-20} {1,5} {2, 3}";
public ArrivalsMonitor(string name)
{
if (String.IsNullOrEmpty(name))
throw new ArgumentNullException("The observer must be assigned a name.");
this.name = name;
}
public virtual void Subscribe(BaggageHandler provider)
{
cancellation = provider.Subscribe(this);
}
public virtual void Unsubscribe()
{
cancellation.Dispose();
flightInfos.Clear();
}
public virtual void OnCompleted()
{
flightInfos.Clear();
}
// No implementation needed: Method is not called by the BaggageHandler class.
public virtual void OnError(Exception e)
{
// No implementation.
}
// Update information.
public virtual void OnNext(BaggageInfo info)
{
bool updated = false;
// Flight has unloaded its baggage; remove from the monitor.
if (info.Carousel == 0) {
var flightsToRemove = new List<string>();
string flightNo = String.Format("{0,5}", info.FlightNumber);
foreach (var flightInfo in flightInfos) {
if (flightInfo.Substring(21, 5).Equals(flightNo)) {
flightsToRemove.Add(flightInfo);
updated = true;
}
}
foreach (var flightToRemove in flightsToRemove)
flightInfos.Remove(flightToRemove);
flightsToRemove.Clear();
}
else {
// Add flight if it does not exist in the collection.
string flightInfo = String.Format(fmt, info.From, info.FlightNumber, info.Carousel);
if (! flightInfos.Contains(flightInfo)) {
flightInfos.Add(flightInfo);
updated = true;
}
}
if (updated) {
flightInfos.Sort();
Console.WriteLine("Arrivals information from {0}", this.name);
foreach (var flightInfo in flightInfos)
Console.WriteLine(flightInfo);
Console.WriteLine();
}
}
}
Public Class ArrivalsMonitor : Implements IObserver(Of BaggageInfo)
Private name As String
Private flightInfos As New List(Of String)
Private cancellation As IDisposable
Private fmt As String = "{0,-20} {1,5} {2, 3}"
Public Sub New(ByVal name As String)
If String.IsNullOrEmpty(name) Then Throw New ArgumentNullException("The observer must be assigned a name.")
Me.name = name
End Sub
Public Overridable Sub Subscribe(ByVal provider As BaggageHandler)
cancellation = provider.Subscribe(Me)
End Sub
Public Overridable Sub Unsubscribe()
cancellation.Dispose()
flightInfos.Clear()
End Sub
Public Overridable Sub OnCompleted() Implements System.IObserver(Of BaggageInfo).OnCompleted
flightInfos.Clear()
End Sub
' No implementation needed: Method is not called by the BaggageHandler class.
Public Overridable Sub OnError(ByVal e As System.Exception) Implements System.IObserver(Of BaggageInfo).OnError
' No implementation.
End Sub
' Update information.
Public Overridable Sub OnNext(ByVal info As BaggageInfo) Implements System.IObserver(Of BaggageInfo).OnNext
Dim updated As Boolean = False
' Flight has unloaded its baggage; remove from the monitor.
If info.Carousel = 0 Then
Dim flightsToRemove As New List(Of String)
Dim flightNo As String = String.Format("{0,5}", info.FlightNumber)
For Each flightInfo In flightInfos
If flightInfo.Substring(21, 5).Equals(flightNo) Then
flightsToRemove.Add(flightInfo)
updated = True
End If
Next
For Each flightToRemove In flightsToRemove
flightInfos.Remove(flightToRemove)
Next
flightsToRemove.Clear()
Else
' Add flight if it does not exist in the collection.
Dim flightInfo As String = String.Format(fmt, info.From, info.FlightNumber, info.Carousel)
If Not flightInfos.Contains(flightInfo) Then
flightInfos.Add(flightInfo)
updated = True
End If
End If
If updated Then
flightInfos.Sort()
Console.WriteLine("Arrivals information from {0}", Me.name)
For Each flightInfo In flightInfos
Console.WriteLine(flightInfo)
Next
Console.WriteLine()
End If
End Sub
End Class
Klasa ArrivalsMonitor zawiera Subscribe metody i Unsubscribe . Metoda Subscribe umożliwia klasie zapisywanie implementacji zwróconej przez wywołanie IDisposable do Subscribe zmiennej prywatnej. Metoda Unsubscribe umożliwia klasie anulowanie subskrypcji powiadomień przez wywołanie implementacji dostawcy Dispose . ArrivalsMonitor Udostępnia również implementacje OnNextmetod , OnErrori OnCompleted . Tylko implementacja OnNext zawiera znaczną ilość kodu. Metoda współpracuje z prywatnym, posortowany, rodzajowym List<T> obiektem, który przechowuje informacje o portach lotniczych pochodzenia dla lotów przychodzących i karuzelach, na których jest dostępny ich bagaż. BaggageHandler Jeśli klasa zgłasza nowy przylot lotu, implementacja OnNext metody dodaje informacje o tym locie do listy. BaggageHandler Jeśli klasa zgłasza, że bagaż lotu został zwolniony, OnNext metoda usuwa ten lot z listy. Za każdym razem, gdy zostanie wprowadzona zmiana, lista zostanie posortowana i wyświetlona w konsoli.
Poniższy przykład zawiera punkt wejścia aplikacji, który tworzy wystąpienie BaggageHandler klasy, a także dwa wystąpienia ArrivalsMonitor klasy i używa BaggageHandler.BaggageStatus metody do dodawania i usuwania informacji o przychodzących lotach. W każdym przypadku obserwatorzy otrzymują aktualizacje i prawidłowo wyświetlają informacje o bagażu.
using System;
using System.Collections.Generic;
public class Example
{
public static void Main()
{
BaggageHandler provider = new BaggageHandler();
ArrivalsMonitor observer1 = new ArrivalsMonitor("BaggageClaimMonitor1");
ArrivalsMonitor observer2 = new ArrivalsMonitor("SecurityExit");
provider.BaggageStatus(712, "Detroit", 3);
observer1.Subscribe(provider);
provider.BaggageStatus(712, "Kalamazoo", 3);
provider.BaggageStatus(400, "New York-Kennedy", 1);
provider.BaggageStatus(712, "Detroit", 3);
observer2.Subscribe(provider);
provider.BaggageStatus(511, "San Francisco", 2);
provider.BaggageStatus(712);
observer2.Unsubscribe();
provider.BaggageStatus(400);
provider.LastBaggageClaimed();
}
}
// The example displays the following output:
// Arrivals information from BaggageClaimMonitor1
// Detroit 712 3
//
// Arrivals information from BaggageClaimMonitor1
// Detroit 712 3
// Kalamazoo 712 3
//
// Arrivals information from BaggageClaimMonitor1
// Detroit 712 3
// Kalamazoo 712 3
// New York-Kennedy 400 1
//
// Arrivals information from SecurityExit
// Detroit 712 3
//
// Arrivals information from SecurityExit
// Detroit 712 3
// Kalamazoo 712 3
//
// Arrivals information from SecurityExit
// Detroit 712 3
// Kalamazoo 712 3
// New York-Kennedy 400 1
//
// Arrivals information from BaggageClaimMonitor1
// Detroit 712 3
// Kalamazoo 712 3
// New York-Kennedy 400 1
// San Francisco 511 2
//
// Arrivals information from SecurityExit
// Detroit 712 3
// Kalamazoo 712 3
// New York-Kennedy 400 1
// San Francisco 511 2
//
// Arrivals information from BaggageClaimMonitor1
// New York-Kennedy 400 1
// San Francisco 511 2
//
// Arrivals information from SecurityExit
// New York-Kennedy 400 1
// San Francisco 511 2
//
// Arrivals information from BaggageClaimMonitor1
// San Francisco 511 2
Module Example
Public Sub Main()
Dim provider As New BaggageHandler()
Dim observer1 As New ArrivalsMonitor("BaggageClaimMonitor1")
Dim observer2 As New ArrivalsMonitor("SecurityExit")
provider.BaggageStatus(712, "Detroit", 3)
observer1.Subscribe(provider)
provider.BaggageStatus(712, "Kalamazoo", 3)
provider.BaggageStatus(400, "New York-Kennedy", 1)
provider.BaggageStatus(712, "Detroit", 3)
observer2.Subscribe(provider)
provider.BaggageStatus(511, "San Francisco", 2)
provider.BaggageStatus(712)
observer2.Unsubscribe()
provider.BaggageStatus(400)
provider.LastBaggageClaimed()
End Sub
End Module
' The example displays the following output:
' Arrivals information from BaggageClaimMonitor1
' Detroit 712 3
'
' Arrivals information from BaggageClaimMonitor1
' Detroit 712 3
' Kalamazoo 712 3
'
' Arrivals information from BaggageClaimMonitor1
' Detroit 712 3
' Kalamazoo 712 3
' New York-Kennedy 400 1
'
' Arrivals information from SecurityExit
' Detroit 712 3
'
' Arrivals information from SecurityExit
' Detroit 712 3
' Kalamazoo 712 3
'
' Arrivals information from SecurityExit
' Detroit 712 3
' Kalamazoo 712 3
' New York-Kennedy 400 1
'
' Arrivals information from BaggageClaimMonitor1
' Detroit 712 3
' Kalamazoo 712 3
' New York-Kennedy 400 1
' San Francisco 511 2
'
' Arrivals information from SecurityExit
' Detroit 712 3
' Kalamazoo 712 3
' New York-Kennedy 400 1
' San Francisco 511 2
'
' Arrivals information from BaggageClaimMonitor1
' New York-Kennedy 400 1
' San Francisco 511 2
'
' Arrivals information from SecurityExit
' New York-Kennedy 400 1
' San Francisco 511 2
'
' Arrivals information from BaggageClaimMonitor1
' San Francisco 511 2
Tematy pokrewne
| Tytuł | Opis |
|---|---|
| Wzorzec projektowy obserwatora — Najlepsze praktyki | Opisuje najlepsze rozwiązania do przyjęcia podczas tworzenia aplikacji implementujących wzorzec projektowania obserwatora. |
| Instrukcje: implementowanie dostawcy | Zapewnia krok po kroku implementację dostawcy dla aplikacji do monitorowania temperatury. |
| Instrukcje: implementowanie obserwatora | Zapewnia krok po kroku implementację obserwatora dla aplikacji do monitorowania temperatury. |