快捷導(dǎo)航

java觀察者模式的三種實現(xiàn)方式代碼實例

更新時間：2023年10月25日 09:03:30 作者：葡萄曉虎

這篇文章主要介紹了java觀察者模式的三種實現(xiàn)方式代碼實例,觀察者模式(又被稱為發(fā)布-訂閱（Publish/Subscribe)模式,屬于行為型模式的一種,它定義了一種一對多的依賴關(guān)系,讓多個觀察者對象同時監(jiān)聽某一個主題對象,需要的朋友可以參考下

java觀察者模式的三種實現(xiàn)方式

Java中可以使用觀察者模式開發(fā)，有三種簡單的方式可以實現(xiàn)。

自定義接口實現(xiàn)

觀察者

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

觀察者的實現(xiàn)

public class ObserverImpl implements Observer{
    private Object str;
    @Override
    public void update(Object o) {
        this.str = o;
        System.out.println(this.str);
    }
}

觀察者的注入和方法調(diào)用

    @Autowired
    private List<Observer> observers;
    @GetMapping("impl/{str}")
    public void impl(@PathVariable("str")  String str){
        for (Observer observer : observers){
            observer.update(str);
        }
    }

基于spring的事件

先定義spring事件

public class CustEvent extends ApplicationEvent  {

    public String msg;

    public CustEvent(Object source, String msg) {
        super(source);
        this.msg = msg;
    }
}

事件監(jiān)聽器

@Component
public class CustEventListener {

    @EventListener()
    public void eventListen(ApplicationEvent applicationEvent){
        if(applicationEvent instanceof CustEvent){
            CustEvent custEvent = (CustEvent)applicationEvent;
            System.out.println(custEvent.msg);
        }
    }
}

發(fā)布事件

    @GetMapping("event/{str}")
    public void event(@PathVariable("str")  String str){
        context.publishEvent(new CustEvent(this,str));
    }

基于Java原生接口

實現(xiàn)java.util.Observer

public class JavaObserverA implements Observer {

    private int myState;
    @Override
    public void update(Observable o, Object arg) {
        myState = ((JavaConcreteSubject)o).getState();
        System.out.println(myState);
    }
}

繼承Observable類，注意發(fā)布時要調(diào)用父類的setChanged()和notifyObservers()方法

public class JavaConcreteSubject extends Observable {

    private int state;

    public void set(int s){
        state = s;  //目標(biāo)對象的狀態(tài)發(fā)生了改變
        setChanged();  //表示目標(biāo)對象已經(jīng)做了更改
        notifyObservers(state);  //通知所有的觀察者
    }

    public int getState() {
        return state;
    }

}

注冊觀察者，然后發(fā)布事件

    private JavaConcreteSubject subject = new JavaConcreteSubject();
    public testController(){
        subject.addObserver(new JavaObserverA());
    }
    @GetMapping("util/{str}")
    public void util(@PathVariable("str")  String str){
        subject.set(1);
    }

到此這篇關(guān)于java觀察者模式的三種實現(xiàn)方式代碼實例的文章就介紹到這了,更多相關(guān)java觀察者模式實現(xiàn)方式內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: