啟動程序：

package com.zxl.akka.two_actorsimport akka.actor.{ActorRef, ActorSystem, Props}//extends App 可以替代main方法 object ActorGame extends App { //創(chuàng)建 ActorSystemval actorfactory = ActorSystem("actorfactory")//先創(chuàng)建 BActor 引用/代理val bActorRef: ActorRef = actorfactory.actorOf(Props[BActor], "bActor")//創(chuàng)建 AActor 的引用val aActorRef: ActorRef = actorfactory.actorOf(Props(new AActor(bActorRef)), "aActor")//aActor 出招aActorRef ! "start"}

AActor

package com.zxl.akka.two_actorsimport akka.actor.{Actor, ActorRef}class AActor(actorRef: ActorRef) extends Actor {val bActorRef: ActorRef = actorRefoverride def receive: Receive = {case "start" => {println("AActor 出招了 , start ok")self ! "我打" //發(fā)給自己}case "我打" => {//給 BActor 發(fā)出消息//這里需要持有 BActor 的引用(BActorRef)println("AActor(黃飛鴻) 厲害 看我佛山無影腳")Thread.sleep(1000)bActorRef ! "我打" //給 BActor 發(fā)出消息}} }

BActor

package com.zxl.akka.two_actorsimport akka.actor.Actorclass BActor extends Actor{override def receive:Receive = {case "我打" => {println("BActor(喬峰) 挺猛 看我降龍十八掌")Thread.sleep(1000)//通過 sender() 可以獲取到發(fā)現(xiàn)消息的 actor 的 refsender() ! "我打"}} }

pom

<project xmlns = "http://maven.apache.org/POM/4.0.0"xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd"><!-- 模型版本 --><modelVersion>4.0.0</modelVersion><!-- 公司或者組織的唯一標志，并且配置時生成的路徑也是由此生成， 如com.companyname.project-group，maven會將該項目打成的jar包放本地路徑：/com/zxl/akka --><groupId>com.zxl.akka</groupId><!-- 項目的唯一ID，一個groupId下面可能多個項目，就是靠artifactId來區(qū)分的 --><artifactId>akka-hello</artifactId><!-- 版本號 --><version>1.0</version><properties><scala.version>2.11.8</scala.version><scala.compat.version>2.11</scala.compat.version><akka.version>2.4.17</akka.version><encoding>UTF-8</encoding></properties><dependencies><!-- scala的依賴 --><dependency><groupId>org.scala-lang</groupId><artifactId>scala-library</artifactId><version>${scala.version}</version></dependency><!-- akka actor --><dependency><groupId>com.typesafe.akka</groupId><artifactId>akka-actor_${scala.compat.version}</artifactId><version>${akka.version}</version></dependency><!-- 多進程之間akka通信 --><dependency><groupId>com.typesafe.akka</groupId><artifactId>akka-remote_${scala.compat.version}</artifactId><version>${akka.version}</version></dependency></dependencies><build><sourceDirectory>src/main/scala</sourceDirectory><plugins><plugin><groupId>net.alchim31.maven</groupId><artifactId>scala-maven-plugin</artifactId><version>3.2.2</version><executions><execution><goals><goal>compile</goal><goal>testCompile</goal></goals><configuration><args><arg>-dependencyfile</arg><arg>${project.build.directory}/.scala_dependencies</arg></args></configuration></execution></executions></plugin><!-- 使用maven-assembly-plugin打包成可執(zhí)行的jar --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-assembly-plugin</artifactId><executions><execution><phase>package</phase><goals><goal>single</goal></goals><configuration><archive><manifest><mainClass>com.zxl.akka.two_actors.ActorGame</mainClass></manifest></archive><descriptorRefs><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration></execution></executions></plugin></plugins></build></project>

總結(jié)

以上是生活随笔為你收集整理的【完整代码】Scala AKKA实现两个Actor之间的通信代码示例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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