主要內(nèi)容：
1. Typed Actor定義
2. Typed Actor創(chuàng)建
3. 消息發(fā)送

1. Typed Actor定義

Akka中的Typed Actor是Active Objects設(shè)計模式的實現(xiàn)，Active Objects模式將方法的執(zhí)行和方法的調(diào)用進(jìn)行解耦合，從而為程序引入并發(fā)性。Typed Actor由公用的接口和對應(yīng)實現(xiàn)兩部分構(gòu)成，其后面深層次的實現(xiàn)使用的是代理模式，即通過使用JDK中的動態(tài)代理來實現(xiàn)，在調(diào)用接口的方法時自動分發(fā)到實現(xiàn)接口的對象上。Typed Actor的定義[ ]如下所示。

trait Squarer {//fire-and-forget消息def squareDontCare(i: Int): Unit//非阻塞send-request-reply消息def square(i: Int): Future[Int]//阻塞式的send-request-reply消息def squareNowPlease(i: Int): Option[Int]//阻塞式的send-request-reply消息def squareNow(i: Int): Int}class SquarerImpl(val name: String) extends Squarer {def this() = this("SquarerImpl")def squareDontCare(i: Int): Unit = i * idef square(i: Int): Future[Int] = Promise.successful(i * i).futuredef squareNowPlease(i: Int): Option[Int] = Some(i * i)def squareNow(i: Int): Int = i * i}

trait Squarer中定義了4個方法：
（1）def squareDontCare(i: Int): Unit方法：返回值類型為Unit，它類似于Untyped Actor中的fire-and-forget消息發(fā)送模型，即！和tell方法調(diào)用。
（2）def square(i: Int): Future[Int]：返回值類型為Future[Int]，它類似于Untyped Actor中的send-request-reply消息發(fā)送模型，即?和ask方法調(diào)用，此種調(diào)用是非阻塞的。
（3）def squareNowPlease(i: Int): Option[Int]：返回值類型為Option[Int]（Option類可以是Scala.Option[_]也可以是akka.japi.Option

2. 創(chuàng)建Typed Actor

通過下列代碼創(chuàng)建Typed Actor實例。

//直接通過默認(rèn)的構(gòu)造函數(shù)創(chuàng)建Typed Actor val mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl]()) //直接通過默認(rèn)的構(gòu)造函數(shù)創(chuàng)建Typed Actor并指定Typed Actor名稱 val mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl](),"mySquarer") //通過非默認(rèn)的構(gòu)造函數(shù)創(chuàng)建Typed Actor并指定Typed Actor名稱 val otherSquarer: Squarer = TypedActor(system).typedActorOf(TypedProps(classOf[Squarer],new SquarerImpl("SquarerImpl")), "otherSquarer")

上面代碼演示的是使用構(gòu)造函數(shù)和非默認(rèn)構(gòu)造函數(shù)創(chuàng)建Typed Actor，其中Squarer為代理的類型，SquarerImpl為具體實現(xiàn)的類型。

3. 消息發(fā)送

//fire-forget消息發(fā)送mySquarer.squareDontCare(10)//send-request-reply消息發(fā)送val oSquare = mySquarer.squareNowPlease(10)val iSquare = mySquarer.squareNow(10)//Request-reply-with-future 消息發(fā)送val fSquare = mySquarer.square(10)val result = Await.result(fSquare, 5 second)

代碼mySquarer.squareDontCare(10)是單向消息發(fā)送，方法將在另外一個線程上異步地執(zhí)行；val oSquare = mySquarer.squareNowPlease(10)、val iSquare = mySquarer.squareNow(10)為Request-reply消息發(fā)送，在特定時間內(nèi)以阻塞的方式執(zhí)行，對于.squareNowPlease(10)方法如果在對應(yīng)時間內(nèi)沒有返回結(jié)果則返回值為None，否則返回值為Option[Int]類型，對于squareNow(10)方法如果在對應(yīng)時間內(nèi)無返回值則會拋出異常Java.util.concurrent.TimeoutException，否則返回Int類型值；val fSquare = mySquarer.square(10)為Request-reply-with-future式的消息發(fā)送，以非阻塞的方式執(zhí)行，可以通過val result = Await.result(fSquare, 5 second)獲取執(zhí)行結(jié)果。完整代碼如下所示。

/** Typed Actor*/ object Example_01 extends App {import akka.event.Loggingimport scala.concurrent.{ Promise, Future }import akka.actor.{ TypedActor, TypedProps }import scala.concurrent.duration._trait Squarer {//fire-and-forget消息def squareDontCare(i: Int): Unit//非阻塞send-request-reply消息def square(i: Int): Future[Int]//阻塞式的send-request-reply消息def squareNowPlease(i: Int): Option[Int]//阻塞式的send-request-reply消息def squareNow(i: Int): Int}class SquarerImpl(val name: String) extends Squarer {def this() = this("SquarerImpl")def squareDontCare(i: Int): Unit = i * idef square(i: Int): Future[Int] = Promise.successful(i * i).futuredef squareNowPlease(i: Int): Option[Int] = Some(i * i)def squareNow(i: Int): Int = i * i}val system = ActorSystem("TypedActorSystem")val log = Logging(system, this.getClass)//使用默認(rèn)構(gòu)造函數(shù)創(chuàng)建Typed Actorval mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl](),"mySquarer")//使用非默認(rèn)構(gòu)造函數(shù)創(chuàng)建Typed Actorval otherSquarer: Squarer =TypedActor(system).typedActorOf(TypedProps(classOf[Squarer],new SquarerImpl("SquarerImpl")), "otherSquarer")//fire-forget消息發(fā)送mySquarer.squareDontCare(10)//send-request-reply消息發(fā)送val oSquare = mySquarer.squareNowPlease(10)log.info("oSquare="+oSquare)val iSquare = mySquarer.squareNow(10)log.info("iSquare="+iSquare)//Request-reply-with-future 消息發(fā)送val fSquare = mySquarer.square(10)val result = Await.result(fSquare, 5 second)log.info("fSquare="+result)system.shutdown() }

代碼運行結(jié)果如下：
[INFO] [03/21/2016 21:15:50.592] [main] [Example12_9(akka://TypedActorSystem)]oSquare=Some(100)[INFO][03/21/201621:15:50.649][main][Example129(akka://TypedActorSystem)] iSquare=100
[INFO] [03/21/2016 21:15:50.649] [main] [Example12_9$(akka://TypedActorSystem)] fSquare=100

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的Akka并发编程——第七节：Actor模型（六）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。