HashMaps 与反应式编程

Question

我开始更多地接受响应式编程，并尝试将其应用于我的典型业务问题。我经常设计的一种模式是数据库驱动的类。我有一些已定义的单元类，例如ActionProfile，其实例由ActionProfileManager 管理，它从数据库表中创建实例并将它们存储在Map<Integer,ActionProfile> 中，其中Integer 是actionProfileId 键。 ActionProfileManager 可能会定期清除并重新导入数据，并通知所有依赖项从其映射中重新拉取。

public final class ActionProfileManager {
    private volatile ImmutableMap<Integer,ActionProfile> actionProfiles;

    private ActionProfileManager() { 
        this.actionProfiles = importFromDb();
    }

    public void refresh() { 
        this.actionProfiles = importFromDb();
        notifyEventBus();
    }

    //called by clients on their construction or when notifyEventBus is called
    public ActionProfile forKey(int actionProfileId) { 
        return actionProfiles.get(actionProfiles);
    }

    private ImmutableMap<Integer,ActionProfile> importFromDb() { 
        return ImmutableMap.of(); //import data here
    }
    private void notifyEventBus() { 
        //notify event through EventBus here
    }
}

但是，如果我想让它更具反应性，那么创建地图会破坏 monad。我可以做的一种方法是让Map 本身成为一个 Observable，并返回一个为客户端查找特定密钥的 monad。然而，中间命令式操作可能并不理想，特别是如果我开始使用rxjava-jdbc 时。但是在密集的情况下，hashmap 可能有助于显着提高查找性能。

public final class ActionProfileManager {
    private final BehaviorSubject<ImmutableMap<Integer,ActionProfile>> actionProfiles;

    private ActionProfileManager() { 
        this.actionProfiles = BehaviorSubject.create(importFromDb());
    }

    public void refresh() { 
        actionProfiles.onNext(importFromDb());
    }

    public Observable<ActionProfile> forKey(int actionProfileId) { 
        return actionProfiles.map(m -> m.get(actionProfileId));
    } 
    private ImmutableMap<Integer,ActionProfile> importFromDb() { 
        return ImmutableMap.of(); //import data here
    }
}

因此，对我来说最被动的方法似乎只是在每次刷新时通过 Observable<ActionProfile> 推送数据库中的所有内容，并过滤客户端的最后一个匹配 ID。

public final class ActionProfileManager {
    private final ReplaySubject<ActionProfile> actionProfiles;

    private ActionProfileManager() { 
        this.actionProfiles = ReplaySubject.create();
        importFromDb();
    }

    public void refresh() { 
        importFromDb();
    }

    public Observable<ActionProfile> forKey(int actionProfileId) { 
        return actionProfiles.filter(m -> m.getActionProfileID() == actionProfileId).last();
    } 
    private void importFromDb() { 
        // call onNext() on actionProfiles and pass each new ActionProfile coming from database
    }
}

这是最佳方法吗？导致内存泄漏而不被 GC 处理的旧数据呢？维护地图并使其可观察是否更实用？

上述数据驱动类的最佳响应式方法是什么？或者有没有更好的方法我还没有发现？

Answer 1

如果您不关心早期的值，则在这里使用BehaviorSubject 是正确的做法。

请注意，大多数令人沮丧的主题都是在 Rx.NET 的早期编写的，并且大多被一遍又一遍地引用而没有经过深思熟虑。我将此归因于这样的作者可能并不真正了解主题是如何工作的，或者遇到了一些问题，只是声明不应该使用它们。

我认为主题是多播事件（通常来自单个线程）的好方法，您可以在其中控制或者您是事件的来源，并且事件分派有点“全局”（例如侦听鼠标移动事件） .