HashMaps与反应式编程

Question

我开始更多地接受反应式编程，并试图将其应用于我的典型业务问题。我经常使用的一种模式是数据库驱动类。我有一些已定义的单元类，如ActionProfile，其实例由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来为客户端查找特定的键。然而，中间命令式操作可能并不理想，尤其是如果我以后开始使用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
    }
}

因此，对我来说，最被动的方法似乎只是在每次刷新时将数据库中的所有内容推送到可观察的

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’d呢？维护地图并使其可见是否更实际？

对于数据驱动的类，上面的最佳反应式方法是什么？还是有更好的方法我还没有发现？




Answer 1

如果您不关心早期的值，那么在这里使用行为主体（BehaviorSubject）是正确的。

请注意，大多数令人沮丧的帖子主题都是在Rx的早期写的。NET，大部分被反复引用，没有经过太多思考。我把这归因于这样的作者可能并不真正理解主题是如何工作的，或者遇到了一些问题，只是宣称它们不应该被使用。

我认为主题是多播事件（通常来自单个线程）的好方法，您可以控制或您是事件的来源，并且事件调度有点“全局”（例如监听鼠标移动事件）。