什么是观察者模式

在对象之间定义一对多的依赖，这样一来，当一个对象改变状态，依赖它的对象收到通知并自动更新

其实就是发布订阅模式，发布者发布消息，订阅者获取消息，订阅了就能收到消息，没订阅就收不到消息。

观察者模式应用场景

Zookeeper事件通知节点、消息订阅通知、安卓开发事件注册

观察者模式原理类图

抽象被观察者角色：也就是一个抽象主题，它把所有对观察者对象的引用保存在一个集合中，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者角色。一般用一个抽象类和接口来实现。

抽象观察者角色：为所有的具体观察者定义一个接口，在得到主题通知时更新自己。

具体被观察者角色：也就是一个具体的主题，在集体主题的内部状态改变时，所有登记过的观察者发出通知。

具体观察者角色：实现抽象观察者角色所需要的更新接口，一边使本身的状态与制图的状态相协调。

观察者模式实现方式一

抽象观察者

public interface ObServer {
/**
* 更新消息内容
*/
public void update(String message);

}

抽象主题者

public interface AbstractSubject {
/**
* 添加obServer
*/
void addObServer(ObServer obServer);
/**
* 移除obServer
*/
void removeObServer(ObServer obServer);
/**
* 通知所有的notifyObServerAll
*/
void notifyObServerAll(String message);
/**
* 设置更新内容
*/
void setNtifyMessage(String message);

}

具体主题

public class WeChatSubject implements AbstractSubject {
/**
* 存放所有的ObServer
*/
private List<ObServer> listObServer = new ArrayList<ObServer>();
/**
* 更新的内容
*/
private String message;

public void addObServer(ObServer obServer) {
listObServer.add(obServer);
}
public void removeObServer(ObServer obServer) {
listObServer.remove(obServer);
}
public void notifyObServerAll(String message) {
for (int i = 0; i < listObServer.size(); i++) {
ObServer obServer = listObServer.get(i);
obServer.update(message);
}
}
public void setNtifyMessage(String message) {
this.message = message;
System.out.println("微信公众号设置message:" + message);
notifyObServerAll(message);

}
}

具体观察者

public class UserObServer implements ObServer {
/**
* 订阅者用户名称
*/
private String name;
/**
* 发送内容
*/
private String message;

public UserObServer(String name) {
this.name = name;
}
public void update(String message) {
this.message = message;
read();
}

public void read() {
System.out.println(name + "同学收到推送消息:" + message);
}
}

运行测试

public class App {
public static void main(String[] args) {
// 1.注册主题
AbstractSubject weChatSubject = new WeChatSubject();
// 2.添加观察者 订阅主题
weChatSubject.addObServer(new UserObServer("小须"));
weChatSubject.addObServer(new UserObServer("小霞"));
// 3.设置发送消息
weChatSubject.setNtifyMessage("消息内容：小须喜欢小霞");

}
}

返回结果

微信公众号设置message:消息内容：小须喜欢小霞
小须同学收到推送消息:消息内容：小须喜欢小霞
小霞同学收到推送消息:消息内容：小须喜欢小霞

观察者模式实现方式二

JDK自带观察实现消息发送

（1）. Observable类追踪所有的观察者，并通知他们。
（2）. Observer这个接口看起来很熟悉，它和我们之前写的类几乎一样。

自定义主题

public class MessageObServable extends Observable {

@Override
public void notifyObservers(Object arg) {
// 1.改变数据
setChanged();
// 2.通知所有的观察者改变
super.notifyObservers(arg);
}
}

自定义观察者

public class EmailObServer implements Observer {
public void update(Observable o, Object arg) {
// 1.获取主题
MessageObServable messageObServable = (MessageObServable) o;
System.out.println("发送邮件内容:" + arg);
}
}
public class SmsObServer implements Observer {
public void update(Observable o, Object arg) {
System.out.println("发送短信内容:" + arg);
}
}

运行监听开始

public class JdkObServer {
public static void main(String[] args) {
//1.创建主题
MessageObServable messageObServable = new MessageObServable();
// 2.添加订阅者
messageObServable.addObserver(new EmailObServer());
messageObServable.addObserver(new SmsObServer());
// 3.组装消息内容
JSONObject jsonObject = new JSONObject();
jsonObject.put("email", "11111111@qq.com");
jsonObject.put("phone", "11111111111");
jsonObject.put("text", "小须喜欢小霞.");
messageObServable.notifyObservers(jsonObject.toJSONString());
}
}

pom依赖

<dependencies>
<!-- fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.30</version>
</dependency>
</dependencies>

结果

发送短信内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}
发送邮件内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}

观察者模式实现方式三

Spring封装事件监听

OrderCreateEvent 

public class OrderCreateEvent extends ApplicationEvent {
private JSONObject jsonObject;

public OrderCreateEvent(Object source, JSONObject jsonObject) {
super(source);
this.jsonObject = jsonObject;
}

public JSONObject getJsonObject() {
return jsonObject;
}

public void setJsonObject(JSONObject jsonObject) {
this.jsonObject = jsonObject;
}
}

EmailListener 

@Component
public class EmailListener implements ApplicationListener<OrderCreateEvent> {
@Override
@Async
public void onApplicationEvent(OrderCreateEvent event) {
System.out.println(Thread.currentThread().getName()+"发送邮件内容:" + event.getJsonObject().toJSONString());
}
}

SmsListener 

@Component
public class SmsListener implements ApplicationListener<OrderCreateEvent> {
@Override
@Async
public void onApplicationEvent(OrderCreateEvent event) {
System.out.println(Thread.currentThread().getName() + "发送短信内容:" + event.getJsonObject().toJSONString());
}
}

controller

@RestController
public class OrderController {

@Autowired
private ApplicationContext applicationContext;
@RequestMapping("/sendMsg")
public String sendMsg() {
// 3.组装消息内容
JSONObject jsonObject = new JSONObject();
jsonObject.put("email", "11111111@qq.com");
jsonObject.put("phone", "11111111111");
jsonObject.put("text", "小须喜欢小霞.");
OrderCreateEvent orderCreateEvent = new OrderCreateEvent(this, jsonObject);
applicationContext.publishEvent(orderCreateEvent);
return "success";
}
}

AppStart 

@SpringBootApplication
@EnableAsync
public class AppStart {
public static void main(String[] args) {
SpringApplication.run(AppStart.class,args);
}
}

pom

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
</parent>
<dependencies>
<!-- fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.30</version>
</dependency>
<!-- SpringBoot-整合Web组件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>

结果输出

SimpleAsyncTaskExecutor-2发送短信内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}
SimpleAsyncTaskExecutor-1发送邮件内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com“}

 

 

(adsbygoogle = window.adsbygoogle || []).push({});