Android设计模式--观察者模式
时间是一只藏在黑暗中温柔的手,在你一出神一恍惚之间,物走星移
一,定义
观察者模式是定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知并被自动更新
字面意思很好理解,我们常用的订阅-发布系统就是观察者模式。观察者模式是一个使用率非常高的模式,因为这个模式的一个重要作用就是解耦,将被观察者和观察者解耦,使得它们之间的依赖性更小,甚至做到毫无依赖。
二,使用场景
1,关联行为场景,需要注意的是,关联行为是可拆分的,而不是组合关系
2,事件多级触发场景
3,跨系统的消息交互场景,如消息队列,事件总线的处理机制
观察者模式可以分为四个角色:
1,抽象主题,也就是被观察的角色,抽象主题角色把所有观察者对象的引用保存在一个集合里,每个主题都可以有任意数量的观察者,抽象主题提供一个接口,可以增加和删除观察者对象。
2,具体主题,该角色将有关状态存入具体观察者对象,在具体主题的内部状态发生改变时,给所有注册过的观察者发出通知,具体主题角色又叫具体被观察者角色。
3,抽象观察者,该角色是观察者的抽象类,它定义了一个更新接口,使得在得到主题的更改通知时更新自己。
4,具体的观察者,该角色实现抽象观察者角色所定义的更新接口,以便在主题的状态发生变化时更新自身的状态。
三,使用案例
在我们的开发中,都会遇到下载升级的场景,需要边下载边显示升级进度,还需要在下载完成或者下载失败之后更新状态为正在安装或者下载失败,可能有的应用需要显示进度的页面还不止一个,这个时候使用观察者模式就再好不过了。
首先,我们需要定义一个观察者抽象接口,实现两个方法:
/** @创建者: 袁震* @创建时间: 2023/7/25 10:37* @描述: 观察者接口*/public interface DownLoadObserver {//下载状态发生变化public void onDownloadStateChanged(boolean isSuccess,String path);//下载进度发生变化public void onDownloadProgressChanged(int progress);}
然后实现一个下载管理器,这个下载管理器,实际上就是被观察者,里面注册了观察者,实现了下载功能,并在下载进度和状态改变时,通知观察者:
/** @创建者: 袁震* @创建时间: 2023/7/25 10:34* @描述: 下载管理器 被观察者*/
public class DownloadManager {private static final String TAG = "DownloadManager";private int errorCount =0;//下载失败次数// 私有的构造函数private DownloadManager() {}// 私有的静态内部类private static class Holder {private static DownloadManager instance = new DownloadManager();}// 开放的获取单例对象的方法public static DownloadManager getInstance() {return DownloadManager.Holder.instance;}private ArrayList<DownLoadObserver> mObservers = new ArrayList<DownLoadObserver>();//注册观察者public void registerObserver(DownLoadObserver observer){if(observer!= null && !mObservers.contains(observer)){Log.d(TAG,"----添加observer");mObservers.add(observer);}}//注销观察者public void unregisterObserver(DownLoadObserver observer){if(observer!= null && mObservers.contains(observer)){mObservers.remove(observer);}}// 通知下载状态发生变化public synchronized void notifyDownloadStateChanged(boolean isSuccess,String path) {for (DownLoadObserver observer : mObservers) {observer.onDownloadStateChanged(isSuccess,path);}}// 通知下载进度发生变化public synchronized void notifyDownloadProgressChanged(int progress) {for (DownLoadObserver observer : mObservers) {observer.onDownloadProgressChanged(progress);}}public void downLoadApk(String fileUrl,String name){//调用线程池中的线程A10ThreadExecutor.getExecutorService(A10ThreadExecutor.HANDLE_MODULE).execute(() -> {String rootDir = "/sdcard/Update_APK/";Log.d(TAG, "下载路径为:" + rootDir);Utils.delAllFile(rootDir);OmniHttp.downLoad(fileUrl).savePath(rootDir).saveName(name).execute(new DownloadProgressCallBack<String>() {@Overridepublic void update(long bytesRead, long contentLength, boolean done) {notifyDownloadProgressChanged((int) ((bytesRead * 100)/contentLength));}@Overridepublic void onStart() {}@Overridepublic void onComplete(String path) {notifyDownloadStateChanged(true,path);Log.d(TAG, "-------下载成功path=" + path);}@Overridepublic void onError(final ApiException e) {errorCount++;errMethod(fileUrl,name,errorCount);Log.e(TAG, "----下载失败:" + e.getMessage()+"--失败次数:"+errorCount);}});});}}
在实际使用中:
/** @创建者: 袁震* @创建时间: 2023/7/24 14:14* @描述: 升级页面*/
@RequirePresenter(UpdatePresenter.class)
public class UpdateActivity extends BaseActivity<UpdatePresenter> implements UpdateContract.IUpdateView, DownLoadObserver {private static final String TAG = "UpdateActivity";public static final String UPDATE_DATE = "UPDATE_DATE";private ProgressBar pb;private TextView txtProgress;private TextView txtContent;@Overridepublic int getLayoutId() {return R.layout.activity_update;}@Overridepublic void initFields() {pb = findViewById(R.id.progressBar);txtProgress = findViewById(R.id.txt_progress);txtContent = findViewById(R.id.txt_content);//注册观察者DownloadManager.getInstance().registerObserver(this);}@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);String stringExtra = getIntent().getStringExtra(UPDATE_DATE);bean = GsonUtils.json2Bean(stringExtra, UpdatePackageBean.class);}@Overridepublic void onDownloadStateChanged(boolean isSuccess,String path) {Log.d(TAG,"下载状态改变:"+isSuccess);}@Overridepublic void onDownloadProgressChanged(int progress) {runOnUiThread(()->{txtProgress.setVisibility(View.VISIBLE);txtContent.setText("正在下载新的安装程序,请不要关机或断电");txtProgress.setText(progress+"%");pb.setProgress(progress);});}@Overrideprotected void onDestroy() {super.onDestroy();//注销观察者DownloadManager.getInstance().unregisterObserver(this);}}
这样就通过观察者模式实现了UI和业务逻辑的解耦已经实时更新问题。
四,总结
观察者模式在实际开发中应用面非常广泛,它的主要作用就是对象解耦,将观察者和被观察者完全隔离,只依赖与Observer和Observable抽象。
优点:
1,观察者和被观察者之间是抽象耦合,应对业务变化
2,增加系统灵活性,可扩展性。
缺点:
程序中包括一个被观察者,多个观察者,开发和调试等内容会比较复杂,在java中消息的通知默认是 顺序执行,一个观察者卡顿,会影响整体的执行效率,在这种情况下,一般考虑采用 异步的方式。
参考文献:Android源码设计模式第二版
相关文章:
Android设计模式--观察者模式
时间是一只藏在黑暗中温柔的手,在你一出神一恍惚之间,物走星移 一,定义 观察者模式是定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知并被自动更新 字面意思很好理解&am…...
【Linux】Ubuntu16.04下安装python高版本--源码安装
Ubuntu16.04下完美安装python高版本及对应版本的pip 方法一:直接用命令安装python3.6(但我没安装成功) 好像是因为Ubuntu16.04的软件仓库(源)中python的最高版本就是python3.5,所以无法直接用apt来安装 #方法一 sudo…...
变长子网划分问题的二叉树解法
计网的变长子网划分、计组的变长操作码划分、数据结构的哈夫曼编码,都是前缀编码的本质(变长操作码的二叉树解法我还在琢磨中) 【二叉树解法】每条从叶结点到根节点的路径上有且只有一个被分配的结点: 【例】现将一个IP网络划分成…...
编译安装redis及配置多实例
yum安装是这种十分简单的方法我们就不在提及了,今天我们来做一下redis的编译安装 Redis源码包官方下载链接:http://download.redis.io/releases/ 一、编译安装: 安装依赖包 dnf -y install make gcc jemalloc-devel systemd-devel如果是…...
网络(一)总纲
一 总纲 ① 背景 1、该资料不管是在华为内部还是外部都是很出名的2、该教程仅仅作为个人笔记,形成自己的网络知识体系,自己会按照教程手把手做实验,copy图谱备注: 自己没有处理过物理网和虚拟网,所以会以一个小白的角度去理解,可能存在偏差3、立足点:…...
WPF中的App类介绍
在WPF (Windows Presentation Foundation) 应用程序中,App 类扮演着很重要的角色。这个类通常在每个WPF应用程序中都会有,并且生成在App.xaml文件和其代码后台App.xaml.cs中。App类通常继承自System.Windows.Application类,并且有以下的主要职…...
.nc格式文件的显示及特殊裁剪方式
最近我们遇到一个nc格式的文件,需要将它做成报告插图,bing搜索一番以后,了解到nc的全名为NetCDF(network Common Data Form),是一种网络通用数据格式,广泛用于大气科学、水文、海洋学、环境模拟、地球物理等诸多领域。…...
为什么需要线程池?C++如何实现一个线程池?
为什么需要线程池?C如何实现一个线程池? 为什么需要线程池?C如何实现一个线程池?...
多视图聚类的论文阅读
当聚类的方式使用的是某一类预定义好的相似性度量时, 会出现如下情况: 数据聚类方面取得了成功,但它们通常依赖于预定义的相似性度量,而这些度量受原始方法的影响:当输入维数相对较高时,往往是无效的。 1. Deep Mult…...
shell脚本适用场景
1.适用场景 Shell脚本是一种用于自动化和批量处理任务的脚本语言。它通常在Unix/Linux系统中使用,并且被广泛应用于各种场景,包括但不限于以下几个方面: 自动化任务:Shell脚本可以用于编写自动化脚本,完成一系列重复性…...
Bash openldap同步AD组织数据
将AD的ou同步到openldap(可支持全量同步和增量同步) 整体思路如下: 从ad导出所有的数据,然后进行参数替换以及处理,处理后的文件称为A;从openldap导出所有的数据,然后进行参数替换以及处理&am…...
C#WPF文本转语音实例
本文介绍C#WPF文本转语音实例 实现方法:使用类库(SpeechSynthesizer )实现的。 一、首先是安装程序包。 二、创建项目 需要添加引用using System.Speech.Synthesis; UI界面 <Windowx:Class="TextToSpeechDemo.MainWindow"xmlns="http://schemas.micr…...
08-流媒体-RTMP拉流
整体方案: 采集端:摄像头采集(YUV)->编码(YUV转H264)->写封装(H264转FLV)->RTMP推流 客户端:RTMP拉流->解封装(FLV转H264)…...
一键免费去除视频水印和字幕的AI工具
最近有学员经常让我分享好用的智能抹除视频水印字幕AI工具,今天就给大家分享一个我经常用到的这款工具——腾讯智影,这个平台提供的智能抹除功能,借助这个工具我们可以将视频中不需要的字幕或者水印删除掉。 不过这款工具每天有三次免费次数…...
实验六:Android的网络编程基础
实验六:Android 的网络编程基础 6.1 实验目的 本次实验的目的是让大家熟悉 Android 开发中的如何获取天气预报,包括了 解和熟悉 WebView、WebService 使用、网络编程事件处理等内容。 6.2 实验要求 熟悉和掌握 WebView 使用 了解 Android 的网络编程…...
09-流媒体-FLV解复用
整体方案: 采集端:摄像头采集(YUV)->编码(YUV转H264)->写封装(H264转FLV)->RTMP推流 客户端:RTMP拉流->解封装(FLV转H264)…...
信息的浏览
万维网(WWW)是目前Internet上最流行的一种服务,它是建立在Internet上的多媒体集合信息系统。它利用超媒体的信息获取技术,通过一种超文本的表达方式,将所有WWW上的信息连接在一起。我们使用浏览器浏览网上的信息。 ▶浏览器 浏览器是指可以…...
vue directive自定义指令实现弹窗可拖动
vue2 创建一个js文件 // draggable.js export default {// 定义 Vue 插件install(Vue) {Vue.directive(draggable, { // 全局指令名为 v-draggableinserted(el) {el.onmousedown function (ev) {// 获取鼠标按下时的偏移量(鼠标位置 - 元素位置)const…...
07-流媒体-RTMP推流
整体方案: 采集端:摄像头采集(YUV)->编码(YUV转H264)->写封装(H264转FLV)->RTMP推流 客户端:RTMP拉流->解封装(FLV转H264)…...
Neo4j安装(Docker中安装Neo4j)
天行健,君子以自强不息;地势坤,君子以厚德载物。 每个人都有惰性,但不断学习是好好生活的根本,共勉! 文章均为学习整理笔记,分享记录为主,如有错误请指正,共同学习进步。…...
在四层代理中还原真实客户端ngx_stream_realip_module
一、模块原理与价值 PROXY Protocol 回溯 第三方负载均衡(如 HAProxy、AWS NLB、阿里 SLB)发起上游连接时,将真实客户端 IP/Port 写入 PROXY Protocol v1/v2 头。Stream 层接收到头部后,ngx_stream_realip_module 从中提取原始信息…...
【ROS】Nav2源码之nav2_behavior_tree-行为树节点列表
1、行为树节点分类 在 Nav2(Navigation2)的行为树框架中,行为树节点插件按照功能分为 Action(动作节点)、Condition(条件节点)、Control(控制节点) 和 Decorator(装饰节点) 四类。 1.1 动作节点 Action 执行具体的机器人操作或任务,直接与硬件、传感器或外部系统…...
SpringBoot+uniapp 的 Champion 俱乐部微信小程序设计与实现,论文初版实现
摘要 本论文旨在设计并实现基于 SpringBoot 和 uniapp 的 Champion 俱乐部微信小程序,以满足俱乐部线上活动推广、会员管理、社交互动等需求。通过 SpringBoot 搭建后端服务,提供稳定高效的数据处理与业务逻辑支持;利用 uniapp 实现跨平台前…...
mysql已经安装,但是通过rpm -q 没有找mysql相关的已安装包
文章目录 现象:mysql已经安装,但是通过rpm -q 没有找mysql相关的已安装包遇到 rpm 命令找不到已经安装的 MySQL 包时,可能是因为以下几个原因:1.MySQL 不是通过 RPM 包安装的2.RPM 数据库损坏3.使用了不同的包名或路径4.使用其他包…...
Typeerror: cannot read properties of undefined (reading ‘XXX‘)
最近需要在离线机器上运行软件,所以得把软件用docker打包起来,大部分功能都没问题,出了一个奇怪的事情。同样的代码,在本机上用vscode可以运行起来,但是打包之后在docker里出现了问题。使用的是dialog组件,…...
如何在网页里填写 PDF 表格?
有时候,你可能希望用户能在你的网站上填写 PDF 表单。然而,这件事并不简单,因为 PDF 并不是一种原生的网页格式。虽然浏览器可以显示 PDF 文件,但原生并不支持编辑或填写它们。更糟的是,如果你想收集表单数据ÿ…...
短视频矩阵系统文案创作功能开发实践,定制化开发
在短视频行业迅猛发展的当下,企业和个人创作者为了扩大影响力、提升传播效果,纷纷采用短视频矩阵运营策略,同时管理多个平台、多个账号的内容发布。然而,频繁的文案创作需求让运营者疲于应对,如何高效产出高质量文案成…...
安宝特案例丨Vuzix AR智能眼镜集成专业软件,助力卢森堡医院药房转型,赢得辉瑞创新奖
在Vuzix M400 AR智能眼镜的助力下,卢森堡罗伯特舒曼医院(the Robert Schuman Hospitals, HRS)凭借在无菌制剂生产流程中引入增强现实技术(AR)创新项目,荣获了2024年6月7日由卢森堡医院药剂师协会࿰…...
【JavaSE】多线程基础学习笔记
多线程基础 -线程相关概念 程序(Program) 是为完成特定任务、用某种语言编写的一组指令的集合简单的说:就是我们写的代码 进程 进程是指运行中的程序,比如我们使用QQ,就启动了一个进程,操作系统就会为该进程分配内存…...
【学习笔记】erase 删除顺序迭代器后迭代器失效的解决方案
目录 使用 erase 返回值继续迭代使用索引进行遍历 我们知道类似 vector 的顺序迭代器被删除后,迭代器会失效,因为顺序迭代器在内存中是连续存储的,元素删除后,后续元素会前移。 但一些场景中,我们又需要在执行删除操作…...
