集群感知路由器 依赖 组路由器 带路由组的路由器示例 带有远程部署路由池的路由器 带有远程部署路由池的路由器示例 集群感知路由器 所有「routers 」都可以知道集群中的成员节点，即部署新的路由（routees ）或在集群中的节点上查找路由。当一个节点无法访问或离开集群时，该节点的路由将自动从路由器中注销。当新节点加入集群时，会根据配置向...

本地集群 Setup: Download and Start Flink Start a Local Flink Cluster Windows Cygwin Users Stop a Local Flink Cluster 本地集群 Get a local Flink cluster up and running in a few simp...

Hello World - Scala using Akka HTTP Before you begin Configuring the Service descriptor Publishing to Docker Deploying to Knative Serving Cleanup Feedback Hello World - S...

Hello World - Scala using Akka HTTP Before you begin Configuring the sbt build Configuring the Service descriptor Publishing to Docker Deploying to Knative Serving Cleanup ...

滚动更新 简介 关闭命令 更改日志 2.5.0 小版本中的几个变更 2.5.10 连接回归 2.5.10 加入旧版本 2.5.14 ORSet[ActorRef] 的分布式数据序列化 2.5.22 ShardRegionStats 的 ClusterSharding 序列化 滚动更新 简介 滚动更新是将系统的一个版本替换为另一个版...

作为 FSM 的行为 作为 FSM 的行为 对于非类型化的 Actor，有明确的支持来构建「有限状态机 」。在 Akka 类型中不需要支持，因为用行为表示 FSM 很简单。 为了了解如何使用 Akka 类型的 API 来建模 FSM，下面是从「非类型化的 Actor FSM 文档 」移植的Buncher 示例。它演示了如何： 使用不同行为模拟状...

持久化 依赖 示例项目 简介 体系结构 事件源 标识符 恢复 恢复自定义 恢复状态 内部存储 Relaxed 本地一致性需求和高吞吐量用例 推迟操作，直到执行了前面的持久处理程序 嵌套的持久调用 失败 原子写入 批量写入 消息删除 持久化状态处理 安全地关闭持久性 Actor 重播滤波器 快照 快照删除 快照状态处理...

容错 依赖 简介 实践中的故障处理 创建监督策略 默认监督策略 停止监督策略 记录 Actor 的失败 顶级 Actor 的监督者 测试应用 容错 依赖 容错（fault tolerance ）概念与 Actor 相关，为了使用这些概念，需要在项目中添加如下依赖： <!-- Maven --> <dependency> ...

Hello World - Scala using Akka HTTP Before you begin Configuring the sbt build Configuring the Service descriptor Publishing to Docker Deploying to Knative Serving Cleanup ...

持续时间 依赖 有限 vs. 无限 Scala Java 最后期限 持续时间 持续时间（Duration ）在整个 Akka 库中使用，因此这个概念由一个特殊的数据类型scala.concurrent.duration.Duration 表示。此类型的值可以表示无限（Duration.Inf 、Duration.MinusInf ）或有限的...