采用cqrsnode框架开发的DDD CQRS例子

// 这个有个约定，监听事件的方法名要是 AggreName + eventName
// domain 是个CQRS顶级控制类，会自动注入这里，也是整个领域的入口。有时如果不需要访问domain层，而是要处理持久化db，或是发送email，就不用回到domain老家里操作领域层了，不过默认是会注入的，因为也许会用上。
function UserchangeName(event,domain){

   // 当监听到这个changeName事件时，我们可以对他进行持久化，
   // 这里的持久化可不是 event store，因为那个已经默认持久化完成了，
   // 这里的持久化，可以持久化到其他数据库，用 query command 访问。
   // 比如：异步保存
   db.update(event.aggreId,{name:event.data}...) // 大概就是这个意思。

   // 我们也可以 email
   emailer.push(...) ; // 只是个例子

   // 我们可以对领域其他对象进行操作,利用domain可以访问到领域层对象
   var r = domain.repo('X');  // 得到X的仓储。
   r.findById(.. . , functino(x){  // 得到其他对象  })  
      
}

function ChangeUserName(id,name){

    // 验证 id / name 是否正确,这是 command对象做的最有用的，
    // 有些人认为 Commmand 只不过就是个数据对象，然后发给 handle,
    // 其实不对的，因为 Command可以验证等功能。
    ......
    
    this.id = id;
    this.name = name;
}

// 这是处理 command 的handle，
// 还应该注意的是，这里编码时，可以用 this.domain 访问到领域层入口，而这是注入的，不需要我们做什么。
// callback是回调，虽然cqrs方式的command不应该返回，但是最新调查，是应该返回是否操作成功和一些简单的提示信息的，和 query 返回的不同。
function ChangeUserName(cmd,callback){
   var userRepository = this.domain.repo('User');
   // 这里有个事，就是findById 是个 lock method ，也就是相同 id 时，会lock, 其他持有lock调用 next() 才能被下一个访问者使用。
   userRepository.findById(cmd.id,function(user,next){
        user.changeName(event.name);
        next();
   })
}

// 实际应用需要找个web框架，比如 express 配合使用。
// web framework + cqrs framework 比较合适，我也想过，整合两个框架，我发现没必要，
// 因为cqrs框架独立比较好，这样外界可以随意的更换环境。

function run(){  

// 这里有个事情，我们可以 new Domain 很多个领域，呵呵，这是可以的，领域之间可以通过 command 交流。
// 有人说 领域之间通过事件交流，我觉得不妥，那样就会出现事件耦合和不必要的复杂性，
// 每个领域都应该有个边界，我觉得通过 new Domain 创建个新领域，可以解决模块问题。
// 如果强制需要扩展，也就是需要领域和领域密切接触，这时可以在 Event Handle 里做文章，可以说可以无限扩展。
var Domain = require('cqrsnode'); // 得到Domain类
var Store = require('cqrsnode.store').Tiny; // 我们需要一个EventStore 的实际持久化DB.这里选择了Tiny，还可以选择 Mem 和 Mongdb / mysql 等等。随自己喜欢了。

// 创建一个领域，当我们做这一步之后，内部会做一些好玩的事，
// 比如： 加载我们之前创造的那些东西。
// 还有就是根据 Aggre 自动创建对应的 Repository 等功能
// 包括 自动 extend Aggre等等
var domain = new Domain({mainPath:__dirname,Store:Store});
// 得到 change user name 的Command类
var CMD = domain.commands.ChangeUserName;
// 创建一个Command实例
var cmd = new CMD('id001','brighthas');
// 执行方法，内部会让指定的handle处理这个command
domain.commandBus.execute(cmd,function(r){});
}