我下面简要概括一下观察者模式的思想要点：
1、需要被观察者，第一可以发布通知，第二可以触发观察者的回调方法
2、需要观察者，提供回调方法供被观察者触发
用微信公众号的逻辑简单说明：
用户关注微信公众号，用户就是观察者，微信公众号就是被观察者，微信公众号得知道有多少用户关注了它（得保存起来），当微信公众号发布文章时（发布通知），通知关注它的用户（触发观察者的回调方法）。
下面看看简单代码实现以上逻辑：
观察者接口：
package com.nobt.observer;
/**
- 定义一个观察者接口，只提供了更新方法，当被观察者触发更新方法时，会触发被观察者保存的所有观察者update();
- @author nobt
- @date 2018年12月25日 下午8:30:26
*/
public interface Observer {
public void update(String message);
}
被观察者接口：
package com.nobt.observer;
/**
- 被观察者接口，声明添加、移除、通知观察者
- @author nobt
- @date 2018年12月25日 下午8:33:34
*/
public interface Observerable {
public void addObserver(Observer o);
public void removeObserver(Observer o);
public void notifyObserver();
}
观察者接口的实现类，就是公众号例子中的用户：
package com.nobt.observer;
/**
- 模拟用户，实现观察者接口
- @author nobt
- @date 2018年12月25日 下午8:40:06
*/
public class User implements Observer {
private String userName;
public User(String userName) {
super();
this.userName = userName;
}
@Override
public void update(String message) {
System.out.println(userName + " 收到推送消息： " + message);
}
}
被观察者接口的实现类，就是公众号例子中的公众号：
package com.nobt.observer;
import java.util.ArrayList;
import java.util.List;
/**
- 模拟微信公众号，实现被观察者接口
- @author nobt
- @date 2018年12月25日 下午8:35:28
*/
public class Wechat implements Observerable {
//被观察者保存所有观察者的集合
private List<Observer> observerList;
private String message;
public Wechat() {
observerList = new ArrayList<Observer>();
}
@Override
public void addObserver(Observer o) {
observerList.add(o);
}
@Override
public void removeObserver(Observer o) {
if(!observerList.isEmpty()){
observerList.remove(o);
}
}
@Override
public void notifyObserver() {
for(Observer o : observerList){
o.update(message);
}
}
public void topicMsg(String message) {
this.message = message;
System.out.println("微信公众号发布文章： " + message);
//发布文章，通知所有观察者
notifyObserver();
}
}
简单测试类，模拟3个用户关注公众号，第一次发布消息3个用户得到通知，第二次让其中一个用户取消关注，将只有两个用户得到通知：
package com.nobt.observer;
/**
- 测试类
- @author nobt
- @date 2018年12月25日 下午8:41:42
*/
public class TestObserver {
public static void main(String[] args) {
Wechat wc = new Wechat();
User u1 = new User("user1");
User u2 = new User("user2");
User u3 = new User("user3");
wc.addObserver(u1);
wc.addObserver(u2);
wc.addObserver(u3);
wc.topicMsg("我发布了一篇公众号文章：《java观察者模式Demo》");
System.out.println("用户user1取消了订阅...");
wc.removeObserver(u1);
wc.topicMsg("my name is nobt...");
}
}
打印结果如下：
以上源码：observer_demo: java观察者模式demo
