akka使用

谁借莪１个温暖的怀抱￠ 2022-08-01 14:52 202阅读 0赞

Akka可以以两种不同的方式来使用

(1)以库的形式：在web应用中使用，放到WEB-INF/lib中或者作为一个jar包放进classpath。

(2)以微内核的形式：将应用放进一个独立的内核中。

微内核

要运行微内核，将应用的jar包放到deploy目录下运行bin目录下的脚本。

依赖包

akka-actor\_2.11-2.3.6.jar

scala-library-2.11.2.jar

akka-remote\_2.11-2.3.6.jar

config-1.2.1.jar

akka-slf4j\_2.11-2.3.6.jar

Props

Props是一个配置类，作用是对创建角色确认选项。

ActorSystem

使用ActorSystem将创建顶级角色，该角色使用上下文创建子角色。

ActorRef  child=getContext().actorOf();

(1)actorOf   创建一个新的actor,新的actor是actorOf所调用的上下文的直接子actor。

(2)actorFor  查找一个已存在的actor。

得到角色名称

ActorRef.path().name()

得到本地actor引用

ActorRef   self=getSelf();

得到消息发送者

ActorRef  send=getSender();

停止Actor

使用ActorContext或ActorSystem来停止Actor的运行。通常context用来终止子Actor的运行，而System用来停止最高一级Actor。

停止过程：Actor暂停邮箱并给它的子Actor发送stop消息，然后接收来自子Actor的termination消息直到最后一个子Actor终止，最后终止自己。这个过程确保Actors系统终止的顺序是有序的，如果某个actor没有响应，那么整个过程就陷在那里。

ActorSystem.shutdown()

转发消息

转发消息时，最初的发送者地址/引用保持不变。

target.forward(result , getContext());

PoisonPill

向角色发送PoisonPill消息，这个消息处理完成会角色会被终止。PoisonPill与普通消息一样被放进队列，会在已经入队列的其他消息之后被执行。

target.tell(PoisonPill.getInstance() ,sender);

终止顺序

杀死一个角色

通过发送一个kill消息，导致角色抛出一个ActorKilledException，引发故障。角色将暂停运作，其处理方式取决于监管策略。

target.tell(Kill.getInstance(),ActorRef.noSender());

发表评论取消回复

表情：

评论列表（有 0 条评论，202人围观）

还没有评论，来说两句吧...

相关阅读

相关 Akka使用ProtoBuf序列化

1、根据proto文件生成java代码，具体操作见之前的netty博客 [https://blog.csdn.net/zsj777/article/details/10268

柔光的暖阳◎/ 2023年01月14日 14:56/ 0 赞/ 152 阅读

相关使用Akka创建集群

1、一直有一个想法，想做一个IM集群，最近有个思路通过nacos注册中心实现IM集群节点的服务注册和服务发现，然后用Akka做集群之间的各节点通讯，通过服务注册和服务发现，

缺乏、安全感/ 2023年01月14日 01:42/ 0 赞/ 137 阅读

相关 akka介绍

1、概述 Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成，同时提供了Scala和JAVA的开发接口。 Akk

太过爱你忘了你带给我的痛/ 2022年09月26日 15:58/ 0 赞/ 438 阅读

相关 akka使用

Akka可以以两种不同的方式来使用 (1)以库的形式：在web应用中使用，放到WEB-INF/lib中或者作为一个jar包放进classpath。 (2)以微内核的形式：将

谁借莪１个温暖的怀抱￠/ 2022年08月01日 14:52/ 0 赞/ 203 阅读

相关 Akka 实践（一）Akka基础

一、Akka是什么，解决什么问题系统开发中，软件开发工程师经常面对的困难是高并发处理，高并发处理模块的好坏往往决定了系统的好坏。Akka就是一个基于事件驱动模型的高并发

小咪咪/ 2022年07月15日 14:08/ 0 赞/ 435 阅读

相关 Akka初步

一种类似Netty的RPC通信组件，常见于Scala平台。官方网站： [https://akka.io/][https_akka.io] 待完善。。。 [http

深藏阁楼爱情的钟/ 2022年04月11日 01:43/ 0 赞/ 233 阅读

相关 akka介绍

akka简介一开始想接触到akka，是在看一些并发相关资料的时候，查了下akka的官方介绍，介绍如下：Akka是一个开发库和运行环境，可以用于构建高并发、分布式、可容

╰半夏微凉°/ 2022年03月18日 10:57/ 0 赞/ 398 阅读

相关 akka介绍之-akka-remote介绍

akka-remote介绍既然akka是构建分布式高并发的计算和运行框架，当然要离不开远程通信，akka的remote模块就是专门支持分布式的远程调用。说到分布式

今天药忘吃喽~/ 2022年03月18日 10:49/ 0 赞/ 511 阅读

相关 akka note

if invoked from an instance that is not an Actor the sender will be deadLetters actor

╰+攻爆jí腚メ/ 2021年11月01日 20:26/ 0 赞/ 321 阅读

相关如何开始使用 Akka

如果你是第一次开始使用 Akka，我们推荐你先运行简单的 Hello World 项目。情况参考 [Quickstart Guide][] 页面中的内容来下载和运行 Hello

落日映苍穹つ/ 2021年10月30日 04:52/ 0 赞/ 315 阅读