cqrs - 对 React 的 Flux 架构感到困惑 - waitFor

Question

我对如何使用 React 有自己的看法，并且正在构建自己的框架，受到 Om 的启发。我正在实现一些类似于 Flux 架构的东西，其中的存储可以根据某些事件进行 self 更新。

我不太明白的是为什么在 Flux 架构中我们需要存储依赖项？

存储不应该是给定有界上下文的独立数据持有者，就像我们对 CQRS 架构所做的那样？

在事件系统中，2 个 CQRS 组件最终可能会保存相同的数据。我们是否表达存储依赖性以避免在存储中保存重复数据？

有人可以提出一些非常具体的用例，其中需要存储依赖项并且问题很难通过任何其他方式解决吗？我自己找不到。

Answer 1

在 refluxjs我们通过多种方式解决 waitFor 问题，一种用于顺序数据流，另一种用于并行数据流。我尝试以一种避免保存相同数据(即双重维护数据)的方式对数据存储进行建模。

基本上，数据存储是 CQRS 组件，我尽量避免 2 个数据存储最终得到相同类型的数据。如果我需要以某种方式转换只有某些组件需要的数据，我会将其分解为“聚合”数据存储。简单的实现:

var carsStore = Reflux.createStore({
    init: function() {
        this.listenTo(Actions.updateCars, this.updateCallback);
    },
    updateCallback: function() {
        $.ajax('/api/cars', {}).done(function(data) {
            this.trigger(data.cars);
        }.bind(this));
    }
});

我们可以创建另一个数据存储，通过监听 carsStore 来聚合数据:

var modelsStore = Reflux.createStore({
    init: function() {
        this.listenTo(carsStore, this.carsCallback);
    },
    carsCallback: function(cars) { // passed on from carsStore trigger
        this.trigger(this.getModels(cars)); // pass on the models
    }
    getModels: function(cars) {
        return _.unique(_.map(cars, function(car) { return car.model; }));
    }
});

这样，您的 React View 组件就可以使用一个来获取汽车，另一个来获取模型，这些模型是从 carStore 聚合的。

如果存储需要等待两个并行数据流完成，我们提供 Reflux.all 来连接操作和存储。这很有用，例如如果您正在等待从不同的 REST 资源加载数据。

var carsAndPartsAreLoaded = Reflux.all(carStore, partsStore);

// you may now listen to carsAndPartsAreLoaded 
// from your data stores and components

希望这对您有意义。