首先明白下面幾點：

• ActorSystem是該程序中的Actor的管理者，負責建立和監控所有的actor
• ActorSystem是單例的
• Actor負責通訊

如下我們使用Akka實現一個簡單的RPC通訊，首先我們看下他們互動的流程

如下給出Akka相關的Maven包

  <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-actor_2.10</artifactId>
            <version>2.3.14</version>
        </dependency>

        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-remote_2.10</artifactId>
            <version>2.3.14</version>
        </dependency>
 

class Master extends Actor {

  println("constructor invoked")

  //該方法在構造器後執行
  override def preStart(): Unit = {
    println("preStart invoked")
  }

  // 用於接收訊息
  override def receive: Receive = {
    case "connect" => {
      println("a client connected")
      sender ! "reply"  //為context.sender()，即Worker連線端的actor
    }

    case "hello" => {
      println("hello")
    }
  }
}

object Master {
  def main(args: Array[String]) {

    val host = args(0)
    val port = args(1).toInt
    // 準備配置
    val configStr =
      s"""
         |akka.actor.provider = "akka.remote.RemoteActorRefProvider"
         |akka.remote.netty.tcp.hostname = "$host"
         |akka.remote.netty.tcp.port = "$port"
       """.stripMargin
    val config = ConfigFactory.parseString(configStr)
    //ActorSystem老大，輔助建立和監控下面的Actor，他是單例的
    val actorSystem = ActorSystem("MasterSystem", config)
    //建立Actor, 起個名字Master,其會在Worker連線Master的時候使用到
    val master = actorSystem.actorOf(Props[Master], "Master")//Master主構造器會執行
    master ! "hello"  //傳送資訊
    actorSystem.awaitTermination()  //讓程序等待著, 先別結束
  }
}
 

如下是Worker端的程式碼

class Worker(val masterHost: String, val masterPort: Int) extends Actor{

  var master : ActorSelection = _
  //建立連線
  override def preStart(): Unit = {
    //在master啟動時會列印下面的那個協議, 可以先用這個做一個標誌, 連線哪個master
    //繼承actor後會有一個context, 可以通過它來連線
    master = context.actorSelection(s"akka.tcp://
 
[email protected]$masterHost:$masterPort/user/Master") //需要有/user, Master要和master那邊建立的名字保持一致
    master ! "connect"
  }

  override def receive: Receive = {
    case "reply" => {
      println("a reply form master")
    }
  }
}

object Worker {
  def main(args: Array[String]) {
    val host = args(0)
    val port = args(1).toInt
    val masterHost = args(2)
    val masterPort = args(3).toInt
    // 準備配置
    val configStr =
      s"""
         |akka.actor.provider = "akka.remote.RemoteActorRefProvider"
         |akka.remote.netty.tcp.hostname = "$host"
         |akka.remote.netty.tcp.port = "$port"
       """.stripMargin
    val config = ConfigFactory.parseString(configStr)
    //ActorSystem老大，輔助建立和監控下面的Actor，他是單例的
    val actorSystem = ActorSystem("WorkerSystem", config)
    actorSystem.actorOf(Props(new Worker(masterHost, masterPort)), "Worker")
    actorSystem.awaitTermination()
  }
}