如何使用角色进行数据库访问和DDD？

Question

我不太确定如何使用actors访问数据库。在Akka的文档和书籍中，这个主题似乎被省略了。

一种解决方案可以是无状态参与者中的包装DAO。例如，对于数据库中的每个表（或域对象类型或聚合类型），可以创建一个负责所有CRUD操作的参与者。这种方法的一个变体可以是命令和查询的分离。例如，对于每个数据类型，1个命令参与者（用于并发）和10个查询参与者（用于并行性）。

另一种方法可以是创建只表示数据库中一行（或域对象实例或聚合实例）的有状态参与者。当然，在这种情况下，数据库也可以是一个事件存储（如akka持久化模块），最终具有到数据库、文档存储或缓存的一致性投影。这与这里无关。这种方法实际上是一种内存缓存的实现，具有所有的优点和问题。必须有一种策略来摧毁演员，以免在一段时间后内存耗尽。

我将延长我关于DDD的问题：

比方说，我想用Akka演员开发一个DDD应用程序。让我们把注意力集中在指挥部分。在我看来，这应该以这种方式实现：对于每个有界上下文，将有一个端口参与者，例如。喷涂REST API，用于将消息路由到适当的域服务参与者。此服务参与者将业务任务协调到一个或多个域模型聚合。每个聚合都是一个有状态的参与者，由服务参与者从数据库中恢复（或在新数据上创建）。服务参与者向所有相关的聚合参与者发送/路由消息。接收域模型的参与者将对他们的状态消息执行业务验证，然后他们将他们的更改写入数据库。滑头DAO。在向服务参与者发送完成的后，他们会停止。当所有聚合参与者完成后，将向消息的发送者发送一条do消息。一个变体可以是不立即停止有状态域模型参与者，而是在时间跨度之后，比如3分钟。

这是Akka的DDD的有效使用模式吗？




Answer 1

通常DB读取操作（cRud）可以由任何参与者直接执行。在大多数情况下，无需进行任何特殊处理。只是一个简单的循环来平衡负载。

至于更新操作（CrUD），它们可以被分成非交叉域/分片。例如，具有单个帐户的所有操作最好由单个参与者处理。例如，一个可能有N个几乎独立的处理角色和一个路由器，该路由器基于account.hash代码%N将命令路由到其中一个角色。因此，操作将或多或少平均地分配给参与者，每个账户都将按顺序处理。

P.S.Slick似乎是Akka应用程序的下降数据库库。