【观察者设计模式详解】C/Java/JS/Go/Python/TS不同语言实现

简介

观察者模式（Observer Pattern）是一种行为型模式。它定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。

观察者模式使用三个类Subject、Observer和Client。Subject对象带有绑定观察者到Client对象和从Client对象解绑观察者的方法。我们创建Subject类、Observer抽象类和扩展了抽象类Observer的实体类。

作用

  1. 一个对象状态更新，其他依赖对象收到通知和自动更新的机制。
  2. 实现模块化分离，实现主题与观察者交互对象之间的松耦合。
    1）观察者定义了对象之间一对多的关系。
    2）被观察者(主题)用一个共同的接口来更新观察者。
    3）观察者和被观察者用松耦合方式结合，被观察者不知道观察者的细节，只知道观察者实现了观察者接口。

实现步骤

  1. 创建观察者observer基础接口，包含主题和更新方法
  2. 创建主题subject抽象类，包含observer列表以及添加和删除方法
  3. 创建具体的主题类，实现通知方法，发布通知时轮询通知全部观察者
  4. 创建多个具体观察者，与主题关联，并实现自己的更新方法
  5. 客户调用时先声明主题，再将观察者分别添加到主题，当主题发布通知时，观察者自动更新

UML

 

Java代码

观察者接口

 

// ObserverAPI.java 观察者接口，Java 9已经默认支持Observer接口
// 这里避免冲突采取ObserverAPI命名
public interface ObserverAPI {
public Subject subject = null;
public void update(String content);
}
 

具体观察者
 

 

 

// ConcreteObserver.java 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
// 不同的观察者也可以对应多个主题
public class ConcreteObserver implements ObserverAPI {
public Subject subject;
// 给观察者绑定主题，同时把观察者添加到主题列表
public ConcreteObserver(Subject subject) {
this.subject = subject;
this.subject.register((ObserverAPI) this);
}
// 观察者发出更新通知，不用单独告诉订阅者，由订阅者自行监听
public void update(String content) {
System.out.println(String.format("%s::update() [subject.name = %s content = %s]",
this.getClass().getName(),
this.subject.getName(), content));
}
}
 

 

 

// ConcreteObserver2.java 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
// 不同的观察者可以对应不同的主题。
public class ConcreteObserver2 implements ObserverAPI {
// 这里没有在构造器就绑定某个主题，而是从客户角度去注册观察者
public ConcreteObserver2() {
}
// 观察者发出更新通知，观察者自行监听
public void update(String content) {
System.out.println(String.format("%s::update() [content = %s]",
this.getClass().getName(), content));
}
}
 

抽象主题类
 

 

 

// Subject.java 定义抽象主题类或者接口，供具体主题类继承
public abstract class Subject {
private String name;
// protected Set<ObserverAPI> observers = new HashSet<>();
protected List<ObserverAPI> observers = new ArrayList<>();
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public void register(ObserverAPI observer) {
System.out.println(this.getClass().getName() + "::register() [observer = " + observer.getClass().getSimpleName() + "]");
observers.add(observer);
}
public void remove(ObserverAPI observer) {
observers.remove(observer);
}
// 通知由具体类来实现逻辑
public abstract void notify(String name);
}
 

具体主题类
 

 

 

// ConcreteSubject.java 观察者主题类，也是发布者，重写具体的通知方法。不同主题可以关联不同的观察者。
public class ConcreteSubject extends Subject {
public ConcreteSubject(String name) {
this.setName(name);
}
// 不同的主题类有自己的通知方法，批量通知绑定的观察者
@Override
public void notify(String content) {
System.out.println(this.getClass().getName() + "::notify() [content = " + content + "]");
for (Object observer : this.observers) {
((ObserverAPI) observer).update(content);
}
}
}
 

测试调用
 

 

 

/**
* 观察者模式应用非常广泛，主要是观察者提前绑定到发布者
* 当发布者发布消息时，批量广播通知，而无需逐一通知
* 观察者监听到消息后自己决定采取哪一种行为
*/
// 定义一个主题，也就是发布者
Subject concreteSubject = new ConcreteSubject("subject1");
// 再声明观察者，通过构造器注册到主题上
ObserverAPI observer1 = new ConcreteObserver(concreteSubject);
// 也可以单独给主题注册一个新的观察者
concreteSubject.register(new ConcreteObserver2());
// 可以移除观察者对象，可以打开注释试下
// concreteSubject.remove(observer1);
// 主题开始发布新通知，各观察者自动更新
concreteSubject.notify("hello, this is broadcast.");
 

Python代码
 

观察者接口
 

 

 

