AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

乐在其中设计模式(C#) - 观察者模式(Observer Pattern)

2014-03-09 792
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 原文:乐在其中设计模式(C#) - 观察者模式(Observer Pattern)[索引页][源码下载]乐在其中设计模式(C#) - 观察者模式(Observer Pattern) 作者：webabcd 介绍 定义对象间的一种一对多的依赖关系,以便当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并自动刷新。
原文: 乐在其中设计模式(C#) - 观察者模式(Observer Pattern)

[索引页]
[源码下载]


乐在其中设计模式(C#) - 观察者模式(Observer Pattern)


作者： webabcd


介绍
定义对象间的一种一对多的依赖关系,以便当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并自动刷新。


示例
有一个Message实体类，某些对象对它的操作有Insert()方法，当发生某些改变的时候，通知所有这些对象并执行Insert()方法。



MessageModel
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// Message实体类
    /// </summary>
    public class MessageModel
    {
        /**//// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="msg">Message内容</param>
        /// <param name="pt">Message发布时间</param>
        public MessageModel(string msg, DateTime pt)
        {
            this._message = msg;
            this._publishTime = pt;
        }

        private string _message;
        /**//// <summary>
        /// Message内容
        /// </summary>
        public string Message
        {
            get { return _message; }
            set { _message = value; }
        }

        private DateTime _publishTime;
        /**//// <summary>
        /// Message发布时间
        /// </summary>
        public DateTime PublishTime
        {
            get { return _publishTime; }
            set { _publishTime = value; }
        }
    }
}

IMessage
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// 操作Message的接口（Observer）
    /// </summary>
    public interface IMessage
    {
        /**//// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message实体对象</param>
        /// <returns></returns>
        string Insert(MessageModel mm);
    }
}

SqlMessage
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// Sql方式操作Message（ConcreteObserver）
    /// </summary>
    public class SqlMessage : IMessage
    {
        /**//// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message实体对象</param>
        /// <returns></returns>
        public string Insert(MessageModel mm)
        {
            return "sql方式：" + mm.Message + " " + mm.PublishTime.ToString();
        } 
    }
}

XmlMessage
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// Xml方式操作Message（ConcreteObserver）
    /// </summary>
    public class XmlMessage : IMessage
    {
        /**//// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message实体对象</param>
        /// <returns></returns>
        public string Insert(MessageModel mm)
        {
            return "xml方式：" + mm.Message + " " + mm.PublishTime.ToString();
        } 
    }
}

AbstractMessageSubject
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// 抽象Message主题（Subject）
    /// </summary>
    public abstract class AbstractMessageSubject
    {
        private MessageModel _messageModel;
        private List<IMessage> list = new List<IMessage>();

        /**//// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="mm">Message实体对象</param>
        public AbstractMessageSubject(MessageModel mm)
        {
            this._messageModel = mm;
        }

        /**//// <summary>
        /// 添加一个实现IMessage接口的对象
        /// </summary>
        /// <param name="m">实现IMessage接口的对象</param>
        public void Attach(IMessage m)
        {
            list.Add(m);
        }

        /**//// <summary>
        /// 移除一个实现IMessage接口的对象
        /// </summary>
        /// <param name="m">实现IMessage接口的对象</param>
        public void Detach(IMessage m)
        {
            list.Remove(m);
        }

        /**//// <summary>
        /// 通知所有观察者
        /// </summary>
        /// <returns></returns>
        public string Notify()
        {
            string s = "";
            foreach (IMessage i in list)
            {
                s += i.Insert(_messageModel);
                s += "<br />";
            }

            return s;
        }

        /**//// <summary>
        /// Message发布时间
        /// </summary>
        public DateTime PublishTime
        {
            get { return _messageModel.PublishTime; }
            set
            {
                _messageModel.PublishTime = value;
                Notify();
            }
        }
    }
}

MessageSubject
using  System;
 using  System.Collections.Generic;
 using  System.Text;

 namespace  Pattern.Observer
 {
    /**//// <summary>
    /// Message主题（ConcreteSubject）
    /// </summary>
    public class MessageSubject : AbstractMessageSubject
    {
        /**//// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="mm">Message实体对象</param>
        public MessageSubject(MessageModel mm)
            : base(mm)
        {
 
        }
    }
}


