介紹akka之前需要簡單說一下Scala，Scala號稱下一代jvm語言，

集成了Java的面向物件，以及函數語言程式設計於一體，異常強大，但也複雜，此文不作爭論，姑且簡單介紹。

Akka框架是基於scala以及少量java程式碼實現的，Scala從其2.11.0版本起將自有的底層actor庫替換成了akka，可見akka的強大。

Akka官網的自吹：

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

Akka同時提供了Java和Scala兩種API介面，下面就Java介面為例簡單介紹一下。

ØActor表示

²publicclassGreetingimplementsSerializable {

²publicfinalString who;

²publicGreeting(String who) { this.who = who; }

²}

²

²publicclassGreetingActorextendsUntypedActor {

²LoggingAdapter log = Logging.getLogger(getContext().system(), this

²

²publicvoid onReceive(Object message) throwsException {

²if (message instanceofGreeting)

²      log.info("Hello " + ((Greeting) message).who);

²  }

²}

²

²ActorSystem system = ActorSystem.create("MySystem");

²ActorRef greeter = system.actorOf(Props.create(GreetingActor.class), "greeter"

²greeter.tell(newGreeting("Charlie Parker"), ActorRef.noSender());

繼承UntypeActor可以定義一個actor角色的類，其中的onReceive方法可以接受來自其他actor傳遞過來的訊息

ActorSystem類負責建立最頂層的actor，其負責管理整個系統中actors監控樹。

Ø分散式

ActorSystem system = ActorSystem.create("MySystem");

//獲取機器2上面的一個actor：greeter

ActorSelection greeter = system.actorSelection("akka.tcp://[email protected]:2552/user/greeter");

// 向上面的actor傳送訊息,Greeting表示訊息

greeter.tell(newGreeting("Sonny Rollins"), ActorRef.noSender());

上面的幾行程式碼簡單展示了akka中的分散式環境中不同機器節點之間actor的相互通訊方式，可以看出和Erlang很類似，即遮蔽底層節點之間的通訊細節，然後提供簡單API介面。

Ø監控

classSupervisorextendsUntypedActor {

privateSupervisorStrategy strategy = newOneForOneStrategy(

10, Duration.create("1 minute"), newFunction<Throwable, Directive>() {

@Override

publicDirective apply(Throwable t) {

if (t instanceofArithmeticException) return resume();

elseif (t instanceofNullPointerException) return restart();

elsereturn escalate();

      }

    });

@Override

publicSupervisorStrategy supervisorStrategy() {

return strategy;

  }

ActorRef worker = context.actorOf(Props.create(Worker.class));

publicvoid onReceive(Object message) throwsException {

if (message instanceofInteger) worker.forward(message, getContext());

  }

}

上面程式碼定義了一個監控角色的actor，可以看到其也是繼承與UntypeActor，因為監控者變身也是一個actor，其變身也可以被監控。與普通工作actor不同的是，其定義了監控策略SupervisorStrategy，負責處理子actor的重啟、停止工作。