rest - 事件溯源 - 如何处理竞争条件和 http 传递？

Question

我试图了解如何将事件溯源用于 Web 应用程序。据我所知，事件溯源是关于在事件存储中以事件形式存储数据库更新。我猜想将状态与读取数据库同步可能是由守护进程完成的，它从事件存储中读取最新事件并在读取数据库上执行更改。

我有很多问题，但我认为我们最好讨论一个示例场景。例如，我想构建一个具有用户的 REST 服务。我有一个限制，即用户名应该是唯一的。我有一个事件存储，我已经读取了我设置约束的数据库。好的，现在我发送一个 POST/users 请求，其中的用户名已经存储在数据库中。首先，我将 UserCreated 事件存储在事件存储中，然后呢？我可以用我猜的事件存储生成一个资源 ID，因此我可以在 GET/users/{id} 链接中使用 201 created header 将其发回。客户端获取该链接，点击它(可能是自动的，或者我什至可以发回一个位置 header )，但是读取的数据库还没有同步，所以它会得到一个 404 not found 错误... 好吧，我们可以设置客户端，等待响应。我不明白，我应该在哪些 channel 上发回关于同步结果的响应？通过具有线程的语言，如 java，或通过具有事件循环的语言，如 nodejs 没关系，我可以添加事件和事件处理程序，但是对于仅具有进程的语言，例如 php，我必须构建一些具有巨大内存泄漏的同步守护进程并找到一种在此基础上构建事件总线的方法。这是可以做到的，但这将是艰难而血腥的。所以在那之后我会得到一个正确的响应，比如 500 internal server error，或者类似的东西。所以最后我得到了一个损坏的事件存储，一个无效的 UserCreated 事件，我无法将它与我读取的数据库同步......

我该如何解决这类问题？

我仍然认为将所有内容存储在事件中并添加一些缓存用于数据读取是一种很好的方法，但我真的不明白我应该如何实现它。我认为事件溯源可以很好地适用于websockets + zmq + nodejs，或类似的系统，但不适用于rest + php ...也许我通过阅读失去了意义关于 cqrs 和事件溯源的太多... :S

Answer 1

正如您所注意到的，在 REST 架构中，请求是针对特定资源(如 /users/123)或资源类别(如 /users/)发出的。当执行添加、删除、更新 /users/124 等资源操作时，可能会有对这些事件感兴趣的客户端。如果捕获到事件，则可以近乎实时地通知感兴趣的客户。这称为基于事件的架构。

基于事件的架构提供了一种有效的方式来保持事件生产者和事件消费者客户端的状态与系统同步，而不是系统定期为来自事件消费者客户端(即基于轮询的客户端)的完整状态请求提供服务.通常，事件驱动和轮询驱动方法都用于将客户端与系统同步。