关于服务
翻译我在 Akka 上开发并发和分布式系统,使用 Scala 或 Java,已经有好几年将演员模型转化为能够平稳处理负载的代码。当一个服务需要处理成千上万的同时请求,为每个用户在内存中存储状态,并且同时不丢失消息时,我设计演员层次结构、监督策略和背压,以确保故障保持为局部事件,而不是系统范围的故障。
我使用完整的 Akka 工具包:用于在节点之间分配实体的集群和集群分片,具有背压的有界管道的 Akka Streams,使用 CQRS 的持久性和事件溯源,以便写入和读取模型独立演变,以及网络分区不损坏数据的分裂脑解决方案。我还关心你在战斗中仅记住的内容:对非活动演员的被动处理、无停机时间的更新、具有幂等处理程序的至少一次交付。
如果你想要一个诚实对待并发的系统,而不是将其隐藏在锁后,请联系我。我将分析你当前的架构或从头开始,编写经过测试的演员,并交付可以理解的代码。典型任务:
— 新的基于演员的后端和消息协议;
— 将阻塞服务迁移到 Akka Streams;
— 向实时应用程序添加集群分片和事件溯源;
— 拯救一个在负载下出现死锁和泄漏演员的项目。
我使用完整的 Akka 工具包:用于在节点之间分配实体的集群和集群分片,具有背压的有界管道的 Akka Streams,使用 CQRS 的持久性和事件溯源,以便写入和读取模型独立演变,以及网络分区不损坏数据的分裂脑解决方案。我还关心你在战斗中仅记住的内容:对非活动演员的被动处理、无停机时间的更新、具有幂等处理程序的至少一次交付。
如果你想要一个诚实对待并发的系统,而不是将其隐藏在锁后,请联系我。我将分析你当前的架构或从头开始,编写经过测试的演员,并交付可以理解的代码。典型任务:
— 新的基于演员的后端和消息协议;
— 将阻塞服务迁移到 Akka Streams;
— 向实时应用程序添加集群分片和事件溯源;
— 拯救一个在负载下出现死锁和泄漏演员的项目。