读spark源码,AKKA确实有必要单独研究一下,用在java的项目上也不错
1.maven构建一个akka的java项目,只需要添加一个dependencies
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-actor_2.10</artifactId>
<version>2.3.14</version>
</dependency>
2. 第一个java AKKA消息驱动程序
1)构建ActorSystem,发送给自定义的MasterActor
import scala.concurrent.Future;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.apply.actor.MasterActor;
import akka.pattern.Patterns;
public class MainTest {
public static void main(String[] args) {
ActorSystem as = ActorSystem.create("test");
ActorRef master = as.actorOf(Props.create(MasterActor.class), "master");
master.tell("start", master);
as.awaitTermination();
}
}
import akka.actor.ActorRef;
import akka.actor.Props;
import akka.actor.UntypedActor;
public class MasterActor extends UntypedActor {
@Override
public void onReceive(Object msg) throws Exception {
System.out.println(""+this.getClass().getSimpleName()+"::sender:"+this.getSender()+" ::self:"+this.getSelf());
}
}
运行结果:
相关推荐
读书笔记:基于Akka编写的RPC通讯程序Demo以Scala为开发语言
读书笔记:Scala支持的著名的并发编程框架Akka的学习记录
读书笔记:以Scala带动对异步编程webflux、akka、pulsar、gRpc等框架学习
Akka笔记 Akka消息 文档 源代码 从 Akka记录 文档 源代码 从 Akka测试 文档 源代码 从 Akka消息传递请求和响应 文档 源代码 从arunma / AkkaMessagingRequestResponse分叉
读书笔记:《实战Java高并发程序设计》第2版 第7章使用Akka构建高并发程序 源码
阿卡持久性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`...
1. **Action过滤器**(Xitrum学习笔记15 - Action过滤器.pdf):这部分内容讲述了Xitrum中的Action过滤器,这是框架提供的一个关键特性,允许开发者在处理HTTP请求之前或之后执行自定义逻辑。过滤器可以用于身份验证...
接下来,我们来看`akka笔记.txt`中的内容,可能会涉及如何创建Actor以及如何进行远程调用: 1. 创建Actor:使用`Props`和`ActorSystem`创建Actor。例如: ```scala val system = ActorSystem("MySystem") val ...
第四部分:"Scala入门及进阶-part04-Akka Actor.pdf" 专注于Scala与Akka框架的集成,Akka是用于构建高度并发、分布式和容错系统的工具。Actor模型在Akka中扮演核心角色,这部分将解释Actor如何工作,以及如何创建、...
### Spark源码阅读笔记 #### 一、Spark概述与特性 **Spark** 是一款由加州大学伯克利分校AMP实验室研发的数据处理框架,它极大简化了开发者编写并行应用程序的过程,使得用户能够在集群环境中轻松地运行自己的应用...
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 介绍
1. **销售自动化**:自动跟踪销售过程,从潜在客户到最终客户的转换,管理销售机会,预测销售业绩。 2. **市场营销自动化**:协助策划和执行营销活动,如电子邮件营销,自动化潜在客户培育过程。 3. **客户服务和...
5. Akka框架:Akka是用Scala编写的开源框架,用于构建高度可扩展、容错的应用程序,它充分利用了Scala的Actor模型。 6. Scala与Java互操作:由于Scala是运行在JVM上的,所以可以直接使用Java库,与Java代码无缝集成...