如何在Spring Boot中注册一个观察者？

Question

如何在Spring Boot中注册一个观察者？

4

我想使用Spring Boot实现GoF观察者设计模式，而不使用Spring Events。
代码示例：

    @Component
    public class MyObservable extends java.util.Observable {
      void myObservableMethod(Object obj){
        notifyObservers(obj);
      }
    }

    @Component
    public class MyObserver implements java.util.Observer{  
    @Override
      public void update(java.util.Observable observable, Object obj) {
        System.out.println(obj.toString());
      }
    }

Are the java.util classes a good implementation for that pattern ?
How can I register the observer with the observable , and still able to use Spring Depedency Injection?
Where I can call myObserver.accept(myObservable); ?
```
@Autowired
MyObservable myObservable;
@Autowired
MyObserver myObservable;

myObserver.accept(myObservable); //??
```

- Yuri S

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Magnus · Accepted Answer

“java.util”类是该模式的一个很好的实现吗？GoF模式及其Java实现有些过时并存在一些问题。这真的取决于您要解决的问题，但如果您的应用程序不会大量使用事件，并且您不想引入诸如Spring事件或RxJava之类的东西，则可能是合适的。

“我如何向可观察对象注册观察者，同时仍然能够使用Spring依赖注入？在哪里可以调用myObserver.accept(myObservable)？”请参见以下示例，了解如何定义可观察对象、一些观察者，将它们连接起来并最终向它们发送一些事件。

@SpringBootApplication
public class ObserverApplication {

    public static void main(String[] args) {
        try(ConfigurableApplicationContext ctx = SpringApplication.run(ObserverApplication.class, args)){
            Observable observable = ctx.getBean(Observable.class);
            observable.notifyObservers("Hello");
        }
    }

    @Bean
    public Observable myObservable(){
        return new MyObservable();
    }

    @Bean
    MyObserver observer1(){
        return new MyObserver(1);
    }

    @Bean
    MyObserver observer2(){
        return new MyObserver(2);
    }

    @Autowired
    public void configureObservers(Observable myObservable, MyObserver observer1, MyObserver observer2){
        myObservable.addObserver(observer1);
        myObservable.addObserver(observer2);
    }

    static class MyObserver implements Observer {

        int id;

        public MyObserver(int id) {
            this.id = id;
        }

        @Override
        public void update(Observable o, Object arg) {
            System.out.println("Observer: " + id + ", Received object: " + arg);
        }
    }

    static class MyObservable extends Observable {
        @Override
        public void notifyObservers(Object arg){
            this.setChanged();
            super.notifyObservers(arg);
        }
    }
}