package org.apache.spark.rpc

import org.apache.spark.SparkConf

import java.util.concurrent.CountDownLatch

object RpcRemoteTest extends RpcParent {

  def main(args: Array[String]): Unit = {
    val shutdownLatch = new CountDownLatch(1)
    val anotherEnv = createRpcEnv(new SparkConf(), "remote-client", 0, clientMode = true)
    println(s"地址：${anotherEnv.address}")

    val rpcEndpointRef = anotherEnv.setupEndpointRef(new RpcAddress("localhost", 8000), "ask-remotely")
    val reply = rpcEndpointRef.askSync[String]("hello Remote")
    println(reply)
    shutdownLatch.await()
  }
}