上一节讲到actor是actor system最基本的单元。这一节详细的讲讲actor.更详细here。actor是一个拥有state,behavior,mailbox,children,supervisor strategy的容器.Akka保证所有actor都只运行在自己的轻量级线程,并一次处理一个消息,这样程序员就不用处理同步、竞态
Actor Reference
为了防止actor对象被直接的访问和操作,所以actors通过ActorRef来间接交流。message可以通过如下方式传递:
- ! (“tell”) - 发送message并马上返回
- ? (“ask”) - 发送message并返回Future
详见here
State
actor拥有的一组变量,即actor的state。state是可恢复的,详见Persistence
Behavior
actor处理消息的方法吧~
Mailbox
所有收到的消息,会进入actor的mailbox队列。默认是FIFO。
Children
每一个actor,都是潜在的监控者。actor会自动监控执行子任务的actor.children被放在context中,通过context.actorof(...))
或者context.stop(child))
操作children.这些操作都是异步的,所以相应非常快。
Supervisor Strategy
actor一旦创建,监控策略是不可修改的。Akka自动帮我们处理错误故障。具体的错误策略详见错误的监督和监控
当Actor终止时
一旦actor意外终止,比如失败了。它会释放所有资源,将未处理的messages发送给system的dead letter mailbox.这些message将由EventStream处理。
为什么不把dead letter全部丢掉呢?dead letter主要用来debug
http://blog.csdn.net/wsscy2004/article/details/38233175
相关推荐
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.5.19; 标签:typesafe、akka、actor、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译...
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.5.19; 标签:typesafe、akka、actor、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化...
另外,本书介绍了 Actor 模型的一个实现框架 Akka 以及它的工具,而后讨论了在充分利用 actor 架构的基础上使用 Akka 框架来设计软件系统的方法,以及使用它来开发并发性和分布式应用程序的方怯。本书还介绍了领域 ...
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.5.21; 标签:typesafe、akka、actor、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译...
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.4.20; 标签:typesafe、akka、actor、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化...
spark,akka,actor工具类,版本2.11;akka.actor override def receive: Receive = { case mess: Message => { if (mess.message.equals("")) { println(mess.message) } } }
标签:akka-typed-actor-1.0-RC2.jar.zip,akka,typed,actor,1.0,RC2,jar.zip包下载,依赖包
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.4.20; 标签:typesafe、akka、actor、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译...
Maven坐标:com.typesafe.akka:akka-actor_2.11:2.5.21; 标签:typesafe、akka、actor、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化...
用于 actor系统的可插拔监视系统工具。 火卫一vs.阿卡。 2018年, 的制造商Petabridge 。 Phobos比Akka具有更全面的功能。 不需要用户用任何代码来修饰其参与者-监视和跟踪自动进行; 开箱即用地支持大量公制和...
其中包括:Actor模型和响应式软件的主要概念、Scala语言的基础知识、Akka框架与Akka集群功能、Actor模型中的通道机制和技术、降低消息源与消息目的地之间耦合性的方式、持久化Actor对象和幂等接收者。附录A中还介绍...
scala-akka-study:scala-akka学习探索
akka-study:akkaの勉强
其中包括:Actor模型和响应式软件的主要概念、Scala语言的基础知识、Akka框架与Akka集群功能、Actor模型中的通道机制和技术、降低消息源与消息目的地之间耦合性的方式、持久化Actor对象和幂等接收者。附录A中还介绍...
Akka HTTP模块在akka-actor和akka-stream之上实现了完整的服务器和客户端HTTP堆栈。 它不是Web框架,而是提供和使用基于HTTP的服务的更通用的工具包。 虽然与浏览器的交互当然也在范围内,但这并不是Akka HTTP的...
akka-rabbitmq:Scala和Akka演员中的RabbitMq客户端
Akka ZIO应用 该项目的目的是将Akka Toolkit与ZIO一起使用,以构建高度并发,分布式和弹性消息驱动的应用程序 云 当地的 sbt run open http://0.0.0.0:8080
akka-microservice:具有Scala,Akka,Spray和CamelActiveMQ的微服务的示例
Akka-Testing:Akka.NET测试基础
zio-akka-cluster:用于Akka群集的ZIO包装器