Test
using  System;
 using  System.Data;
 using  System.Configuration;
 using  System.Collections;
 using  System.Web;
 using  System.Web.Security;
 using  System.Web.UI;
 using  System.Web.UI.WebControls;
 using  System.Web.UI.WebControls.WebParts;
 using  System.Web.UI.HtmlControls;

 using  Pattern.Observer;

 public  partial  class  Observer : System.Web.UI.Page
 {
    protected void Page_Load(object sender, EventArgs e)
    {
        MessageSubject m = new MessageSubject(new MessageModel("插入Message", DateTime.Now));

        SqlMessage sqlMessage = new SqlMessage();
        XmlMessage xmlMessage = new XmlMessage();

        m.Attach(sqlMessage);
        m.Attach(xmlMessage);

        // System.Threading.Thread.Sleep(1000);
        // 修改了PublishTime就会通知所有观察者
        // m.PublishTime = DateTime.Now;
        
        Response.Write(m.Notify());
    }
}

运行结果
sql方式：插入Message 2007-5-26 9:38:18
xml方式：插入Message 2007-5-26 9:38:18


参考
http://www.dofactory.com/Patterns/PatternObserver.aspx


OK
[源码下载]
文章标签：
C#
SQL
数据格式
XML
索引
设计模式
关键词：
设计模式观察者模式
C#观察者模式
设计模式pattern
设计模式observer
设计模式观察者模式observer
杰克.陈
目录
相关文章
stefanie燕
|
1月前
|
设计模式 监控 Java
Kotlin - 改良设计模式 - 观察者模式
Kotlin - 改良设计模式 - 观察者模式
stefanie燕
53 3
划雨悦潭之赋
|
3天前
|
设计模式 存储 供应链
前端必须掌握的设计模式——观察者模式
观察者模式（Observer Pattern）是一种行为型设计模式，实现了一种订阅机制。它包含两个角色：**观察者**（订阅消息、接收通知并执行操作）和**被观察者**（维护观察者列表、发送通知）。两者通过一对多的关系实现解耦，当被观察者状态改变时，会通知所有订阅的观察者。例如，商店老板作为被观察者，记录客户的需求并在商品到货时通知他们。前端应用中，如DOM事件注册、MutationObserver等也体现了这一模式。
划雨悦潭之赋
23 4
游客syv66y3m2ksnc
|
1月前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
游客syv66y3m2ksnc
38 1
小王老师呀
|
27天前
|
设计模式 消息中间件 搜索推荐
Java 设计模式——观察者模式：从优衣库不使用新疆棉事件看系统的动态响应
【11月更文挑战第17天】观察者模式是一种行为设计模式，定义了一对多的依赖关系，使多个观察者对象能直接监听并响应某一主题对象的状态变化。本文介绍了观察者模式的基本概念、商业系统中的应用实例，如优衣库事件中各相关方的动态响应，以及模式的优势和实际系统设计中的应用建议，包括事件驱动架构和消息队列的使用。
小王老师呀
46 6
聚优云惠
|
29天前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
聚优云惠
37 1
聚优云惠
|
1月前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
聚优云惠
29 3
聚优云惠
|
2月前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
聚优云惠
36 9
毓秀清荷
|
2月前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
毓秀清荷
37 2
我是快乐的嘟嘟
|
2月前
|
设计模式 监控 UED
设计模式之观察者模式
【10月更文挑战第12天】 观察者模式是一种行为型设计模式，定义了一对多的依赖关系，当一个对象状态改变时，所有依赖它的对象都会自动更新。主要由主题（被观察者）和观察者组成，实现对象间的松耦合，广泛应用于用户界面、事件驱动系统和数据监控等领域。
我是快乐的嘟嘟
47 1
毓秀清荷
|
2月前
|
设计模式 监控 Java
Kotlin教程笔记(52) - 改良设计模式 - 观察者模式
本教程详细讲解Kotlin语法，适合深入学习。对于快速掌握Kotlin，推荐“简洁”系列教程。本文特别介绍了观察者模式，包括使用Java API和Kotlin委托属性（如Delegates.observable）实现的方法，旨在帮助开发者更高效地实现和优化观察者模式的应用。
毓秀清荷
42 3