前言
观察者设计模式系列文章：
观察者设计模式（一） - 定义、角色划分、示例代码
观察者设计模式（二） - 推拉模式
观察者设计模式（三） - Java自带的观察者
观察者设计模式（四） - 源码中观察者设计模式的使用场景
1. 定义？
当一个对象的状态发生改变时，与他相关联的部分对象的状态同时也会发生改变。
比如订阅公众号：
- 比如我订阅了鸿阳的微信公众号，只要他每更新一篇文章都会及时的通知我 [观察者设计模式]；
对应上边定义就是：一个对象的状态发生改变时，就是鸿阳公众号有文章更新，由于我订阅了该公众号，所以说我的部分状态也会发生改变，比如我会去看该公众号更新的文章；
EventBus：和观察者设计模式没有半毛钱关系
2. 角色划分？
被观察者（Observable）：公众号；
具体的被观察者（Concreate Observable）：鸿阳公众号；
观察者（Observer）：微信用户；
具体的观察者（Concreate Observer）：我，Novate
3. 示例代码 - 订阅公众号？
写一个事例代码
被观察者：WXPublicObservable（公众号）；
具体的被观察者：WXAdvanceObservable（鸿阳的公众号）；
观察者：IWXUser（微信用户）；
具体的观察者：WXUser（Novate、WangZiWen）；
4. 示例代码如下
1>：WXPublicObservable，被观察者 - 微信公众号
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:03
* Version 1.0
* Params:
* Description: 微信公众号 - 多个人去订阅的公众号
*/
public class WXPublicObservable {
// 所有订阅用户的集合
private List<IWXUser> mWXUsers ;
public WXPublicObservable(){
mWXUsers = new ArrayList<>() ;
}
/**
* 订阅
*/
public void register(IWXUser wxUser){
mWXUsers.add(wxUser) ;
}
/**
* 取消订阅
*/
public void unregister(IWXUser wxUser){
mWXUsers.remove(wxUser) ;
}
/**
* 文章更新
*/
public void update(String article){
// 推送所有更新的文章
for (IWXUser wXUser : mWXUsers) {
wXUser.push(article);
}
}
}
2>：WXAdvanceObservable，具体的被观察者 - 鸿阳的微信公众号
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:12
* Version 1.0
* Params:
* Description: 具体的被观察者 - 鸿阳的微信公众号
*/
public class WXAdvanceObservable extends WXPublicObservable{
private String article ;
public String getArticle() {
return article;
}
public void setArticle(String article) {
this.article = article;
// 通知更新，推送给微信用户
update(article);
}
}
3>：IWXUser，接口，微信用户；
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:06
* Version 1.0
* Params:
* Description: 微信用户 - 订阅该微信公众号
*/
public interface IWXUser {
/**
* 读文章
*/
void push(String article) ;
}
4>：WXUser，具体的观察者，具体的用户，订阅鸿阳微信公众号的用户
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:14
* Version 1.0
* Params:
* Description: 具体的用户 - 订阅鸿阳的微信公众号
*/
public class WXUser implements IWXUser{
private String name ;
public WXUser(String name){
this.name = name ;
}
@Override
public void push(String article) {
System.out.println(name+"收到了一篇文章："+article);
}
}
5>：创建具体的被观察者和具体的观察者对象，测试代码如下：
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:16
* Version 1.0
* Params:
* Description:
*/
public class Client {
public static void main(String[] args){
// 具体的被观察者 - 微信公众号 - 鸿阳的公众号
WXAdvanceObservable wxAdvanceObservable = new WXAdvanceObservable() ;
// 具体的观察者 - 微信公众号 - Novate
WXUser novate = new WXUser("novate") ;
WXUser wangziwen = new WXUser("wangziwen") ;
// 微信公众号 - 用户订阅公众号
wxAdvanceObservable.register(novate);
wxAdvanceObservable.register(wangziwen);
// 微信公众号 - 推送文章
wxAdvanceObservable.setArticle("《观察者设计模式 - 定义及事例代码》");
// 微信公众号 - 用户取消订阅公众号
wxAdvanceObservable.unregister(wangziwen);
}
}
运行结果打印如下
图片.png
