觀察者設計模式

在網上找了很久沒看見有講的很清楚的,我自己花了一點時間終於弄懂了,現在想用最通俗易懂的方法將觀察者設計模式講明白

觀察者設計模式類似於發布訂閱模式,所以我准備以訂閱用戶定義公眾號來舉例說明

首先創建公眾號接口類

package 觀察者模式;
//公眾號接口
interface WechatInterface {
    //添加用戶
    void addUser(User user);
    //刪除用戶(這里相當於將用戶放入黑名單)
    void deleteUser(User user);
    //當公眾號要推送新的內容時,調用這個方法
    void notifyUser();
}

其次創建訂閱接口類

package 觀察者模式;
//訂閱接口
interface Oder {
    //當公眾號更新內容的時候,會將內容傳入該方法,每個微信公眾號的訂閱者都要實現該方法
    public void update(String message);
}

接下來創建公眾號類

package 觀察者模式;
import java.util.ArrayList;
import java.util.List;

//公眾號類
public class WechatOfficialAccount implements WechatInterface{

    //微信公眾號維護內部維護了很多訂閱用戶
    private List<User> userList = new ArrayList<>();

    //公眾號的名字
    private String wechatName;

    //要推送的內容
    private String message;

    public WechatOfficialAccount(String wechatName) {
        this.wechatName = wechatName;
    }

    public void setMessage(String message) {
        this.message = message;
        this.notifyUser();
    }

    @Override
    public void addUser(User user) {
        userList.add(user);
    }

    @Override
    public void deleteUser(User user) {
        if (userList.indexOf(user)>=0){
            userList.remove(user);
        }
    }

    @Override
    public void notifyUser() {
        message=this.wechatName+this.message;
        for (User user:userList) {
            user.update(message);
        }
    }
}

接下來創建用戶類

package 觀察者模式;
//公眾號的訂閱用戶
public class User implements Oder{

    //用戶關注的公眾號
    private WechatOfficialAccount wechatOfficialAccount;

    //用戶名
    private String username;

    public User(WechatOfficialAccount wechatOfficialAccount, String username) {
        this.wechatOfficialAccount = wechatOfficialAccount;
        this.username = username;
        wechatOfficialAccount.addUser(this);//每創建一個用戶,都叫他關注這個公眾號
    }

    @Override
    public void update(String message) {
        System.out.println(username+"收到消息"+message);
    }
}

接下來創建主方法進行測試

package 觀察者模式;
//測試觀察者模式的主類
public class Main {
    public static void main(String[] args) {
        WechatOfficialAccount wechatOfficialAccount = new WechatOfficialAccount("羅輯思維");
        User user1 = new User(wechatOfficialAccount,"馬芸");
        User user2 = new User(wechatOfficialAccount,"馬化疼");
        User user3 = new User(wechatOfficialAccount,"李艷紅");

        wechatOfficialAccount.setMessage("今日推送的內容為:時間的朋友");

        wechatOfficialAccount.deleteUser(user2);//馬化疼因為懟羅輯思維,被羅輯思維放黑名單了

        wechatOfficialAccount.setMessage("今日推送的內容為:終身學習");

    }
}

以下是輸出結果

馬芸收到消息羅輯思維今日推送的內容為:時間的朋友
馬化疼收到消息羅輯思維今日推送的內容為:時間的朋友
李艷紅收到消息羅輯思維今日推送的內容為:時間的朋友
馬芸收到消息羅輯思維今日推送的內容為:終身學習
李艷紅收到消息羅輯思維今日推送的內容為:終身學習

Process finished with exit code 0