美文网首页
Akka框架之选择Actor和消息收件箱Inbox

Akka框架之选择Actor和消息收件箱Inbox

作者: 夏与清风 | 来源:发表于2019-07-08 14:54 被阅读0次

选择Actor

在一个ActorSystem中可能存在大量的Actor,如何有效对其进行批量管理和通信?框架提供了ActorSelection类,用来批量消息发送。示例代码如下:

消息收件箱Inbox

Akka框架提供了收件箱组件Inbox,可以方便的对Actor进行消息发送和接收,也方便了程序和Actor之间的交互。

示例中Worker会根据收到的消息打印自己的工作状态,当收到CLOSE消息时,会关闭自己结束运行。

main方法及运行结果

--参考文献《实战Java高并发程序设计》

相关文章

  • Akka框架之选择Actor和消息收件箱Inbox

    选择Actor 在一个ActorSystem中可能存在大量的Actor,如何有效对其进行批量管理和通信?框架提供了...

  • Akka框架之消息路由

    Akka提供了灵活的消息发送机制,当使用一组Actor来提供服务时,组中所有的Actor都是平等的,你可以选择任意...

  • AKKA介绍(二)

    上一篇提到,Akka是Actor内单线程编程模型,不共享状态,使用消息在actor间通信。有效的提升actor内的...

  • Akka 2.5.11 路由 Routing

    当处理到来的消息流时,我们需要一个actor来引导消息路由到目标actor,从而提高消息的分配效率。在Akka中这...

  • Akka中的Scheduler

    Actor之间进行通信时,通常都会立即发送消息,然后即刻返回,不会阻塞。但是,AKKA也支持我们对Actor设置S...

  • Springboot flyway migrate执行完毕再执行

    我在Springboot中同时集成了Akka actor和flyway。在WeatherActor中启动actor...

  • Akka系列(二):Akka中Actor系统

    Actor作为Akka中最核心的结构,其在Akka中的中的组织结构也至关重要,今天我们就来讲讲Akka中Actor...

  • akka(1)

    akka 处理并发的基于actor

  • Akka框架之Actor的生命周期

    Actor产生后也存在活动周期,Akka框架提供了若干个回调函数,可以在Actor活动周期内进行一些业务行为。 A...

  • Akka框架之监督策略

    如果一个Actor在执行过程中出现某些未处理的异常,系统如何处理? 在Akka框架内,父Actor可以对子Acto...

网友评论

      本文标题:Akka框架之选择Actor和消息收件箱Inbox

      本文链接:https://www.haomeiwen.com/subject/cgjshctx.html