实现观察者模式（监听观察）原创

/**
 * 观察者接口
 * 定义了一个update()方法，当被观察者通知时，观察者的update()方法会被调用
 */
public interface Observer {
    public void update(String message);
}

/**
 * 被观察接口
 * 模拟微信公众号，他是一个被观察的接口
 * 声明添加、删除、通知观察者的方法
 */
public interface Observerable {
    //添加（注册）观察者的方法
    public void registerObserver(Observer o);

    //删除观察者的方法
    public void removeObserver(Observer o);

    //通知观察者开始观察的方法
    public void notifyObserver();
}

public class User implements  Observer {
    private String name;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getMessage() {
        return message;
    }

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

    private String message;//用户自己接收到的信息（微信公众号推送过来的信息）

    public void update(String message) {
        this.message = message;
        read();
    }
    public void read(){
        System.out.println(this.name + "获取到了" + this.message);
    }

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

package com.design.observer;
import java.util.ArrayList;
import java.util.List;

//微信服务 实现被观察者接口，同时需要具有一个List集合，用来保存注册的观察者。等需要通知观察者的时候，便利集合
public class WechatServer implements  Observerable {
    private List<Observer> observerList = new ArrayList<Observer>(); //注意到这个List集合的泛型参数为Observer接口，设计原则：面向接口编程而不是面向实现编程
    private String message; //这是被观察者的被观察对象，这里只是简单的模拟微信公众号一篇文章
    public void registerObserver(Observer o) {
        observerList.add(o);
    }

    public void removeObserver(Observer o) {
        observerList.remove(o);
    }
    //通知观察者及时获取信息
    public void notifyObserver() {
        for(int i = 0; i < observerList.size(); i++){
            observerList.get(i).update(message);
        }
    }

    //被观察者开始加工需要告诉观察者的信息
    public void machining(String mes){//这里只是加工了一个字符串（在微信中相当于一篇文章）
        this.message = mes;
    }

}

public class TestMain {

    public static void main(String[] args) {
        User zhangsan = new User("张三");
        User lisi  = new User("李四");
        User wangwu = new User("王五");
        //------------------------------------------以上三个对象都是观察者，观察微信公众号推送文章
        //开始构建微信公众号（被观察者）,并且将三个观察者注册到被观察者中（相当于三个用户关注了同一个微信公众号）
        WechatServer wechatServer = new WechatServer();
        wechatServer.registerObserver(zhangsan);
        wechatServer.registerObserver(lisi);
        wechatServer.registerObserver(wangwu);
        //模拟微信公众号推送一片文章（在这之前要先加工一片文章）
        wechatServer.machining("床前明月光，疑是地上霜，举头望明月，低头思故乡");
        wechatServer.notifyObserver();//开始推送文章
        //--------------------------------------------------------------
        System.out.println("--------------------------------------------");
        //模拟用户取消关注微信公众号
        wechatServer.removeObserver(zhangsan);
        System.out.println("张三取消关注微信公众号");
        wechatServer.notifyObserver();
    }
}