第一起來學(xué)習(xí)C#的觀察者模式BaggageHandlerprovider=newBaggageHandler();

ArrivalsMonitorobserver1=newArrivalsMonitor("BaggageClaimMonitor1");

ArrivalsMonitorobserver2=newArrivalsMonitor("SecurityExit");

//添加信息，此時(shí)沒有觀察者，對(duì)于新的信息不會(huì)進(jìn)行操作，若有觀察者，則對(duì)觀察者內(nèi)部數(shù)據(jù)進(jìn)行對(duì)比，若有新內(nèi)容則進(jìn)行更新。

provider.BaggageStatus(712,"Detroit",3);

//添加了觀察者，觀察者內(nèi)部也有數(shù)據(jù)集。新信息傳進(jìn)來，會(huì)與內(nèi)部數(shù)據(jù)集進(jìn)行對(duì)比，若有新內(nèi)容則進(jìn)行更新。

observer1.Subscribe(provider);

provider.BaggageStatus(712,"Kalamazoo",3);

provider.BaggageStatus(400,"NewYork-Kennedy",1);

provider.BaggageStatus(712,"Detroit",3);

observer2.Subscribe(provider);

provider.BaggageStatus(511,"SanFrancisco",2);

//參數(shù)3為0執(zhí)行移除712對(duì)應(yīng)信息值，對(duì)應(yīng)觀察者打印

provider.BaggageStatus(712);

observer2.Unsubscribe();

provider.BaggageStatus(400);

provider.LastBaggageClaimed();

//Theexampledisplaysthefollowingoutput:

//ArrivalsinformationfromBaggageClaimMonitor1

//Detroit7123

//ArrivalsinformationfromBaggageClaimMonitor1

//Detroit7123

//Kalamazoo7123

//ArrivalsinformationfromBaggageClaimMonitor1

//Detroit7123

//Kalamazoo7123

//NewYork-Kennedy4001

//ArrivalsinformationfromSecurityExit

//Detroit7123

//ArrivalsinformationfromSecurityExit

//Detroit7123

//Kalamazoo7123

//ArrivalsinformationfromSecurityExit

//Detroit7123

//Kalamazoo7123

//NewYork-Kennedy4001

//ArrivalsinformationfromBaggageClaimMonitor1

//Detroit7123

//Kalamazoo7123

//NewYork-Kennedy4001

//SanFrancisco5112

//ArrivalsinformationfromSecurityExit

//Detroit7123

//Kalamazoo7123

//NewYork-Kennedy4001

//SanFrancisco5112

//ArrivalsinformationfromBaggageClaimMonitor1

//NewYork-Kennedy4001

//SanFrancisco5112

//ArrivalsinformationfromSecurityExit

//NewYork-Kennedy4001

//SanFrancisco5112

//ArrivalsinformationfromBaggageClaimMonitor1

//SanFrancisco5112

usingSystem;

usingSystem.Collections.Generic;

publicclassArrivalsMonitor:IObserverBaggageInfo

privatestringname;

privateListstringflightInfos=newListstring

privateIDisposablecancellation;

privatestringfmt="{0,-20}{1,5}{2,3}";

publicArrivalsMonitor(stringname)

if(String.IsNullOrEmpty(name))

thrownewArgumentNullException("Theobservermustbeassignedaname.");

=name;

publicvirtualvoidSubscribe(BaggageHandlerprovider)

//參數(shù)是處理者！添加觀察者this

cancellation=provider.Subscribe(this);

publicvirtualvoidUnsubscribe()

cancellation.Dispose();

flightInfos.Clear();

publicvirtualvoidOnCompleted()

flightInfos.Clear();

//Noimplementationneeded:MethodisnotcalledbytheBaggageHandlerclass.

publicvirtualvoidOnError(Exceptione)

//Noimplementation.

//Updateinformation.

publicvirtualvoidOnNext(BaggageInfoinfo)

boolupdated=false;

//Flighthasunloadeditsbaggage;removefromthemonitor.

if(info.Carousel==0)

varflightsToRemove=newListstring

stringflightNo=String.Format("{0,5}",info.FlightNumber);

foreach(varflightInfoinflightInfos)

if(flightInfo.Substring(21,5).Equals(flightNo))

flightsToRemove.Add(flightInfo);

updated=true;

foreach(varflightToRemoveinflightsToRemove)

flightInfos.Remove(flightToRemove);

flightsToRemove.Clear();

else

//Addflightifitdoesnotexistinthecollection.

stringflightInfo=String.Format(fmt,info.From,info.FlightNumber,info.Carousel);

if(!flightInfos.Contains(flightInfo))

flightInfos.Add(flightInfo);

updated=true;

if(updated)

flightInfos.Sort();

Console.WriteLine("Arrivalsinformationfrom{0}",);

foreach(varflightInfoinflightInfos)

Console.WriteLine(flightInfo);

Console.WriteLine();

usingSystem;

usingSystem.Collections.Generic;

publicclassBaggageHandler:IObservableBaggageInfo

privateListIObserverBaggageInfoobservers;

privateListBaggageInfoflights;

publicBaggageHandler()

observers=newListIObserverBaggageInfo();

flights=newListBaggageInfo

publicIDisposableSubscribe(IObserverBaggageInfoobserver)

//Checkwhetherobserverisalreadyregistered.Ifnot,addit

if(!observers.Contains(observer))

observers.Add(observer);

//Provideobserverwithexistingdata.

foreach(variteminflights)

observer.OnNext(item);

returnnewUnsubscriberBaggageInfo(observers,observer);

//Calledtoindicateallbaggageisnowunloaded.

publicvoidBaggageStatus(intflightNo)

BaggageStatus(flightNo,String.Empty,0);

publicvoidBaggageStatus(intflightNo,stringfrom,intcarousel)

varinfo=newBaggageInfo(flightNo,from,carousel);

//Carouselisassigned,soaddnewinfoobjecttolist.

if(carousel0!flights.Contains(info))

flights.Add(info);

foreach(varobserverinobservers)

observer.OnNext(info);

elseif(carousel==0)

//Baggageclaimforflightisdone

varflightsToRemove=newListBaggageInfo

foreach(varflightinflights)

if(info.FlightNumber==flight.FlightNumber)

flightsToRemove.Add(flight);

foreach(varobserverinobservers)

observer.OnNext(info);

foreach(varflightToRemoveinflightsToRemove)

flights.Remove(flightToRemove);

flightsToRemove.Clear();

publicvoidLastBaggageClaimed()

foreach(varobserverinobservers)

observer.OnCompleted();

observers.Clear();

usingSystem;

usingSystem.Collections.Generic;

publicclassBaggageInfo

privateintflightNo;

privatestringorigin;

privateintlocation;

internalBaggageInfo(intflight,stringfrom,intcarousel)

this.flightNo=flight;

this.origin=from;

this.location=carousel;

publicintFlightNumber

get{returnthis.flightNo;}

publicstringFrom

get{returnthis.origin;}

publicintCarousel

get{returnthis.location;}

usingSystem;

usingSystem.Colle