# ObserverAPI.py 观察者抽象父类，定义一些公共方法
class ObserverAPI:
def __init__(self, name):
self.name = name
# 观察者发出更新通知，观察者自行监听
def update(self, content):
print(self.__class__.__name__ + '::update() [content = ' + content + ']')
def set_name(self, name):
self.name = name
 

具体观察者
 

 

 

# ConcreteObserver.py 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
# 不同的观察者也可以对应多个主题
from src.ObserverAPI import ObserverAPI
# 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
# 不同的观察者也可以对应多个主题
class ConcreteObserver(ObserverAPI):
# 给观察者绑定主题，同时把观察者添加到主题列表
def __init__(self, subject, name):
ObserverAPI.__init__(self, name)
# python3支持的父类调用
# super(ConcreteObserver, self).__init__(name)
# super().__init__(name)
self.subject = subject
subject.register(self)
# 观察者发出更新通知，不用单独告诉订阅者，由订阅者自行监听
def update(self, content):
print(self.__class__.__name__ + '::update() [subject.name = ' +
self.subject.name + ' content = ' + content + ']')
 

 

 

# ConcreteObserver2.py 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
# 不同的观察者可以对应不同的主题。
from src.ObserverAPI import ObserverAPI
# 具体的观察者实现类，也可以看成订阅者，关联对应的主题类。
# 不同的观察者可以对应不同的主题。
class ConcreteObserver2(ObserverAPI):
# 这里没有在构造器就绑定某个主题，而是从客户角度去注册观察者
# 观察者发出更新通知，观察者自行监听
# def update(self, content):
# print(self.__class__.__name__ + '::update() [content = ' + content +']')
pass
 

抽象主题类
 

 

 

# Subject.py 定义抽象主题类或者接口，供具体主题类继承
class Subject:
def __init__(self, name):
self.name = name
self.observers = []
def get_name(self):
return self.name
def set_name(self, name):
self.name = name
def register(self, observer):
print(self.__class__.__name__ + '::register() [observer = ' +
observer.__class__.__name__ + ']')
self.observers.append(observer)
def remove(self, observer):
self.observers.remove(observer)
# 通知由具体类来实现逻辑
def notify(self, name):
pass
 

具体主题类
 

 

 

// ConcreteSubject.py 观察者主题类，也是发布者，重写具体的通知方法。不同主题可以关联不同的观察者。
from src.Subject import Subject
# 观察者主题类，也是发布者，重写具体的通知方法。不同主题可以关联不同的观察者。
class ConcreteSubject(Subject):
# 不同的主题类有自己的通知方法，批量通知绑定的观察者
def notify(self, content):
print(self.__class__.__name__ + '::notify() [content = ' + content +
']')
for observer in self.observers:
observer.update(content)
 

测试调用
 

 

 

import sys
import os
os_path = os.getcwd()
sys.path.append(os_path)
from src.ConcreteSubject import ConcreteSubject
from src.ConcreteObserver import ConcreteObserver
from src.ConcreteObserver2 import ConcreteObserver2
def test():
'''
* 观察者模式应用非常广泛，主要是观察者提前绑定到发布者
* 当发布者发布消息时，批量广播通知，而无需逐一通知
* 观察者监听到消息后自己决定采取哪一种行为
'''
# 定义一个主题，也就是发布者
concrete_subject = ConcreteSubject('subject1')
# 再声明观察者，通过构造器注册到主题上
observer1 = ConcreteObserver(concrete_subject, 'observer1')
# 也可以单独给主题注册一个新的观察者
observer2 = ConcreteObserver2('observer2')
concrete_subject.register(observer2)
# 可以移除观察者对象
# concrete_subject.remove(observer1)
# 主题开始发布新通知，各观察者自动更新
concrete_subject.notify('hello, this is broadcast.')
if __name__ == '__main__':
print(__file__)
print("test start:")
test()
 

更多语言版本
 

不同语言实现设计模式：https://github.com/microwind/design-pattern
 

  











本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/63103.html


如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！












相关文章










Go把Map转成对象








Go把Map转成对象




最近使用了Redis的Hash&#xff0c;把一个对象给存储到了hash里面&#xff0c;具体如下&#xff1a; 现在需要从RedisHash缓存里面把结果给取出来&#xff0c;同时赋值到一个对象上面 result, err : global.GVA_REDIS.HGetAll(context.Background(), key).Result() 问题是resul…




阅读更多...

















java实现文件的下载








java实现文件的下载




系统日志的获取不可能每次都登录服务器&#xff0c;所以在页面上能够下载系统运行的日志是必须的 
如何来实现日志的下载&#xff0c;这样的一个功能 前端我们用到的是window.open(...)这样可以发送一个get请求到后台 后台接收到get请求之后&#xff0c;如何实现对文件的下载 R…




