Java编程之内置观察者模式实例详解
程序员文章站
2023-12-20 17:11:58
本文实例讲述了java内置观察者模式。分享给大家供大家参考,具体如下:
之前也简单地写过观察者模式(又称为发布-订阅模式)小例子,现在项目中也常用到该模式。今天贴一下如何...
本文实例讲述了java内置观察者模式。分享给大家供大家参考,具体如下:
之前也简单地写过观察者模式(又称为发布-订阅模式)小例子,现在项目中也常用到该模式。今天贴一下如何使用java内置的观察者模式。
主要使用到的java api就两个类:
observer接口:观察者对象,监听被观察者对象数据变化,一是数据发生变化 ,就做出相应地啥响应。
observable类:被观察者对象,提供添加及移出观察者对像方法,数据发生哟完成时并通知所有已经添加进来的观察者对象。
被观察者代码示例:
//observable是被观察者对象接口,实现该接口就是:目标(被观察者)的具体实现 public class targetobservable extends observable { // 要观察的数据:消息发生改变时,所有被添加的观察者都能收到通知 private string message; public string getconent() { return message; } public void setmessage(string message) { this.message = message; // 被观察者数据发生变化时,通过以下两行代码通知所有的观察者 this.setchanged(); this.notifyobservers(message); } }
2个观察者代码示例:
//observer对象是观察者,实现observer的对象就是具体的观察者对象 public class targetobserver implements observer { // 定义观察者名称 private string name; public string getobservername() { return name; } public void setobservername(string observername) { this.name = observername; } @override public void update(observable arg0, object arg1) { //更新消息数据 system.out.println(name + "收到了发生变化的数据内容是:" + ((targetobservable) arg0).getconent()); } }
public class targetobserver01 implements observer { // 定义观察者名称 private string name01; public string getobservername() { return name01; } public void setobservername(string observername) { this.name01 = observername; } @override public void update(observable arg0, object arg1) { //更新消息数据 system.out.println(name01 + "收到了发生变化的数据内容是:" + ((targetobservable) arg0).getconent()); } }
测试代码:
/** * @description:测试类 * @author ldm * @date 2016-11-1 上午8:29:07 */ public static void main(string[] args) { // 创建一个具体的被 观察者 targetobservable observable = new targetobservable(); // 创建第一个观察者 targetobserver one = new targetobserver(); one.setobservername("我是观察者a"); // 创建第二个观察者 targetobserver01 two = new targetobserver01(); two.setobservername("我是观察者b"); // 注册观察者 observable.addobserver(one); observable.addobserver(two); // 目标更新天气情况 observable.setmessage("***我要更新的数据***"); } }
执行结果:
我是观察者b收到了发生变化的数据内容是:—–我要更新的数据—– 我是观察者a收到了发生变化的数据内容是:—–我要更新的数据—–
模式优点:
一个被观察者可以对应多个观察者,当被观察者发生变化的时候,他可以将消息通知给所有已经添加观察者。基于接口实现为程序提供了更大的灵活性。
但在使用时要注意根据条件及时添加或移除观察者对象,否则可能导致意料外结果 。
最后附上observer和observable的原码,这样我们自己在写的时候就知道如何下手了:
package java.util; import java.util.observable; public interface observer { void update(observable var1, object var2); }
package java.util; import java.util.observer; import java.util.vector; public class observable { private boolean changed = false; private vector<observer> obs = new vector(); public observable() { } public synchronized void addobserver(observer var1) { if(var1 == null) { throw new nullpointerexception(); } else { if(!this.obs.contains(var1)) { this.obs.addelement(var1); } } } public synchronized void deleteobserver(observer var1) { this.obs.removeelement(var1); } public void notifyobservers() { this.notifyobservers((object)null); } public void notifyobservers(object var1) { object[] var2; synchronized(this) { if(!this.changed) { return; } var2 = this.obs.toarray(); this.clearchanged(); } for(int var3 = var2.length - 1; var3 >= 0; --var3) { ((observer)var2[var3]).update(this, var1); } } public synchronized void deleteobservers() { this.obs.removeallelements(); } protected synchronized void setchanged() { this.changed = true; } protected synchronized void clearchanged() { this.changed = false; } public synchronized boolean haschanged() { return this.changed; } public synchronized int countobservers() { return this.obs.size(); } }
更多java相关内容感兴趣的读者可查看本站专题:《java数据结构与算法教程》、《java操作dom节点技巧总结》、《java文件与目录操作技巧汇总》和《java缓存操作技巧汇总》
希望本文所述对大家java程序设计有所帮助。