1

我有一个 REST 服务，它有多个相互协调的参与者。数据存储在 postgresDB 中。根据针对类型化 Actor 的新 akka Actor System 2.6，https: //doc.akka.io/docs/akka/2.6/typed/actors.html ，我们需要在 Actor 之间传递消息并基于 Actor 响应的消息。例如，我必须对用户类别进行 CRUD 操作。请求流程为：控制器 -> 参与者 1 -> 参与者 2 -> DAO 响应流程为：DAO -> 参与者 2 -> 参与者 1 -> 控制器

基于这种情况，我有几个问题：

1 我们是否必须为每个参与者设置不同的 onMessages？

return newReceiveBuilder().onMessage(GetCategories.class, this::onGet)
.onMessage(AddCategories.class, this::onAdd)
.build();

  1. 控制器将如何调用actor 1？

  2. 我们是否需要为每条传递的消息创建一个新的 POJO？例如GetCategory、AddCategory。

  3. 每个演员的代码设置不是太多了吗？

4

0 回答 0