一般规则
关于消息发送,有两条基本规则:
- 最多一次,即不保证消息传递可靠性
- message ordering per sender–receiver pair
消息传递机制
- 最多一次,意味消息有可能丢失
- 最少一次,保证消息传递可靠,但可能冗余
- 保证只成功一次,性能最差,消息成功传递,不冗余
为什么不保证传递可靠性
问题是,我们要保证消息传递在什么环节可靠:
- 消息已经发到网络上了?
- 消息被远程主机接收到了?
- 消息已经在接收者actor的邮箱里了?
- 目标actor是否能处理这个消息?
- 消息在目标actor上开始处理了?
- 消息在目标actor上已经处理完毕了?
上面每一条都有不同的挑战和成本。为什么不需要那么可靠?查看这篇文章
Akka拥抱分布式计算和分布式网络,并通过消息传递来明确实现它,因此它不说谎,而是模拟一个有漏洞的抽象方式。这是在Erlang中取得了重大成功的模型,并要求用户基于此为应用建模。你可以阅读Erlang 文档(10.9, 10.10)了解更多。Akka与它非常相似。
底线:你是一个开发者,知道你的应用中需要提供哪些保证,那么你可以飞快又可靠地使用专门的ACK和RETRY来实现(如果你真的需要,大多数情况你并不需要)。使用Akka的Durable邮箱会有帮助。
消息次序
Actor A1 发送消息 M1, M2, M3 给 A2 Actor A3 发送消息 M4, M5, M6 给 A2
意味着:
- 如果 M1 被投递了,那么它一定在 M2 和 M3之前被投递
- 如果 M2 被投递了,那么它一定在 M3之前被投递
- 如果 M4 被投递了,那么它一定在 M5 and M6之前被投递
- 如果 M5 被投递了,那么它一定在 M6之前被投递
- A2 收到 A1 的消息会与收到的 A3的消息交织在一起
- 因为没有投递保证,所以可能会“没有”,或有“一些”,或“全部”消息到达 A2
http://blog.csdn.net/wsscy2004/article/details/38421333
相关推荐
另外,本书介绍了 Actor 模型的一个实现框架 Akka 以及它的工具,而后讨论了在充分利用 actor 架构的基础上使用 Akka 框架来设计软件系统的方法,以及使用它来开发并发性和分布式应用程序的方怯。本书还介绍了领域 ...
Akka笔记 Akka消息 文档 源代码 从 Akka记录 文档 源代码 从 Akka测试 文档 源代码 从 Akka消息传递请求和响应 文档 源代码 从arunma / AkkaMessagingRequestResponse分叉
akka-study:akkaの勉强
scala-akka-study:scala-akka学习探索
响应式架构 消息模式Actor实现与Scala.Akka应用集成 响应式架构 消息模式Actor实现与Scala.Akka应用集成
Akka ZIO应用 该项目的目的是将Akka Toolkit与ZIO一起使用,以构建高度并发,分布式和弹性消息驱动的应用程序 云 当地的 sbt run open http://0.0.0.0:8080
akka-rabbitmq:Scala和Akka演员中的RabbitMq客户端
akka-microservice:具有Scala,Akka,Spray和CamelActiveMQ的微服务的示例
akka-tools:简化Akka事件源,日记持久性,序列化,集群和分片的开源工具
zio-akka-cluster:用于Akka群集的ZIO包装器
Akka-Testing:Akka.NET测试基础
这意味着,如果您在使用高级API实现某件事时遇到困难,则很有可能可以通过低级API完成该操作,这提供了更大的灵活性,但可能需要您编写更多的应用程序代码。 在了解更多。 文献资料 该文档可在,用于和 。 社区 您...
akka-serial:用于Akka和Scala的React性串行通信库
第 3 章 传递消息:消息传递模式。 第 4 章 Actor 的生命周期—处理状态与错误:Actor 生命周期、监督机制、Stash/ Unstash、Become/Unbecome 以及有限自动机。 第 5 章 纵向扩展:并发编程、Router Group/Pool、...
akka型团队:与Akka Typed,Akka Cluster Sharding和Cassandra结合在一起的未打磨宠物项目
约卡学习 用Akka要点书学习Akka
swagger-akka-http:支持为基于Akka-Http的服务生成Swagger REST API文档
akka-ddd Akka-DDD是一个框架,用于在Akka平台之上遵循DDD / CQRS / ES架构来构建分布式服务。 由于Akka-Persistence的可插拔体系结构,Akka-DDD不受任何特定事件日志提供程序的束缚。 服务被构建为参与者系统。 ...
akka-grpc 支持在Akka Streams上构建流gRPC服务器和客户端。 该库旨在用作使用Akka工具包的项目中的构建块。 文献资料 文档 项目状态 该库可以在生产中使用,但是API和构建系统插件仍有望得到改进,并且。 双方...