将Web控制器添加到Akka Actor系统

Question

我和Akka和Spring一起工作。

我有一个演员系统，它运行在一个卡夫卡流上(使用akka-stream-kafka_2.12)，参与者在内存中保存一些数据，并使用akka-persistence保存他们的状态。

我想知道的是，我可以创建一个REST端点，它可以与我的Actor-System交互，以提供一些数据或向我的参与者发送消息。

我的问题是，怎样才能达到这个目标？

Answer 1

正如评论中所说的，我在github中创建了一个示例工作应用程序，以演示Spring在Akka中的用法。

请注意:

1. 我使用Springboot进行快速设置和配置。
2. 在这个演示项目中，您不能期望任何好/最好的实践，因为我必须在30分钟内创建它。它只是解释了在Spring中使用akka的一种方法(简单)。
3. 此示例不能用于微服务架构，因为这里不涉及远程处理或群集。API控制器直接与参与者对话。
4. 在控制器中，为了简单起见，在所有地方使用GetMapping而不是PostMapping。
5. 将使用另一个示例更新存储库，说明在another和ActorSystem之间的通信方式发生变化的情况下使用集群的情况。

这是连接到存储库的链接。希望这能让你开始。

您可以自己构建应用程序，也可以在命令提示符下运行akka integration-0.0.1-SNAPSHOT.jar文件。它在默认的8080端口中运行。此示例包含两种APIs，/Calc/{Operation}/{operand1}/{operand2}和/Chat/{message}。

/聊天/你好

/calc/add/1/2

/calc/mul/1/2

/calc/div/1/2

/calc/sub/1/2

编辑:2

在API中使用Akka CLuster更新回购程序

Akka集群