【完整代码】Scala AKKA实现两个Actor之间的通信代码示例

启动程序：

package com.zxl.akka.two_actorsimport akka.actor.{ActorRef, ActorSystem, Props}//extends App 可以替代main方法
object ActorGame extends App {  //创建 ActorSystemval actorfactory = ActorSystem("actorfactory")//先创建 BActor 引用/代理val bActorRef: ActorRef = actorfactory.actorOf(Props[BActor], "bActor")//创建 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 ! "我打" //发给自己}case "我打" => {//给 BActor 发出消息//这里需要持有 BActor 的引用(BActorRef)println("AActor(黄飞鸿) 厉害 看我佛山无影脚")Thread.sleep(1000)bActorRef ! "我打" //给 BActor 发出消息}}
}

BActor

package com.zxl.akka.two_actorsimport akka.actor.Actorclass BActor extends Actor{override def receive:Receive = {case "我打" => {println("BActor(乔峰) 挺猛 看我降龙十八掌")Thread.sleep(1000)//通过 sender() 可以获取到发现消息的 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来区分的 --><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打包成可执行的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>

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！