16、异步消息传递模式与领域驱动设计解析

异步消息传递模式与领域驱动设计解析

1. 异步消息传递基础

在消息处理中，与常见的队列示例不同，这里不是轮询 NATS 服务器，而是暴露一个端点并向 NATS 注册。当 NATS 服务器接收到消息时，会尝试将其转发到所有注册的端点。不过，使用之前代码示例中的实现，系统上运行的每个工作进程都会获得消息的副本，这并不理想。我们可以使用 API 中的QueueSubscribe方法来解决这个问题：

func (nc *Conn) QueueSubscribe(subj, queue string, cb MsgHandler) (*Subscription, error)

QueueSubscribe函数会在给定的主题上创建一个异步队列订阅者。所有使用相同队列名称的订阅者会形成一个队列组，对于任何给定的消息，只会异步选择组中的一个成员来接收。其签名与Subscribe方法类似，只是多了一个参数，即队列名称或对给定主题感兴趣的唯一订阅者集群的名称。

2. 命令查询职责分离（CQRS）

CQRS 即 Command Query Responsibility Segregation，由 Greg Young 提出。其核心概念是使用不同的模型来更新信息和读取信息。实现 CQRS 主要有两个原因：一是模型的存储方式与展示方式差异巨大；二是尝试创建一个既优化存储又优化显示的模型可能无法解决任何问题。因此，CQRS 将这些模型拆分为用于展示逻辑的查询模型和用于存储与验证的命令模型。此外，