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

蔚落 2023-10-06 08:19 15阅读 0赞

> 启动程序：

package com.zxl.akka.two_actors
    
    import akka.actor.{
        ActorRef, ActorSystem, Props}
    
    //extends App 可以替代main方法
    object ActorGame extends App {
          
    
    
      //创建 ActorSystem
      val 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_actors
    
    import akka.actor.{
        Actor, ActorRef}
    
    
    class AActor(actorRef: ActorRef) extends Actor {
        
      val bActorRef: ActorRef = actorRef
      override 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_actors
    
    import akka.actor.Actor
    
    
    class BActor extends Actor{
        
      override def receive:Receive = {
        
        case "我打" => {
        
          println("BActor(乔峰) 挺猛 看我降龙十八掌")
          Thread.sleep(1000)
          //通过 sender() 可以获取到发现消息的 actor 的 ref
          sender() ! "我打"
        }
      }
    }

> 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.0
        http://maven.apache.org/xsd/maven-4.0.0.xsd">
     
        
        <modelVersion>4.0.0</modelVersion>
        
        <groupId>com.zxl.akka</groupId>
     
        
        <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>
            
            <dependency>
                <groupId>org.scala-lang</groupId>
                <artifactId>scala-library</artifactId>
                <version>${
        scala.version}</version>
            </dependency>
            
            <dependency>
                <groupId>com.typesafe.akka</groupId>
                <artifactId>akka-actor_${
        scala.compat.version}</artifactId>
                <version>${
        akka.version}</version>
            </dependency>
            
            <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>
    
                
                <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>

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200507223423744.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk=,size_16,color_FFFFFF,t_70