Akka框架实例demo讲解(akka framework)
ccwgpt 2024-10-15 08:54 32 浏览 0 评论
Akka官网demo:
//#full-example package akka import akka.actor.{ Actor, ActorLogging, ActorRef, ActorSystem, Props } //#greeter-companion //#greeter-messages object Greeter { //#greeter-messages def props(message: String, printerActor: ActorRef): Props = Props(new Greeter(message, printerActor)) //#greeter-messages final case class WhoToGreet(who: String) case object Greet } //#greeter-messages //#greeter-companion //#greeter-actor class Greeter(message: String, printerActor: ActorRef) extends Actor { import Greeter._ import Printer._ var greeting = "" def receive = { case WhoToGreet(who) => greeting = message + ", " + who case Greet => //#greeter-send-message printerActor ! Greeting(greeting) //#greeter-send-message } } //#greeter-actor //#printer-companion //#printer-messages object Printer { //#printer-messages def props: Props = Props[Printer] //#printer-messages final case class Greeting(greeting: String) } //#printer-messages //#printer-companion //#printer-actor class Printer extends Actor with ActorLogging { import Printer._ def receive = { case Greeting(greeting) => log.info("Greeting received (from " + sender() + "): " + greeting) } } //#printer-actor //#main-class object AkkaQuickstart extends App { import Greeter._ // Create the 'helloAkka' actor system val system: ActorSystem = ActorSystem("helloAkka") //#create-actors // Create the printer actor val printer: ActorRef = system.actorOf(Printer.props, "printerActor") // Create the 'greeter' actors val howdyGreeter: ActorRef = system.actorOf(Greeter.props("Howdy", printer), "howdyGreeter") val helloGreeter: ActorRef = system.actorOf(Greeter.props("Hello", printer), "helloGreeter") val goodDayGreeter: ActorRef = system.actorOf(Greeter.props("Good day", printer), "goodDayGreeter") //#create-actors //#main-send-messages howdyGreeter ! WhoToGreet("Akka") howdyGreeter ! Greet howdyGreeter ! WhoToGreet("Lightbend") howdyGreeter ! Greet helloGreeter ! WhoToGreet("Scala") helloGreeter ! Greet goodDayGreeter ! WhoToGreet("Play") goodDayGreeter ! Greet //#main-send-messages } //#main-class //#full-example
看起来官方的demo挺眼花缭乱的,但是它是入门akka的demo,为了说明akka的工作机制已经写得相对明了了,由于akka也是基于scala语言实现的所以我选择scala语言的实现的例子,同时熟悉一下scala的用法。
首先这个类我们从akka官网下载之后,解压然后复制到我们的idea工具中,运行一下,这里可能会运行失败,有可能是pom文件引用的版本不对,例如我的scala SDK版本是scala-sdk-2.11.8,而pom中引用的akka是 akka-actor_2.12
<dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-actor_2.12</artifactId> <version>2.5.18</version> </dependency>
这里把2.12改为2.11重新运行就可以了。
运行结果如下:
[INFO] [11/22/2018 16:30:33.678] [helloAkka-akka.actor.default-dispatcher-5] [akka://helloAkka/user/printerActor] Greeting received (from Actor[akka://helloAkka/user/goodDayGreeter#1309545673]): Good day, Play [INFO] [11/22/2018 16:30:33.678] [helloAkka-akka.actor.default-dispatcher-5] [akka://helloAkka/user/printerActor] Greeting received (from Actor[akka://helloAkka/user/helloGreeter#-1160926357]): Hello, Scala [INFO] [11/22/2018 16:30:33.678] [helloAkka-akka.actor.default-dispatcher-5] [akka://helloAkka/user/printerActor] Greeting received (from Actor[akka://helloAkka/user/howdyGreeter#-1887433215]): Howdy, Akka [INFO] [11/22/2018 16:30:33.678] [helloAkka-akka.actor.default-dispatcher-5] [akka://helloAkka/user/printerActor] Greeting received (from Actor[akka://helloAkka/user/howdyGreeter#-1887433215]): Howdy, Lightbend
那么实例代码到底做了什么事情呢?
1,main class创建了一个ActorSystem,等等,main class从何而来,我们来看:
object AkkaQuickstart extends App
这里继承了App,这个App是trait修饰的scala对象,trait的意思是特征在scala中相当于java中interface,但是它功能更加强大可以定义方法的实现。在App中正是定义了main方法,启动的时候就会找到这个main方法进行执行。
ActorSystem:刚才说创建了一个ActorSystem,它是一个容器里面装了一堆actor,是actor的运行空间。
2,创建了一个printer actor和三个greeter actor
//#create-actors // Create the printer actor val printer: ActorRef = system.actorOf(Printer.props, "printerActor") // Create the 'greeter' actors val howdyGreeter: ActorRef = system.actorOf(Greeter.props("Howdy", printer), "howdyGreeter") val helloGreeter: ActorRef = system.actorOf(Greeter.props("Hello", printer), "helloGreeter") val goodDayGreeter: ActorRef = system.actorOf(Greeter.props("Good day", printer), "goodDayGreeter") //#create-actors
这里给出的是创建actor的方法,解释一下第一步有了ActorSystem,第二步就是用它来创建actor,有点类似spring容器初始化注入的java类,通过actorOf方法创建,这里注意一下这个props。
Props:它是一个配置类,用于指定创建actor的选项标志,相当于一个工厂类,生产actor同时给actor起个名字贴个标签。
我们注意到创建printer actor与greeter actor不太一样,这里的不一样是用了不同的创建actor的方法,其中:
val howdyGreeter: ActorRef = system.actorOf(Greeter.props("Howdy", printer), "howdyGreeter")
这里是为了将printer和要传递的信息通过构造器参数传给了正在创建的howdyGreeter actor,因为后续的调用需要用到printer的打印日志方法,可以看到Greeter的定义如下:
class Greeter(message: String, printerActor: ActorRef) extends Actor { import Greeter._ import Printer._ var greeting = "" def receive = { case WhoToGreet(who) => greeting = message + ", " + who case Greet => //#greeter-send-message printerActor ! Greeting(greeting) //#greeter-send-message } }
它直接是带构造参数进行创建的。
3,开始发送消息,发送消息流程如下:
具体看一下代码:
howdyGreeter ! WhoToGreet("Akka") howdyGreeter ! Greet
首先,!是个什么鬼?点进去看一下:
def !(message : scala.Any)(implicit sender : akka.actor.ActorRef = { /* compiled code */ }) : scala.Unit
可以看到是akka定义的一个方法,用于使用sender发送消息,也相当于调用方法,这里调用的是WhoToGreet("Akka"),在Greeter中定义了receive方法,接收sender的发送消息:
def receive = { case WhoToGreet(who) => greeting = message + ", " + who case Greet => //#greeter-send-message printerActor ! Greeting(greeting) //#greeter-send-message }
这里收到了WhoToGreet,然后greeting= message +“,”+"Akka",message是什么?就是在创造actor的时候通过构造器传入的参数,因此组合成为:greeting= “Howdy”+“,”+"Akka".
接下来调用howdyGreeter ! Greet,内部则是通过传入的printer的actor进行打印日志,整个流程就是如上图显示的调用过程。
相关推荐
- RACI矩阵:项目管理中的角色与责任分配利器
-
作者:赵小燕RACI矩阵RACI矩阵是项目管理中的一种重要工具,旨在明确团队在各个任务中的角色和职责。通过将每个角色划分为负责人、最终责任人、咨询人和知情人四种类型,RACI矩阵确保每个人都清楚自己...
- 在弱矩阵组织中,如何做好项目管理工作?「慕哲制图」
-
慕哲出品必属精品系列在弱矩阵组织中,如何做好项目管理工作?【慕哲制图】-------------------------------慕哲制图系列0:一图掌握项目、项目集、项目组合、P2、商业分析和NP...
- Scrum模式:每日站会(Daily Scrum)
-
定义每日站会(DailyScrum)是一个Scrum团队在进行Sprint期间的日常会议。这个会议的主要目的是为了应对Sprint计划中的不断变化,确保团队能够有效应对挑战并达成Sprint目标。为...
- 大家都在谈论的敏捷开发&Scrum,到底是什么?
-
敏捷开发作为一种开发模式,近年来深受研发团队欢迎,与瀑布式开发相比,敏捷开发更轻量,灵活性更高,在当下多变环境下,越来越多团队选择敏捷开发。什么是敏捷?敏捷是一种在不确定和变化的环境中,通过创造和响应...
- 敏捷与Scrum是什么?(scrum敏捷开发是什么)
-
敏捷是一种思维模式和哲学,它描述了敏捷宣言中的一系列原则。另一方面,Scrum是一个框架,规定了实现这种思维方式的角色,事件,工件和规则/指南。换句话说,敏捷是思维方式,Scrum是规定实施敏捷哲学的...
- 敏捷项目管理与敏捷:Scrum流程图一览
-
敏捷开发中的Scrum流程通常可以用一个简单的流程图来表示,以便更清晰地展示Scrum框架的各个阶段和活动。以下是一个常见的Scrum流程图示例:这个流程图涵盖了Scrum框架的主要阶段和活动,其中包...
- Mockito 的最佳实践(mock方法)
-
记得以前面试的时候,面试官问我,平常开发过程中自己会不会测试?我回答当然会呀,自己写的代码怎么不测呢。现在想想我好像误会他的意思了,他应该是想问我关于单元测试,集成测试以及背后相关的知识,然而当时说到...
- EffectiveJava-5-枚举和注解(java枚举的作用与好处)
-
用enum代替int常量1.int枚举:引入枚举前,一般是声明一组具名的int常量,每个常量代表一个类型成员,这种方法叫做int枚举模式。int枚举模式是类型不安全的,例如下面两组常量:性别和动物种...
- Maven 干货 全篇共:28232 字。预计阅读时间:110 分钟。建议收藏!
-
Maven简介Maven这个词可以翻译为“知识的积累”,也可以翻译为“专家”或“内行”。Maven是一个跨平台的项目管理工具。主要服务于基于Java平台的项目构建、依赖管理和项目信息管理。仔...
- Java单元测试框架PowerMock学习(java单元测试是什么意思)
-
前言高德的技术大佬在谈论方法论时说到:“复杂的问题要简单化,简单的问题要深入化。”这句话让我感触颇深,这何尝不是一套编写代码的方法——把一个复杂逻辑拆分为许多简单逻辑,然后把每一个简单逻辑进行深入实现...
- Spring框架基础知识-第六节内容(Spring高级话题)
-
Spring高级话题SpringAware基本概念Spring的依赖注入的最大亮点是你所有的Bean对Spring容器的存在是没有意识的。但是在实际的项目中,你的Bean必须要意识到Spring容器...
- Java单元测试浅析(JUnit+Mockito)
-
作者:京东物流秦彪1.什么是单元测试(1)单元测试环节:测试过程按照阶段划分分为:单元测试、集成测试、系统测试、验收测试等。相关含义如下:1)单元测试:针对计算机程序模块进行输出正确性检验工作...
- 揭秘Java代码背后的质检双侠:JUnit与Mockito!
-
你有没有发现,现在我们用的手机App、逛的网站,甚至各种智能设备,功能越来越复杂,但用起来却越来越顺畅,很少遇到那种崩溃、卡顿的闹心事儿?这背后可不是程序员一拍脑袋写完代码就完事儿了!他们需要一套严谨...
- 单元测试框架哪家强?Junit来帮忙!
-
大家好,在前面的文章中,给大家介绍了以注解和XML的方式分别实现IOC和依赖注入。并且我们定义了一个测试类,通过测试类来获取到了容器中的Bean,具体的测试类定义如下:@Testpublicvoid...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- 框架图 (58)
- flask框架 (53)
- quartz框架 (51)
- abp框架 (47)
- jpa框架 (47)
- springmvc框架 (49)
- 分布式事务框架 (65)
- scrapy框架 (56)
- shiro框架 (61)
- 定时任务框架 (56)
- java日志框架 (61)
- JAVA集合框架 (47)
- mfc框架 (52)
- abb框架断路器 (48)
- ui自动化框架 (47)
- beego框架 (52)
- java框架spring (58)
- grpc框架 (65)
- ppt框架 (48)
- 内联框架 (52)
- cad怎么画框架 (58)
- ps怎么画框架 (47)
- ssm框架实现登录注册 (49)
- oracle字符串长度 (48)
- oracle提交事务 (47)