package com.asurplus.common.observe;
/**
 * 觀察者
 */
public abstract class Observer {
    protected Subject subject;
    /**
     * 發(fā)布事件
     */
    public abstract void update();
}

package com.asurplus.common.observe;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class Observer1 extends Observer {
    public Observer1(Subject subject) {
        this.subject = subject;
        this.subject.attach(this);
    }
    @Override
    public void update() {
        log.info("觀察者 1 收到通知：{}", this.subject.getState());
    }
}

package com.asurplus.common.observe;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class Observer2 extends Observer {
    public Observer2(Subject subject) {
        this.subject = subject;
        this.subject.attach(this);
    }
    @Override
    public void update() {
        log.info("觀察者 2 收到通知：{}", this.subject.getState());
    }
}

package com.asurplus.common.observe;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class Observer3 extends Observer {
    public Observer3(Subject subject) {
        this.subject = subject;
        this.subject.attach(this);
    }
    @Override
    public void update() {
        log.info("觀察者 3 收到通知：{}", this.subject.getState());
    }
}

package com.asurplus.common.observe;
import java.util.ArrayList;
import java.util.List;
/**
 * 主題
 */
public class Subject {
    /**
     * 觀察者列表
     */
    private List<Observer> observers = new ArrayList<>();
    /**
     * 標(biāo)志
     */
    private int state;
    public int getState() {
        return state;
    }
    /**
     * 標(biāo)識(shí)被改變
     *
     * @param state
     */
    public void setState(int state) {
        this.state = state;
        // 通知所有觀察者
        notifyAllObservers();
    }
    /**
     * 添加進(jìn)接收者列表
     *
     * @param observer
     */
    public void attach(Observer observer) {
        observers.add(observer);
    }
    /**
     * 通知所有人被改變
     */
    public void notifyAllObservers() {
        for (Observer observer : observers) {
            observer.update();
        }
    }
}

package com.asurplus.common.observe;
public class TestMain {
    public static void main(String[] args) {
        // 創(chuàng)建主題
        Subject subject = new Subject();
        // 添加觀察者
        new Observer1(subject);
        new Observer2(subject);
        new Observer3(subject);
        // 改變標(biāo)志
        subject.setState(10);
    }
}