1.Actor是个 scala写的接口
除了获取sender self recieve 其他的打眼一看面向切面的n多方法
其中: preStart 用于发送前初始化参数 postStop用于结束后回收资源
2. Actor sender , self , path 每个actor都有系统内唯一的一个path
master.tell("start", master);
path : akka://test/user/master
Actor之间发送消息:
定义另一个 Actor1 和 Actor2
public class Actor1 extends UntypedActor{
@Override
public void onReceive(Object msg) throws Exception {
System.out.println(""+this.getClass().getSimpleName()+"::sender:"+this.getSender());
if (msg instanceof String){
String s = (String) msg;
this.getSender().tell("akka.apply.actor.Actor2", this.getSelf());
}else
this.unhandled(msg);
}
}
public class Actor2 extends UntypedActor{
@Override
public void onReceive(Object msg) throws Exception {
System.out.println(""+this.getClass().getSimpleName()+"::sender:"+this.getSender());
if (msg instanceof String){
String s = (String) msg;
this.getSender().tell("akka.apply.actor.Actor1", this.getSelf());
}else
this.unhandled(msg);
}
}
修改 MasterActor : onReceive方法
@Override
public void onReceive(Object msg) throws Exception {
System.out.println(""+this.getClass().getSimpleName()+"::sender:"+this.getSender()+" ::self:"+this.getSelf());
//System.out.println(this.getSelf());
if (msg instanceof String){
if ( true)
return;
String s = (String) msg;
if ( s.equals("start")){
ActorRef a1 = this.getContext().actorOf(Props.create(Actor1.class), "Actor1");
ActorRef a2 = this.getContext().actorOf(Props.create(Actor2.class), "Actor2");
a1.tell("akka.apply.actor.Actor1", a2);
}
}else
this.unhandled(msg);
}
虽然启始消息是MasterActor的方法中定义发送的,但 a1.tell("akka.apply.actor.Actor1", a2); 定义了 接受方是 Actor1,发送方是 Actor2,(相当于master在方法中,发给a1一个消息,告诉a1,这个消息不是我发的是a1发的,虽然这个方式很灵活,但现在还不太理解这么设计的目的。)这两者又互相将消息发给对方,执行结果如下:
MasterActor::sender:Actor[akka://test/user/master#-2085464928] ::self:Actor[akka://test/user/master#-2085464928]
Actor1::sender:Actor[akka://test/user/master/Actor2#1627072295] ::self:Actor[akka://test/user/master/Actor1#-2006482622]
Actor2::sender:Actor[akka://test/user/master/Actor1#-2006482622] ::self:Actor[akka://test/user/master/Actor2#1627072295]
Actor1::sender:Actor[akka://test/user/master/Actor2#1627072295] ::self:Actor[akka://test/user/master/Actor1#-2006482622]
Actor2::sender:Actor[akka://test/user/master/Actor1#-2006482622] ::self:Actor[akka://test/user/master/Actor2#1627072295]
Actor1::sender:Actor[akka://test/user/master/Actor2#1627072295] ::self:Actor[akka://test/user/master/Actor1#-2006482622]
Actor2::sender:Actor[akka://test/user/master/Actor1#-2006482622] ::self:Actor[akka://test/user/master/Actor2#1627072295]
........
修改Actor1的方法,将消息发给MasterActor,
public void onReceive(Object msg) throws Exception {
System.out.println(""+this.getClass().getSimpleName()+"::sender:"+this.getSender()+" ::self:"+this.getSelf());
//System.out.println(this.getSelf());
if (msg instanceof String){
String s = (String) msg;
ActorRef m = this.getContext().actorOf(Props.create(MasterActor.class), "master");
m.tell("return Master", this.getSelf());
//this.getSender().tell("akka.apply.actor.Actor2", this.getSelf());
//this.getSelf().tell(s, getSender());
//ActorRef a = this.getContext().actorOf(Props.create( Class.forName(s)), s);
//a.tell(s, a);
//this.getContext().stop(a);
}else
this.unhandled(msg);
}
运行结果:
MasterActor::sender:Actor[akka://test/user/master#-1998415775] ::self:Actor[akka://test/user/master#-1998415775]
Actor1::sender:Actor[akka://test/user/master/Actor2#-63616032] ::self:Actor[akka://test/user/master/Actor1#-795382741]
MasterActor::sender:Actor[akka://test/user/master/Actor1#-795382741] ::self:Actor[akka://test/user/master/Actor1/master#2020933176]
发现MasterActor的path发生了变化,AKKA的Actor采用树结构,父类的Actor负责管理子类,当子类由于错误关闭,父类会重建子类发送消息(后面找机会验证一下)
停止消息
在MasterActor的onReceive方法中添加
this.getContext().stop(a1);
但发现并不是消息传递到Action1的时候 就会停止,而是会在Actor1 Actor2相互交互多次,而且次数不固定,说明这个停止是异步的。
相关推荐
读书笔记:《实战Java高并发程序设计》第2版 第7章使用Akka构建高并发程序 源码
读书笔记:基于Akka编写的RPC通讯程序Demo以Scala为开发语言
读书笔记:Scala支持的著名的并发编程框架Akka的学习记录
读书笔记:以Scala带动对异步编程webflux、akka、pulsar、gRpc等框架学习
Akka笔记 Akka消息 文档 源代码 从 Akka记录 文档 源代码 从 Akka测试 文档 源代码 从 Akka消息传递请求和响应 文档 源代码 从arunma / AkkaMessagingRequestResponse分叉
阿卡持久性rocksdb Akka 的实验性基于的持久性存储。 这是一个 alpha 版本; 目前它更像是 RocksDB 和 Akka-Persistence 的实验,而不是 Akka-...笔记 需要 Akka 2.4-Snapshot,因为它使用简化的 akka-persi
使用 Akka IO 在 Scala 中实现非阻塞 Redis 客户端重新反应基于 Akka I/O 的非...Timeout(5 seconds)// Redis client setupval client = RedisClient("localhost", 6379)笔记下面的示例取自测试用例。每个 API 调用都
笔记 要让多个分片参与者在单独的节点子集上运行,并且可以从集群中的其他节点访问,例如: Counter1 在 node1、node2、node3 上运行 Counter2 在 node7、node8、node9 上运行 Query 想同时查询 Counter1 分片和 ...
在"scala学习笔记整理"中,我们可以深入探讨以下关键知识点: 1. **基础语法**:Scala的基础语法与Java有相似之处,但也有很多独特的特点。例如,它支持变量的不可变性(immutability),使用`val`声明常量,`var`...
3. **集群构建**(Xitrum学习笔记20 - 和Akka、Hazelcast组成集群.pdf):Xitrum可以与Akka和Hazelcast等工具集成,实现应用的集群部署,以提高服务的可用性和伸缩性。这部分会讲解如何配置和管理集群,以及如何处理...
接下来,我们来看`akka笔记.txt`中的内容,可能会涉及如何创建Actor以及如何进行远程调用: 1. 创建Actor:使用`Props`和`ActorSystem`创建Actor。例如: ```scala val system = ActorSystem("MySystem") val ...
### Spark源码阅读笔记 #### 一、Spark概述与特性 **Spark** 是一款由加州大学伯克利分校AMP实验室研发的数据处理框架,它极大简化了开发者编写并行应用程序的过程,使得用户能够在集群环境中轻松地运行自己的应用...
第四部分:"Scala入门及进阶-part04-Akka Actor.pdf" 专注于Scala与Akka框架的集成,Akka是用于构建高度并发、分布式和容错系统的工具。Actor模型在Akka中扮演核心角色,这部分将解释Actor如何工作,以及如何创建、...
1. **通信框架**: Spark采用了**Akka** 和 **Netty** 这两种成熟的通信技术,这些技术已经被广泛应用于生产环境,具有稳定性和高效性。 2. **Shuffle实现**: Spark中的Shuffle功能主要借鉴了**MapReduce**的设计...
笔记: 我们强烈建议在本教程中使用 Java 8。 有一个实验分支latest-dependency-versions可以使用 Java 9 进行编译,但在成功运行时仍然存在问题。 另请参阅我们较新的教程 ,它扩展了此处的概念,更侧重于服务 ML ...
akka-http-routes-guard 我发现 Spray.io / Akka-http 新手经常犯常见的错误 - 他们忘记用波浪号 ( ~ ) 运算符连接路由。 在期间,我想编写一个 Scala 宏,当它遇到路由之间缺少的连接运算符时,它会中止编译(或...
目录如下 Scala简介&快速入门 基础语法 变量 数据类型 流程控制 操作符重载 模式匹配 函数式编程基础 函数式编程说明 函数定义/声明 函数运行机制 递归 函数注意事项和细节 ...Akka 介绍
2. **市场营销自动化**:协助策划和执行营销活动,如电子邮件营销,自动化潜在客户培育过程。 3. **客户服务和支持**:提供客户支持平台,记录客户问题和解决方案,提升服务质量和客户满意度。 4. **数据分析**:...
5. Akka框架:Akka是用Scala编写的开源框架,用于构建高度可扩展、容错的应用程序,它充分利用了Scala的Actor模型。 6. Scala与Java互操作:由于Scala是运行在JVM上的,所以可以直接使用Java库,与Java代码无缝集成...