Akka

Akka是什么呢?直接引用Akka站点上面的描写叙述吧:

Akka is a toolkit and runtime for building highly concurrent, distributed, and fault tolerant event-driven applications on the JVM.

反正我认为Akka是比較难上手的,并且文档对于新手来说,也不太友好。本文会用Akka写一个Hello World程序,从这个程序入手,介绍Akka的一些基本概念。

hello-world-java8项目

Akka同一时候提供了Java版和Scala版,本文的HelloWorld项目将使用Java版。该项目是我用NetBeans创建的Gradle项目,而且放到了Github上面。由于是HelloWorld项目,所以非常easy,仅仅有两个类,例如以下图所看到的:

build.gradle

先介绍一下build脚本:

假设脚本看起来比較吃力,能够先看看我写的“看懂Gradle脚本”系列文章。前面没什么好解释的,可是依赖部分我认为有必要说明一下。我们的HelloWorld项目仅仅依赖了两个库,各自是scalaactor。Akka主要是用Scala语言写的,所以须要依赖Scala。而Akka本身很的模块化,HelloWorld项目仅仅用到了Actor模块,所以声明了对Actor的依赖。注意Akka的模块名包括了Scala版本:akka-actor-_2.11,所以2.3.6才是actor模块的真正版本。

MyActor

Akka的核心就是Actor模型,所以我们的HelloWorld自然要定义一个Actor:

MyActor继承自UntypedActor(与之相应的是TypedActor,但我们还没有足够的知识来讨论两者的差别),UntypedActor是个抽象类,我们必须实现onReceive()方法。

信箱

在Actor的世界里,Actor们是通过消息相互沟通的。每一个Actor都有一个信箱Mailbox),能够接收消息,然后一个个处理。但这些细节Akka都帮我们处理好了,我们的Actor要做的,就是实现onReceive()方法,然后每次处理一条消息。如上面的代码所看到的,MyActor处理消息的方式是:把它打印到控制台。

Main

HelloWorld的第二个类是Main,也就是程序主类,例如以下所看到的:

ActorSystem

从概念上讲,n个相互协作的Actor组成一个系统,Akka提供了ActorSystem类来抽象Actor系统:

main()方法的第一行代码创建了一个Actor系统,并起名为mySystem:

ActorSystem mySystem = ActorSystem.create("mySystem");

ActorRef

整个Actor系统是非常封闭的,Actor们从来不直接和外界接触,它们把这样的危急的事情交给自己的“经纪人”ActorRef去做。main()方法的第二行代码调用ActorSystem的actorOf()方法创建了一个名为myActor的Actor:

ActorRef myActor = mySystem.actorOf(Props.create(MyActor.class), "myActor");

到眼下为止,我们的Actor系统仅仅有一个Actor,例如以下图所看到的:

发消息,关闭Actor系统

main()方法的第三行代码通过ActorRef的tell()方法给myActor发了一个消息:

myActor.tell("Hello, World!", ActorRef.noSender());

tell()方法是异步的,它仅仅给Actor的邮箱放一封邮件,然后就返回了。tell()方法的第一个參数是消息,第二个參数是发送者,这样,接收者Actor就知道是谁给自己发的消息了。MyActor并不关心消息是谁发送的,所以我们给它传了ActorRef.noSender()。main()方法的第四行代码调用ActorSystem的shutdown()方法,通知Actor系统终止自己:

mySystem.shutdown();

这就是所有的代码,执行程序,能够看到控制台里打印出了我们期待已久的Hello, World!

结论

本文用Akka创建了一个HelloWorld项目,介绍了Akka的一些基本概念。下篇文章将用Akka创建一个EchoServer,介绍一下怎样用Akka处理TCP协议。

最新文章

  1. 关于C#消息调度(作业日志)
  2. XPath 运算符
  3. KnockoutJS 3.X API 第四章 数据绑定(5) 控制流component绑定
  4. 阿里云消息队列MQ_HTTP接入 for .NetCore 简单例子
  5. java 和 mysql 获取周 星期 的第一天 最后一天 或者 月的 日期(字符串转日期,日期转字符串,日期加减)
  6. ie textarea不支持maxlength textarea限制长度
  7. Android程序检测网络是否可用
  8. 用标准Struts2+mvc写的用户管理
  9. css3简单几步画一个乾坤图
  10. Redis系统学习 三、使用数据结构
  11. 眼睛跟踪 java
  12. EntityFramework6与EntityFrameworkCore的区别
  13. JS CKEditor使用setData后绑定click事件
  14. [Swift]LeetCode902. 最大为 N 的数字组合 | Numbers At Most N Given Digit Set
  15. JavaScript Concurrency model and Event Loop 并发模型和事件循环机制
  16. python之路——19
  17. MongoDB下Map-Reduce使用简单翻译及示例
  18. NIO之缓冲区
  19. 给本地服务器配置py文件的下载功能
  20. Java泛型方法与数据查询

热门文章

  1. tensorflow 下的滑动平均模型 —— tf.train.ExponentialMovingAverage
  2. linux下查看动态链接库依赖关系的命令 x86: ldd *.so arm: arm-linux-readelf -d *.so 实际例子: 以项目中用到的库librtsp.so分析: lijun@ubuntu:~/workspace$ arm-hisiv100nptl-linux-ld -d librtsp.so arm-hisiv100nptl-linux-ld:
  3. FastSocket学习笔记~RPC的思想,面向对象的灵活
  4. POJ 2363 Blocks (ZOJ 1910) 数学
  5. [outlook] [vba] Highlight text in body of incoming emails
  6. [RxJS] Multicast with a selector argument, as a sandbox
  7. php实现旋转数组的最小数字
  8. 移动web处理input输入框输入银行卡号四位一空格
  9. 【47.40%】【codeforces 743B】Chloe and the sequence
  10. Activity 调用Service的方法