using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;

namespace MyObserver
{
    //定义Subject抽象类，它是'ConcreteSubject'具体目标对象的基类
    //要实现Observer模式时，通常将数据对象作为目标（Subject），各个显示数据的对象作为观察者Observer
    //每一个观察者（Observer）通过调用目标（Subject）中的一个公有（public）方法，在他所感兴趣的数据中注册（registers）自己。
    //这样，当数据改变时，每一个目标（Subject）通过观察者（Observer）的接口发送更新通知。

abstract class Subject
    { 
        #region 定义一个List来装盛所有与此数据对象相联系的观察者Observer
        private List<Observer> _observers = new List<Observer>();
        #endregion

#region 附加或解除Observer功能(注册或注销功能)
        public void Attach(Observer observer)
        {
            _observers.Add(observer); //observer观察者在此数据对象中注册（registers）自己。
        }

public void Detach(Observer observer)
        {
            _observers.Remove(observer);//在此数据对象中取消注册，也即让对象变更时不用再通知此observer观察者
        }
        #endregion

#region 通知在_observers列表中的所有观察者
        public void Nofity()
        {
            //遍历观察者列表，按列表的名录逐一通知
            foreach (Observer o in _observers)
            {
                o.Update();
            }
        }
        #endregion
    }
 
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    //定义具体数据对象类，它继承自Subject抽象类
    class ConcreteSubject:Subject
    {
        #region SubjectState属性
        private string _subjectState;
        public string SubjectState
        {
            get { return _subjectState; }
            set { _subjectState = value; }
        }
        #endregion
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    #region 定义Observer抽象类，它是ConcreteObserver的基类
    abstract  class Observer
    {
        //定义一个用于发送更新通知的接口
        //这样，当数据改变时，每一个目标（Subject）通过观察者（Observer）的接口发送更新通知。
        public abstract void Update();
    }
    #endregion
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    class ConcreteObserver:Observer 
    {
        private string _name;
        private string _observerState;

private ConcreteSubject _subject;
        public ConcreteSubject Subject
        {
            get { return _subject; }
            set { _subject = value; }
        }

#region 构造函数
        public ConcreteObserver(ConcreteSubject subject, string name)
        {
            this._subject = subject;
            this._name = name;
        }
        #endregion

#region 实现目标数据更新通知接口
        public override void Update()
        {
            _observerState = _subject.SubjectState;
            Console.WriteLine("观察者 {0} 收到的数据对象的新状态值是 {1}",_name,_observerState);

}
        #endregion

}
}

            #region 基本思路示例
            Console.WriteLine("----------观察者模式基本思路示例--------");
            ConcreteSubject s = new ConcreteSubject(); //首先创建一个数据对象
            s.Attach(new ConcreteObserver(s, "X")); //向这个数据对象内注册三个观察者X,Y,Z
            s.Attach(new ConcreteObserver(s, "Y"));
            s.Attach(new ConcreteObserver(s, "Z"));

s.SubjectState = "ABC"; //改变数据对象的状态值
            s.Nofity(); //调用数据对象的通知功能来依次通知已经注册的观察者

Console.ReadKey();
            #endregion

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;

namespace MyObserver
{
    abstract class Guard
    {
        #region 定义一个List来收集所有需要通知到的其它士兵
        private List<Soldier> _soldiers = new List<Soldier>();
        #endregion

#region 附加或解除Observer功能(注册或注销功能)
        public void Attach(Soldier observer)
        {
            _soldiers.Add(observer); //observer观察者在此数据对象中注册（registers）自己。
        }

public void Detach(Soldier observer)
        {
            _soldiers.Remove(observer);//在此数据对象中取消注册，也即让对象变更时不用再通知此observer观察者
        }
        #endregion

#region 通知在_observers列表中的所有观察者
        public void Nofity()
        {
            //遍历观察者列表，按列表的名录逐一通知
            foreach (Soldier o in _soldiers)
            {
                o.Update();
            }
        }
        #endregion
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    class ConcreteGurad:Guard
    {
        private string _name;
        public string Name
        {
            get { return _name; }
            set { _name = value; }
        }

#region FightInfo属性
        private string  _fightInfo;
        public string FightInfo
        {
            get { return _fightInfo; }
            set { _fightInfo = value; }
        }
        #endregion

public ConcreteGurad(string name)
        {
            this._name = name;
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    abstract  class Soldier
    {
        public abstract void Update();
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace MyObserver
{
    class ConcreteSoldier:Soldier 
    {
        private string _observerState;
        private string _name;

private ConcreteGurad _subject;
        public ConcreteGurad Subject
        {
            get { return _subject; }
            set { _subject = value; }
        }

#region 构造函数
        public ConcreteSoldier(ConcreteGurad subject, string name)
        {
            this._subject = subject;
            this._name = name;
        }
        #endregion

#region 实现目标数据更新通知接口
        public override void Update()
        {
            _observerState = _subject.FightInfo ;
            Console.WriteLine("士兵 '{0}'  收到哨兵 '{1}' 的信号:{2}",_name,_subject.Name ,_observerState);

}
        #endregion
    }
}

            #region 我的团长我的团
            Console.WriteLine("----------我的团长我的团观察者模式示例--------");
            ConcreteGurad cg = new ConcreteGurad("孟烦了");
            ConcreteSoldier yaoma = new ConcreteSoldier(cg, "要麻");
            ConcreteSoldier sepigu = new ConcreteSoldier(cg, "蛇屁股");
            ConcreteSoldier doubing = new ConcreteSoldier(cg, "豆饼");
            ConcreteSoldier kangya = new ConcreteSoldier(cg, "康丫");
            ConcreteSoldier milong = new ConcreteSoldier(cg, "迷龙");
            ConcreteSoldier bula = new ConcreteSoldier(cg, "不辣");

cg.Attach(yaoma);
            cg.Attach(sepigu);
            cg.Attach(doubing);
            cg.Attach(kangya);
            cg.Attach(milong);
            cg.Attach(bula);

cg.FightInfo = "鬼子从右边摸上来了,大家准备歼灭他们.";
            cg.Nofity();
            Console.ReadKey();
            #endregion