程序员除了会CRUD之外，还应该知道什么叫CQRS！

当然了，CQRS 作为一个读写分离思想的架构，在数据存储方面，也没有做过多的约束。所以 CQRS可以有不同层次的实现。

3 . CQRS 实现方式

CQRS 可以有两种实现方式。

1）CQ 两端数据库共享，只是在上层代码上分离。这样做的好处是可以让我们的代码读写分离，更容易维护，而且不存在 CQ 两端的数据一致性问题，因为是共享一个数据库的。这种架构是非常实用的（也就是我上面画的那种）。

2）CQ 两端不仅代码分离，数据库也分离，然后Q端数据由C端同步过来。同步方式有两种：同步或异步，如果需要 CQ 两端的强一致性，则需要用同步；如果能接受 CQ 两端数据的最终一致性，则可以使用异步。C端可以采用Event Sourcing（简称ES）模式，所有C端的最新数据全部用 Domain Event 表达即可；而要查询显示用的数据，则从Q端的 ReadDB（关系型数据库）查询即可（详细可以参考文献3）。

4 . CQRS 的简单实现

说了这么多，该怎么实现呢？我们以上面提到的第一种方式为例：代码层面实现分离，数据库共享。这种方式在企业里也非常实用。

首先有几个概念需要介绍一下，CQRS 模式中，首先需要有 Command，这个 Command 命令会对应一个实体和一个命令的执行类。那整个系统中肯定有很多不同的 Command，那么还需要一个 CommandBus 来做命令的分发处理。

可能大家觉得比较抽象，我来写几行示例代码，一看就明白了。假设有个订单模块，我要新增一个订单信息。那么根据上文的分析，需要有个新增命令以及对应的订单实体（并不一定和数据库的订单实体完全对应）。首先先创建一个命令接口（绑定命令对应的实体），接口内部有个该命令的处理方法。

public interface Command<T> {
     Object execute(T commandModel);
}

OK，接下来我们可以创建订单的新增命令了。

@Component
public class CreateOrderCommand implements Command<CreateOrderModel> {

     @Override
     public Object execute(CreateOrderModel model) {
         // 具体的逻辑
    }
}

到这里，我们写好了具体的创建订单命令的逻辑，那么该命令需要放到 CommandBus 中去执行，所以我们要写这个 CommandBus。

@Component
public class CommandBus {
     public <T> Object dispatch(Command<T> cmd, T model) {
         return cmd.excute(model);
    }
}

可能大家会看着有点晕，甚至有点绕，没关系，我解释一下：这个 dispatch 方法就相当于分发执行，内部根据传入的具体 Command 以及对应的 model，去执行该 Command 实现的逻辑。

好了，那我们在熟悉的 Controller 层该如何去调用呢？很简单，如下：

@RestController
@RequestMapping(value = "/order")
public class OrderController {

     @Resource
     private GetOrderInfoService getOrderInfoService;
     @Resource
     private CreateOrderCommand createOrderCommand;
     @Resource
     private CommandBus commandBus;

     @PostMapping(value = "/getInfo")
     public Object getOrderInfo(GetOrderInfoModel model) {
         return getOrderInfoService.getOrderInfos(model);
    }

     @PostMapping(value = "/creat")
     public Object createOrderInfo(CreateOrderModel model) {
         return commandBus.dispatch(createOrderCommand, model);
    }
}