`
ding__lin
  • 浏览: 21170 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

AKKA笔记1

 
阅读更多

读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());

 

}

 

}

 

运行结果: 

 

 

  • 大小: 8.9 KB
  • 大小: 10.2 KB
分享到:
评论

相关推荐

    读书笔记:基于Akka编写的RPC通讯程序Demo以Scala为开发语言.zip

    读书笔记:基于Akka编写的RPC通讯程序Demo以Scala为开发语言

    读书笔记:Scala支持的著名的并发编程框架Akka的学习记录.zip

    读书笔记:Scala支持的著名的并发编程框架Akka的学习记录

    读书笔记:以Scala带动对异步编程webflux、akka、pulsar、gRpc等框架学习.zip

    读书笔记:以Scala带动对异步编程webflux、akka、pulsar、gRpc等框架学习

    akka_notes:Akka在学习AkkaReact框架的同时注意

    Akka笔记 Akka消息 文档 源代码 从 Akka记录 文档 源代码 从 Akka测试 文档 源代码 从 Akka消息传递请求和响应 文档 源代码 从arunma / AkkaMessagingRequestResponse分叉

    读书笔记:《实战Java高并发程序设计》第2版 第7章使用Akka构建高并发程序 源码.zip

    读书笔记:《实战Java高并发程序设计》第2版 第7章使用Akka构建高并发程序 源码

    akka-persistence-rocksdb:Akka-Persistence 的 RocksDB 存储后端

    阿卡持久性rocksdb Akka 的实验性基于的持久性存储。 这是一个 alpha 版本; 目前它更像是 RocksDB 和 Akka-Persistence 的实验,而不是 Akka-...笔记 需要 Akka 2.4-Snapshot,因为它使用简化的 akka-persi

    akka-cluster-example-inloop:简单的 akka 集群示例

    笔记 要让多个分片参与者在单独的节点子集上运行,并且可以从集群中的其他节点访问,例如: Counter1 在 node1、node2、node3 上运行 Counter2 在 node7、node8、node9 上运行 Query 想同时查询 Counter1 分片和 ...

    scala学习笔记整理

    在"scala学习笔记整理"中,我们可以深入探讨以下关键知识点: 1. **基础语法**:Scala的基础语法与Java有相似之处,但也有很多独特的特点。例如,它支持变量的不可变性(immutability),使用`val`声明常量,`var`...

    Xitrum学习笔记

    1. **Action过滤器**(Xitrum学习笔记15 - Action过滤器.pdf):这部分内容讲述了Xitrum中的Action过滤器,这是框架提供的一个关键特性,允许开发者在处理HTTP请求之前或之后执行自定义逻辑。过滤器可以用于身份验证...

    scala rpc基础搭建

    接下来,我们来看`akka笔记.txt`中的内容,可能会涉及如何创建Actor以及如何进行远程调用: 1. 创建Actor:使用`Props`和`ActorSystem`创建Actor。例如: ```scala val system = ActorSystem("MySystem") val ...

    scala讲解笔记 入门及进阶 PDF文档1-5

    第四部分:"Scala入门及进阶-part04-Akka Actor.pdf" 专注于Scala与Akka框架的集成,Akka是用于构建高度并发、分布式和容错系统的工具。Actor模型在Akka中扮演核心角色,这部分将解释Actor如何工作,以及如何创建、...

    spark源码阅读笔记

    ### Spark源码阅读笔记 #### 一、Spark概述与特性 **Spark** 是一款由加州大学伯克利分校AMP实验室研发的数据处理框架,它极大简化了开发者编写并行应用程序的过程,使得用户能够在集群环境中轻松地运行自己的应用...

    spark源码阅读笔记(详)

    1. **通信框架**: Spark采用了**Akka** 和 **Netty** 这两种成熟的通信技术,这些技术已经被广泛应用于生产环境,具有稳定性和高效性。 2. **Shuffle实现**: Spark中的Shuffle功能主要借鉴了**MapReduce**的设计...

    java版三级分销源码-kafka-with-akka-streams-kafka-streams-tutorial:关于使用AkkaStre

    笔记: 我们强烈建议在本教程中使用 Java 8。 有一个实验分支latest-dependency-versions可以使用 Java 9 进行编译,但在成功运行时仍然存在问题。 另请参阅我们较新的教程 ,它扩展了此处的概念,更侧重于服务 ML ...

    akka-http-routes-guard:ScalaWAW hackathon 项目 - 遇到路由之间缺少连接运算符时中止编译的宏

    akka-http-routes-guard 我发现 Spray.io / Akka-http 新手经常犯常见的错误 - 他们忘记用波浪号 ( ~ ) 运算符连接路由。 在期间,我想编写一个 Scala 宏,当它遇到路由之间缺少的连接运算符时,它会中止编译(或...

    SCALA从入门到精通个人笔记含代码

    目录如下 Scala简介&快速入门 基础语法 变量 数据类型 流程控制 操作符重载 模式匹配 函数式编程基础 函数式编程说明 函数定义/声明 函数运行机制 递归 函数注意事项和细节 ...Akka 介绍

    管理系统练习.zip555

    1. **销售自动化**:自动跟踪销售过程,从潜在客户到最终客户的转换,管理销售机会,预测销售业绩。 2. **市场营销自动化**:协助策划和执行营销活动,如电子邮件营销,自动化潜在客户培育过程。 3. **客户服务和...

    Scala-学习资料-mht.rar

    5. Akka框架:Akka是用Scala编写的开源框架,用于构建高度可扩展、容错的应用程序,它充分利用了Scala的Actor模型。 6. Scala与Java互操作:由于Scala是运行在JVM上的,所以可以直接使用Java库,与Java代码无缝集成...

    scala笔记:学习scala时的笔记

    1. **基本语法与类型系统**: - Scala是强类型语言,变量声明时必须指定类型,但可以使用类型推断简化编写。 - `val`用于声明不可变变量,`var`用于声明可变变量。 - 类型系统包括基本类型(如Int, Double, ...

Global site tag (gtag.js) - Google Analytics