520還不知道怎麼表白嗎？——浪漫設計模式之【觀察者模式】
阿新 • • 發佈：2019-05-21
什麼是觀察者模式
在物件之間定義一對多的依賴，這樣一來，當一個物件改變狀態，依賴它的物件收到通知並自動更新
其實就是釋出訂閱模式，釋出者釋出訊息，訂閱者獲取訊息，訂閱了就能收到訊息，沒訂閱就收不到訊息。
觀察者模式應用場景
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", "[email protected]");
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":"[email protected]"}
傳送郵件內容:{"phone":"11111111111","text":"小須喜歡小霞.","email":"[email protected]"}
觀察者模式實現方式三
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", "[email protected]");
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":"[email protected]"}
SimpleAsyncTaskExecutor-1傳送郵件內容:{"phone":"11111111111","text":"小須喜歡小霞.","email":"[email protected]“}