阅读更多...

















（docker）mysql镜像拉取-创建容器-容器的使用【个人笔记】








（docker）mysql镜像拉取-创建容器-容器的使用【个人笔记】




【容器的第一次创建】 
容器的第一次创建&#xff0c;需要先下载镜像&#xff0c;从 
镜像拉取 
0、可以搜索镜像的版本 
docker search mysql1、先拉取MySQL的镜像&#xff0c;默认拉取最新版&#xff0c;使用下面的命令拉取mysql镜像 
docker pull mysql也可以指定mysql的版本…




阅读更多...

















RCNA——单臂路由








RCNA——单臂路由




一&#xff0c;实验背景 之前的VLAN实现的很多都是相同部门互相访问&#xff0c;不同部门无法访问。不过这次整来了一个路由器&#xff0c;领导说大部分的部门虽说有保密信息需要互相隔离&#xff0c;但是这些部门和其它部门也应该互相连通以方便工作交流。因此要配置新的环境&…




阅读更多...

















424. 替换后的最长重复字符








424. 替换后的最长重复字符




424. 替换后的最长重复字符  原题链接&#xff1a;完成情况&#xff1a;解题思路&#xff1a;参考代码&#xff1a; 原题链接&#xff1a; 
424. 替换后的最长重复字符 https://leetcode.cn/problems/longest-repeating-character-replacement/description/ 
完成情况&#xff…




阅读更多...

















SQL | 过滤数据








SQL | 过滤数据




4-过滤数据 
4.1-使用WHERE子句 
数据根据 WHERE 子句中指定的搜索条件进行过滤。WHERE 子句在表名&#xff08; FROM 子句&#xff09;之后给出。 
select prod_name,prod_price
from products
where prod_price  3.49; 
上述语句查询价格为3.49的行&#xff0c;然后输出名字和…




阅读更多...

















TDesign中后台管理系统-用户登录








TDesign中后台管理系统-用户登录




目录 1 创建用户表2 开发后端接口3 测试接口4 修改登录页面调用后端接口最终效果总结 中后台系统第一个要实现的功能就是登录了&#xff0c;我们通常的逻辑是让用户在登录页面输入用户名和密码&#xff0c;调用后端接口去验证用户的合法性&#xff0c;然后根据接口返回的结果进…




阅读更多...

















PE启动盘和U启动盘(第三十六课)








PE启动盘和U启动盘(第三十六课)




PE启动盘和U启动盘(第三十六课) 
一 WindowsPE工具盘 
1. 制作WinPE镜像光盘 双击WePE64_V2.2-是-点击右下角光盘图标-选择ISO的输出位置-立即生成ISO 2. 通过光盘启动WinPE




阅读更多...

















Mysql整理








Mysql整理




一、基础概念 
1. 索引 
之前的文章已经写过了&#xff0c;比较细 
数据库索引含义,类别,用法,创建方式_表结构加树形id和索引是为什么_马丁•路德•王的博客-CSDN博客 
简单概括就是在表的某个列或者多个列或者联合表的时候加个索引&#xff0c;类似图书馆书本的索引编号&…




阅读更多...

















Javascript 正则








Javascript 正则




基本语法 
定义 
JavaScript种正则表达式有两种定义方式 构造函数 var regnew RegExp(<%[^%>]%>,g);字面量 var reg/<%[^%>]%>/g;g&#xff1a; global&#xff0c;全文搜索&#xff0c;默认搜索到第一个结果接停止i&#xff1a;ingore case&#xff0c;忽略…




阅读更多...

















刘汉清：从生活到画布，宠物成为灵感源泉








刘汉清：从生活到画布，宠物成为灵感源泉




出生于中国镇江的艺术家刘汉清&#xff0c;其作品展现出他对日常生活的深入洞察力&#xff0c;以及对美的独特理解。他的作品通常没有视觉参考&#xff0c;而是通过对他周围环境的理解&#xff0c;尤其是他的宠物&#xff0c;来进行创作。 
在刘汉清的创作过程中&#xff0c;他…




阅读更多...

















VS + Qt Include宏指向的路径错误或者project特性的值无效








VS + Qt Include宏指向的路径错误或者project特性的值无效




如果你电脑上有多个Qt版本&#xff0c;不同项目又依赖不同的Qt版本&#xff0c;就会偶尔出现Qt Include宏指向的Qt路径并不是当前依赖的Qt路径。有时候还会出现project特性的值无效&#xff0c;路径中含有非法字符错误&#xff0c;如下图所示 这个问题的解决办法就是删除工程目…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023