結合JDK源碼看設計模式——觀察者模式

前言：

　　如今咱們生活中已經離不開微信，QQ等交流軟件，這對於咱們來講不只是交流，更有在朋友圈中或空間中進行分享本身的生活，同時也能夠經過這個渠道知作別人的生活。咱們在看朋友圈的時候其實咱們扮演的就是一個觀察者，朋友圈或空間裏的動態能夠看做是主體對象。接下來咱們就介紹一下觀察者模式

1、定義

　　定義了對象之間的一對多依賴，讓多個觀察者對象同時監聽某一個主體對象，當主體對象發生變化時，它的全部觀察者都會收到通知並更新。

2、適用場景

　　一、關聯行爲場景，創建一套觸發機制

　　　　這裏稍微理解一下，你有一個特別關心，這個特別關心發消息，發動態都會通知你，發消息是一個行爲，通知你又是一個行爲，咱們能夠在觀察者模式中創建一套觸發機制，當她發消息的時候就會通知你。這就是關聯行爲和觸發機制。

3、觀察者模式詳解

　　原本是想結合JDK來說的，可是觀察者模式在JDK中應用的更可能是監聽器，主要用來作C/S架構的，在實際中不多用。可是JDK中會提供Observable類做爲抽象被觀察者，而Observer做爲抽象觀察者接口。因此這裏就本身動手寫一下觀察者模式。下面咱們介紹觀察者模式須要的角色：

　　一、抽象觀察者角色：

　　　　爲全部的具體觀察者定義一個接口，在獲得被觀察者作出行爲時通知更新本身。

　　二、具體觀察者角色：

　　　　實現抽象觀察者角色所須要的更新接口，並接受觀察者的通知信息。

　　三、抽象被觀察者角色：

　　　　它把全部對觀察者對象的引用保存在一個集合中，每一個主體均可以有任意數量的觀察者。抽象主體提供一個接口，能夠增長和刪除觀察者角色。通常用一個抽象類和接口來實現。

　　四、具體被觀察者角色：

　　　　也就是一個具體的主體，在主體的內部狀態改變時，向全部觀察者發出通知。

　　因爲JDK中已經自帶了兩個抽象角色，因此就直接使用

public class Observable { private boolean changed = false; private Vector<Observer> obs; public Observable() { obs = new Vector<>(); } public synchronized void addObserver(Observer o) { if (o == null) throw new NullPointerException(); if (!obs.contains(o)) { obs.addElement(o); } } public synchronized void deleteObserver(Observer o) { obs.removeElement(o); } public void notifyObservers() { notifyObservers(null); } public void notifyObservers(Object arg) { Object[] arrLocal; synchronized (this) { if (!changed) return; arrLocal = obs.toArray(); clearChanged(); } for (int i = arrLocal.length-1; i>=0; i--) ((Observer)arrLocal[i]).update(this, arg); } public synchronized void deleteObservers() { obs.removeAllElements(); } protected synchronized void setChanged() { changed = true; } protected synchronized void clearChanged() { changed = false; } public synchronized boolean hasChanged() { return changed; } public synchronized int countObservers() { return obs.size(); } }

　　上面是抽象被觀察者角色（不是抽象類或接口，但在這裏咱們就這樣理解），能夠看見這裏面基本都是同步的容器，方法，obs主要是放觀察者的。由於繼承這個類的子類是被觀察者，注意多個觀察者是觀察一個被觀察者，可是一個觀察者能夠觀察多個被觀察對象。兩個之間是多對多的關係，咱們如今主要先實現多個觀察者觀察一個被觀察對象的狀況

public interface Observer { void update(Observable o, Object arg); }

　　上面是抽象觀察者角色。裏面的update方法的意思是當被觀察者作出必定行爲後，觀察者就能夠接受到一些消息。但須要咱們去實現具體監聽的方式。

import java.util.Observable; /** * 扮演被觀察者具體實現類 *created by Mr.F on 2019/4/14 */

public class Course extends Observable { private String courseName; public String getCourseName() { return courseName; } public void setCourseName(String courseName) { this.courseName = courseName; } public void produceQuestion(Course course,Question question){ System.out.println(question.getStudentName()+"在"+course.courseName+"提了"+question.getQuestionContext()); setChanged();//改變被觀察者的狀態
 notifyObservers(question); } }

//被悲觀者中的具體內容
public class Question { private String questionContext; private String studentName; public String getStudentName() { return studentName; } public void setStudentName(String studentName) { this.studentName = studentName; } public String getQuestionContext() { return questionContext; } public void setQuestionContext(String questionContext) { this.questionContext = questionContext; } }

import java.util.Observer; /** *觀察者具體實現類 * created by Mr.F on 2019/4/14 */

public class Teacher implements Observer { private String teacherName; public String getTeacherName() { return teacherName; } public void setTeacherName(String teacherName) { this.teacherName = teacherName; } @Override public void update(java.util.Observable o, Object arg) { Course course= (Course) o;//強轉被觀察者對象
        Question question= (Question) arg; System.out.println(teacherName+"收到了來自"+course.getCourseName()+"的"+question.getQuestionContext()); } }

　　上面的代碼很少說，能夠看註釋，主要是一個Teacher類做爲觀察者，Course類做爲被觀察者。這裏主要看Course中的produceQuestion方法和Teacher中的update方法。再去看上面抽象角色中的具體實現就能明白之間的調用，這裏簡單說一下，當將觀察者添加進Observable中的obs數組的時候，每次調用produceQuestion方法，都能使得觀察者中能獲得信息。

/** * created by Mr.F on 2019/4/14 */

public class Test { public static void main(String[] args) { Question question=new Question(); question.setStudentName("方塊人"); question.setQuestionContext("觀察者模式怎麼寫？"); Course course =new Course(); course.setCourseName("設計模式課堂"); Teacher teacher1=new Teacher(); Teacher teacher2=new Teacher(); teacher1.setTeacherName("老師1"); teacher2.setTeacherName("老師2"); course.addObserver(teacher1); course.addObserver(teacher2); course.produceQuestion(course,question); } }

　　上面是測試類代碼。下面是輸出結果：

4、總結

　　其實每一個觀察者模式並不必定要像上面那樣實現兩個接口，而是有不少方式，不要學了模板，忘了原理。日常在作web項目的時候，作點贊系統，其實更多用的是觀察者模式+生產者模式+消費者模式+異步隊列。爲何會用到上面這麼多模式呢，其實主要是考慮到併發的問題，上面的java中自帶的Observable是用鎖的方式，若是被觀察者同時作了不少事情，這裏咱們能夠用異步隊列來進行處理後期的行爲。觀察者模式核心就是當被觀察者作出行爲的時候，觀察者必定會進行更新。必定要多看上面那兩個接口是如何調用的。