您还可以在重新启动 Actor 之前终止其下属。Actor 无法从网络外部连接到主管,并且底关闭。 参与者不是通过直接通信,而是通过消息传递进行通信。参与者引用支持参与者想要发送的消息。参与者遵循已知的消息传递方法,例如“发后不管”、“请求响应”和“自适应响应”。 每个 Actor 都有标准配置,包括邮箱(用于消息队列)、执行环境(用于处理代码和传递消息)、行为变量和地址。
但 Actor 可以根据路径进行区分。 路径是描述参与者的协议和 工程师数据库 位置的地址。每个参与者都有一条物理和逻辑路径。这些路径可帮助工程师定义参与者在参与者系统中的功能位置。 处理参与者的首选方法是通过集群,而不是远程连接到它们。集群模块负责将参与者添加到不同的集群系统或从中删除。它还负责分配计算。 Akka 服务 阿尔帕卡 这是一个用于 Java/Scala 管道集成的开源产品。
Alpakka 有一个名为 Alpakka Kafka 的扩展,可让您连接到 Kafka 流。使用 Akka 进行Kafka 开发服务事务可确保所有消息均被无重复使用,并在接收器处成功生成。 Akka 流 Akka Streams 是一个工具包,可让您创建高级抽象流,而不必担心参与者的行为和变量。 Akka 投影 Akka Projections 允许您处理来自源的流。