redis - 使用 Redis MQ 的 CQRS

Question

在过去的 9 个月里，我一直致力于 CQRS 项目(我的第一个项目)，这是一个沉重的学习曲线。我目前在我的写入模型中使用 JOliver 出色的 EventStore，并在我的读取模型中使用 PostGresSql。

我的读数据库和写数据库都在同一台机器上，这意味着当对写数据库进行更改时，在同一个同步调用中也会对读模型进行更改。

在我学习 CQRS 时，我觉得这是最好的方法，因为我没有使用消息队列/服务总线框架(如 MassTransit、NServiceBus 等)的经验。

我现在的大部分架构都已准备就绪，可以引入消息队列框架。

今天，我遇到了 Redis MQ，它是 ServiceStack 的一部分，因为我们已经将 ServiceStack 用于我们基于 Rest 的 HTTP 客户端，这似乎是正确的方法。

我的问题更多的是了解我需要了解什么(或者我是否有任何误解)来实现 Redis MQ 以及 Redis MQ 是否是正确的选择？

现在，据我了解，我将使用 Redis MQ 作为写入和读取数据库之间的持久队列。一旦我的事件存储记录了我的域中发生的事情，它就会发布到 Redis MQ。监听事件/消息的服务将从 Redis MQ 接收事件/消息，一旦它处理了它(即更新或写入读取模型)，通知/响应返回到事件存储以告诉事件存储消息已被收听者/订阅者接收和处理。

这听起来正确吗？

Redis MQ 架构是否也能提供 NSB、RavenDB、MassTransit 等提供的一切？

此外，我将部署到 Windows 2008 和 2003 服务器。 Redis 对于这些操作系统是否稳定？

Answer 1

我认为 Redis 中消息队列的 ServiceStack 实现更适合作业队列场景——它将消息推送到 Redis 列表的末尾，然后使用 Redis pub-sub 通知监听订阅者有消息要发送从队列中拉出。任何消费者都会竞争消息。

对于事件溯源，您可能对 RabbitMQ 提供的一种扇出或基于主题的消息传递拓扑更感兴趣，但这并不妨碍您自己使用 Redis 数据结构构建此类事物。