java - 将 Web Controller 添加到 Akka Actor 系统

Question

我正在使用 Akka 和 Spring。

我有一个在 Kafka Stream 设置上运行的 actor 系统(使用 akka-stream-kafka_2.12)，并且 actor 在内存中保存一些数据并使用 akka-persistence 保留其状态。

我想知道的是，我能否创建一个可以与我的 Actor 系统交互的 REST 端点，以提供一些数据或向我的 Actor 发送消息。

我的问题是，如何实现？

Answer 1

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

请注意:

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

这是Repo的链接。希望这能让您开始。

您可以自己构建应用程序，也可以在命令提示符中运行 api-akka-integration-0.0.1-SNAPSHOT.jar 文件。它在默认的 8080 端口上运行。此示例包含两种 API，/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 集群使用更新了存储库

API-Akka-Cluster