CQRS是如何实现的，读取数据库是在哪里创建的

Question

我有发现服务：https://github.com/Naresh-Chaurasia/API-MicroServices-Kafka/tree/master/Microservices-CQRS-SAGA-Kafka/DiscoveryService

我有产品服务：https://github.com/Naresh-Chaurasia/API-MicroServices-Kafka/tree/master/Microservices-CQRS-SAGA-Kafka/ProductsService

我有 API 网关：https://github.com/Naresh-Chaurasia/API-MicroServices-Kafka/tree/master/Microservices-CQRS-SAGA-Kafka/ApiGateway

产品服务和API网关已向发现服务注册。我使用API网关来访问产品服务。

我正在学习为产品服务实施CQRS的课程。

在产品服务下，我有< code > src/main/Java/com/appsdeveloperblog/estore/products service/command/product aggregate . Java

这里的ProductAggregate是CRQS的命令。

它有以下方法（有关详细信息，请参阅GitHub）：

@CommandHandler
public ProductAggregate(CreateProductCommand createProductCommand) throws Exception {
...
}

@EventSourcingHandler
public void on(ProductCreatedEvent productCreatedEvent) {
...
}

它还具有src/main/java/com/appsdeveloperblog/estore/ProductsService/query/ProductEventsHandler.java，它们将产品持久化在H2 db中。

我还实现了src/main/java/com/appsdeveloperblog/estore/ProductsService/query/ProductsQueryHandler.java，用于查询数据库。

这里是CRQS的ProductsQueryHandleris查询。

我的问题如下

1. 我无法理解发布事件是如何以及何时生成的，以及何时将消息放入消息队列。
另外，数据保存到
2. 事件存储后，是否有可能不存储在读取数据库中。如果是，那么我们如何同步读取数据库。

Answer 1

我无法理解发布事件是如何以及何时生成的，以及何时将消息放入消息队列。

它发生在事件发布到事件存储之后。

可以使用许多可能的设计将事件从事件存储复制到查询端的事件处理程序。这些将包括

< li >让应用程序代码将事件复制到事件处理程序订阅的消息队列中 < li >让事件处理程序按计划从事件存储中提取成批事件 < li >让事件处理程序从事件存储中提取事件，但使用消息队列来宣布有新消息要提取。

数据是否可能在持久化到事件存储后，不存储在读取数据库中。

是的。这种情况有多普遍取决于...实际上，这主要取决于你在可靠性上投入了多少。

这就是为什么拉取模型往往很受欢迎——读取过程可以跟踪它看到了哪些事件，并在X之后请求下一批消息——其中X是时间戳、序列号或其他东西。

警告：如果您尝试推出自己的事件存储，则正确获取这些详细信息可能会很棘手。除非事件商店的细节是你竞争优势的一部分，否则你真的想购买可靠性，而不是试图建立它。