基於Java API實現通知機制

本節我們來假設這樣一個場景：小夥伴們在 C語言中文網提問後，如果指定了老師回答，那麼對應的老師就會收到郵件通知，這就是觀察者模式的一種應用場景。看到這裡，有些小夥伴可能會想到 MQ、非同步佇列等，其實 JDK 本身就提供了這樣的 API。下面我們用程式碼來還原這樣一個應用場景。

首先建立 CLanguage 類，程式碼如下。

package net.biancheng.c.observer;

import java.util.Observable;

public class CLanguage extends Observable {
    private String name = "C語言中文網";
    private static final CLanguage CLanguage = null;

    private CLanguage() {
    }

    public static CLanguage getInstance() {
        return CLanguage;
    }

    public String getName() {
        return name;
    }

    public void publishQuestion(Question question) {
        System.out.println(question.getUserName() + "在" + this.name + "上提交了一個問題。");
        setChanged();
        notifyObservers(question);
    }
}

java.util.Observable 類和 java.util.Observer 介面在《觀察者模式詳解》中的模式擴充套件部分介紹。

然後建立問題 Question 類。

package net.biancheng.c.observer;

public class Question {
    private String userName;
    private String content;

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }
}

接著建立老師 Teacher 類，程式碼如下。

package net.biancheng.c.observer;

import java.util.Observable;
import java.util.Observer;

public class Teacher implements Observer {

    private String name;

    public Teacher(String name) {
        this.name = name;
    }

    public void update(Observable o, Object arg) {
        CLanguage CLanguage = (CLanguage) o;
        Question question = (Question) arg;
        System.out.println("======================");
        System.out.println(name + "老師，你好！\n" +
                "您收到了一個來自" + CLanguage.getName() + "的提問，希望您解答。問題內容如下：\n" +
                question.getContent() + "\n" +
                "提問者：" + question.getUserName());
    }
}

最後編寫使用者端測試程式碼如下。

package net.biancheng.c.observer;

public class Test {
    public static void main(String[] args) {
        CLanguage cLanguage = CLanguage.getInstance();
        Teacher yan = new Teacher("嚴");
        Teacher xie = new Teacher("解");

        cLanguage.addObserver(yan);
        cLanguage.addObserver(xie);

        //使用者行為
        Question question = new Question();
        question.setUserName("張三");
        question.setContent("觀察者模式適用於哪些場景？");

        cLanguage.publishQuestion(question);
    }
}

執行結果如下。

張三在C語言中文網上提交了一個問題。
======================
解老師，你好！
您收到了一個來自C語言中文網的提問，希望您解答。問題內容如下：
觀察者模式適用於哪些場景？
提問者：張三
======================
嚴老師，你好！
您收到了一個來自C語言中文網的提問，希望您解答。問題內容如下：
觀察者模式適用於哪些場景？
提問者：張三