使用 Spring 依赖注入实现观察者模式

Question

我正在尝试开发一个应用程序，如果零件编号有任何变化，人们就会收到通知。它是一个基于 Spring 的应用程序。以下是代码片段。

我在 SaveSubscriptionIF 中抽象了存储机制。存储和检索的实际细节在该接口的实现类中。实现类将由Spring注入。

外部应用程序调用我的 setState() 方法 - 传递新信息。

store.getObservers() 方法返回 Map，其中包含观察者和要更新的相应信息。

到目前为止，一切都很好。我对 store.getObservers() 的实现部分感到震惊。此方法实现需要状态数据 - 即从外部应用程序传递的新信息。

如何将“状态”数据传递给“SaveSubscriptionIF”的实现类？

public class PartNumberSubject implements Observable {
     private SaveSubscriptionIF store;
     private Object state;
     @Override
     public void addObserver(final ObserverIF o, final Object subscriptionDetails) {
      store.addObserver(o, subscriptionDetails);
     }
     @Override
     public void notifyObservers() {
      @SuppressWarnings("unchecked")
      final Map<ObserverIF, List<PartInformationVO>> observers =(Map<ObserverIF,List<PartInformationVO>>) store                 .getObservers();
  for (final Entry<ObserverIF, List<PartInformationVO>> observer : observers
                        .entrySet()) {
     observer.getKey().update(observer.getValue());
     }
    }
    @Override
    public void setState(final Object state) {
     this.state = state;
     notifyObservers();
    }
    }

Answer 1

我想我明白你的意思。

通常在观察者模式中，更改的值会作为创建的 Event 对象中的参数传递出去。

因此，例如，您可以创建一个 StateChangedEvent 类，其中包含一个值 - state。

然后，您的 setState 方法将如下所示：

public void setState(final Object state) {
    this.state = state;
    notifyObservers(state);
}

并且 notificationObservers:

public void notifyObservers(Object state) {
    StateChangedEvent event = new StateChangedEvent(state);
    // Pass this event into each observer which you have subscribed...
}

如果我误读了问题，我很抱歉，但这似乎就是您要问的。

Answer 2

将数据传递给观察者是通过观察者的方法完成的。所以修改你的接口：

public ObserverIF {
    void update(List<PartInformationVO>, Object state);
}