spark版本裡面用到的就是akka通訊,2.0版本 已經不再使用akka了。這裡寫了乙個簡單的akka程式。
首先定義2個訊息類
object myrequest
object myresponse
定義2個通訊的actor
class student(teacherref:actorref) extends actor
case myresponse =>
}}
class teacher extends actor
}}
定義執行的主函式
object mymain
}
執行結果如下:
[info] [10/25/2016 17:24:49.710] [hellosystem-akka.actor.default-dispatcher-3] [akka://hellosystem/user/mystudent] 這是我的郵件 請teacher查收
[info] [10/25/2016 17:24:49.710] [hellosystem-akka.actor.default-dispatcher-2] [akka://hellosystem/user/myteacher] teacher已經收到資訊==這是我的郵件 請teacher查收
[info] [10/25/2016 17:24:49.710] [hellosystem-akka.actor.default-dispatcher-2] [akka://hellosystem/user/mystudent] ok ,i get it
AKKA快速入門
akka的優點太多,高效能 高可靠 高併發 分布式 可容錯 可擴充套件 事件驅動,不一一敘述。不同版本的api差異很大,本文 執行在 scala 2.10.3 和 akka 2.3.2 之上。com.typesafe.akkagroupid akka actor 2.10artifactid 2.3...
Akka 快速入門
akka的優點太多,高效能 高可靠 高併發 分布式 可容錯 可擴充套件 事件驅動,不一一敘述。不同版本的api差異很大,本文 執行在 scala 2.10.3 和 akka 2.3.2 之上。com.typesafe.akkagroupid akka actor 2.10artifactid 2.3...
spring超級簡單入門例子
首先是乙個名叫action的介面定義了乙個execute 方法 package net.xiaxin.spring.qs public inte ce action實現類loweraction package net.xiaxin.spring.qs public class loweraction...