akka简单示例

 1 [torstan@sparkb5-i ~/akka_example/hello_world]$ cat src/helloWorld.scala 
 2 package our.examples
 3 import akka.actor.Actor
 4 import akka.actor.ActorSystem
 5 import akka.actor.Props
 6  
 7 class HelloActor extends Actor {
 8   def receive = {
 9     case "hello" => println("hello back at you")
10     case _       => println("huh?")
11   }
12 }
13  
14 object HelloApp extends App {
15         override def main(args: Array[String]){
16                 val system = ActorSystem("HelloSystem")
17                         // default Actor constructor
18                         val helloActor = system.actorOf(Props[HelloActor], name = "helloactor")
19                         helloActor ! "hello"
20                         helloActor ! "buenos dias"
21         }
22 }

 1 [torstan@sparkb5-i ~/akka_example/hello_world]$ cat Makefile 
 2 SRC_DIR := src
 3 SRC := $(shell find ${SRC_DIR} -name "*.scala")
 4 DIR=our
 5 
 6 TARGET := HelloApp.jar
 7 
 8 SCALAC := scalac 
 9 SCFLAGS := /usr/local/scala-2.10.4/lib/akka-actors.jar  
10 
11 .PHONY: all clean
12 
13 all: ${TARGET}
14 
15 ${TARGET}: ${SRC}
16         ${SCALAC} -cp ${SCFLAGS} $^
17 
18 clean:
19         ${RM} -r ${TARGET} ${DIR}

1 [torstan@sparkb5-i ~/akka_example/hello_world]$ cat run.sh 
2 #!/bin/bash
3 
4 
5 java -cp 6  .:/usr/local/scala-2.10.4/lib/scala-library.jar:/usr/local/scala-2.10.4/lib/akka-actors.jar:/usr/local/scala-2.10.4/lib/typesafe-config.jar7   our.examples.HelloApp

 1 [torstan@sparkb5-i ~/akka_example/remote_service/server]$ cat src/HelloRemote.scala 
 2 package remote
 3 import akka.actor.Actor
 4 import akka.actor.ActorSystem
 5 import akka.actor.Props
 6 
 7 class RemoteActor extends Actor{
 8         def receive = {
 9                 case msg:String =>
10                         println(s"RemoteActor received message ‘$msg‘")
11                         sender ! "hello from RemoteActor"
12         }
13 }
14 
15 object HelloRemote extends App{
16         val system = ActorSystem("HelloRemoteSystem")
17         val remoteActor = system.actorOf(Props[RemoteActor], name="RemoteActor")
18         remoteActor ! "The remote actor is alive"
19 }

 1 [torstan@sparkb5-i ~/akka_example/remote_service/server]$ cat application.conf 
 2 akka {
 3   loglevel = "DEBUG"
 4   actor {
 5     provider = "akka.remote.RemoteActorRefProvider"
 6    }
 7    remote {
 8      transport = "akka.remote.netty.NettyRemoteTransport"
 9      //log-sent-messages = on
10      //log-received-messages = on
11      netty {
12        hostname = "127.0.0.1"
13        port = 5150
14      }
15    }
16 }

 1 [torstan@sparkb5-i ~/akka_example/remote_service/server]$ cat Makefile 
 2 SRC_DIR := src
 3 SRC := $(shell find ${SRC_DIR} -name "*.scala")
 4 DIR=remote
 5 
 6 TARGET := HelloRemote.jar
 7 
 8 SCALAC := scalac 
 9 SCFLAGS := /usr/local/scala-2.10.4/lib/akka-actors.jar  
10 
11 .PHONY: all clean
12 
13 all: ${TARGET}
14 
15 ${TARGET}: ${SRC}
16         ${SCALAC} -cp ${SCFLAGS} $^
17 
18 clean:
19         ${RM} -r ${TARGET} ${DIR}

1 [torstan@sparkb5-i ~/akka_example/remote_service/server]$ cat run.sh 
2 #!/bin/bash
3 
4 AKKA_LIB_PATH="/usr/local/akka-2.1.4/lib/akka/"
5 
6 java -cp 7  .:/usr/local/scala-2.10.4/lib/scala-library.jar:/usr/local/scala-2.10.4/lib/akka-actors.jar:/usr/local/scala-2.10.4/lib/typesafe-config.jar:${AKKA_LIB_PATH}/akka-remote_2.10-2.1.4.jar:${AKKA_LIB_PATH}/protobuf-java-2.4.1.jar:${AKKA_LIB_PATH}/netty-3.5.8.Final.jar 8  remote.HelloRemote

 1 [torstan@sparkb5-i ~/akka_example/remote_service/client]$ cat src/HelloLocal.scala 
 2 package client 
 3 import akka.actor._
 4 
 5 object HelloLocal extends App{
 6         implicit val system = ActorSystem("LocalSystem")
 7         val localActor = system.actorOf(Props[LocalActor], name="LocalActor")
 8         localActor ! "START"
 9 }
10 
11 class LocalActor extends Actor{
12         val remote = context.actorFor("akka://HelloRemoteSystem@172.27.6.240:5150/user/RemoteActor")
13         var counter = 0
14         def receive = {
15                 case "START" =>
16                         remote ! "HELLO from the LocalActor"
17                 case msg:String =>
18                         println(s"LocalActor received message: ‘$msg‘")
19                         if(counter < 5){
20                                 sender ! "hello back to you"
21                                 counter += 1
22                         }
23         }
24 }

 1 [torstan@sparkb5-i ~/akka_example/remote_service/client]$ cat application.conf 
 2 akka {
 3   //loglevel = "DEBUG"
 4   actor {
 5     provider = "akka.remote.RemoteActorRefProvider"
 6   }
 7   remote {
 8     transport = "akka.remote.netty.NettyRemoteTransport"
 9     //log-sent-messages = on
10     //log-received-messages = on
11     netty {
12       hostname = "127.0.0.1"
13       port = 0
14     }
15   }
16 }

 1 [torstan@sparkb5-i ~/akka_example/remote_service/client]$ cat Makefile 
 2 SRC_DIR := src
 3 SRC := $(shell find ${SRC_DIR} -name "*.scala")
 4 DIR=client
 5 
 6 TARGET := HelloLocal.jar
 7 
 8 SCALAC := scalac 
 9 SCFLAGS := /usr/local/scala-2.10.4/lib/akka-actors.jar  
10 
11 .PHONY: all clean
12 
13 all: ${TARGET}
14 
15 ${TARGET}: ${SRC}
16         ${SCALAC} -cp ${SCFLAGS} $^
17 
18 clean:
19         ${RM} -r ${TARGET} ${DIR}

1 [torstan@sparkb5-i ~/akka_example/remote_service/client]$ cat run.sh 
2 #!/bin/bash
3 
4 AKKA_LIB_PATH="/usr/local/akka-2.1.4/lib/akka/"
5 
6 java -cp 7  .:/usr/local/scala-2.10.4/lib/scala-library.jar:/usr/local/scala-2.10.4/lib/akka-actors.jar:/usr/local/scala-2.10.4/lib/typesafe-config.jar:${AKKA_LIB_PATH}/akka-remote_2.10-2.1.4.jar:${AKKA_LIB_PATH}/protobuf-java-2.4.1.jar:${AKKA_LIB_PATH}/netty-3.5.8.Final.jar 8  client.HelloLocal