首页 > 代码库 > akka简单示例
akka简单示例
刚刚开始接触akka，网上找了2个简单示例，并在公司运营机器上尝试，踩了一些坑，在此记录。
1. 本地hello world
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 constructor18 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 clean12 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/bash3 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
执行结果：
[torstan@sparkb5-i ~/akka_example/hello_world]$ ./run.sh
hello back at you
huh?
2. 简单CS示例
server端：
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 = on10 //log-received-messages = on11 netty {12 hostname = "127.0.0.1"13 port = 515014 }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 clean12 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/bash3 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
client端：
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 = 014 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 += 122 }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 = on10 //log-received-messages = on11 netty {12 hostname = "127.0.0.1"13 port = 014 }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 clean12 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/bash3 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
执行结果：
[root@sparkb5-0 /data/torstan/akka_example/remote_service/server]# ./run.sh
[DEBUG] [12/10/2014 17:31:57.074] [main] [EventStream(akka://HelloRemoteSystem)] logger log1-Logging$DefaultLogger started
[DEBUG] [12/10/2014 17:31:57.080] [main] [EventStream(akka://HelloRemoteSystem)] Default Loggers started
[INFO] [12/10/2014 17:31:57.269] [main] [NettyRemoteTransport(akka://HelloRemoteSystem@172.27.6.240:5150)] RemoteServerStarted@akka://HelloRemoteSystem@172.27.6.240:5150
RemoteActor received message ‘The remote actor is alive‘
[INFO] [12/10/2014 17:32:01.768] [HelloRemoteSystem-10] [NettyRemoteTransport(akka://HelloRemoteSystem@172.27.6.240:5150)] RemoteClientStarted@akka://LocalSystem@127.0.0.1:48437
[DEBUG] [12/10/2014 17:32:01.769] [HelloRemoteSystem-10] [RemoteClient(akka://HelloRemoteSystem)] Starting remote client connection to [akka://LocalSystem@127.0.0.1:48437]
[DEBUG] [12/10/2014 17:32:01.771] [HelloRemoteSystem-10] [NettyRemoteTransport(akka://HelloRemoteSystem@172.27.6.240:5150)] RemoteServerClientConnected@akka://HelloRemoteSystem@172.27.6.240:5150: Client[akka://LocalSystem@127.0.0.1:48437]
RemoteActor received message ‘HELLO from the LocalActor‘
[DEBUG] [12/10/2014 17:32:01.782] [HelloRemoteSystem-akka.actor.default-dispatcher-2] [akka.serialization.Serialization(akka://HelloRemoteSystem)] Using serializer[akka.serialization.JavaSerializer] for message [java.lang.String]
RemoteActor received message ‘hello back to you‘
RemoteActor received message ‘hello back to you‘
RemoteActor received message ‘hello back to you‘
RemoteActor received message ‘hello back to you‘
RemoteActor received message ‘hello back to you‘
[torstan@sparkb5-i ~/akka_example/remote_service/client]$ ./run.sh
[INFO] [12/10/2014 17:32:01.668] [main] [NettyRemoteTransport(akka://LocalSystem@127.0.0.1:48437)] RemoteServerStarted@akka://LocalSystem@127.0.0.1:48437
[INFO] [12/10/2014 17:32:01.755] [LocalSystem-akka.actor.default-dispatcher-3] [NettyRemoteTransport(akka://LocalSystem@127.0.0.1:48437)] RemoteClientStarted@akka://HelloRemoteSystem@172.27.6.240:5150
LocalActor received message: ‘hello from RemoteActor‘
LocalActor received message: ‘hello from RemoteActor‘
LocalActor received message: ‘hello from RemoteActor‘
LocalActor received message: ‘hello from RemoteActor‘
LocalActor received message: ‘hello from RemoteActor‘
LocalActor received message: ‘hello from RemoteActor‘
遇到的坑：
[torstan@sparkb5-i ~/akka_example/remote_service/client]$ ./run.sh
Exception in thread "main" java.lang.ClassNotFoundException: akka.remote.RemoteActorRefProvider
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:270)
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor$1.apply(DynamicAccess.scala:68)
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor$1.apply(DynamicAccess.scala:67)
at scala.util.Try$.apply(Try.scala:161)
google到答案是没有加载依赖文件akka-remote.jar，后来发现是没有安装akka。
2. Exception in thread "main" java.lang.NoSuchMethodException: akka.remote.RemoteActorRefProvider.<init>(java.lang.String, akka.actor.ActorSystem$Settings, akka.event.EventStream, akka.actor.Scheduler, akka.actor.DynamicAccess
google到答案：
akka简单示例