相关疑难解决方法(0)

获取简单的远程Akka应用程序运行

我试图建立一个简单的服务器/客户端akka(使用Akka 2.0.3)应用程序,但它无法连接.这里预先是基本代码:

import com.typesafe.config.ConfigFactory
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.Props

class Server extends Actor {
  def receive = {
    case s: String => println("Got " + s)
  }
}

val serverSystem = ActorSystem("server", ConfigFactory.load(ConfigFactory.parseString("""
  akka {
    actor {
      provider = "akka.remote.RemoteActorRefProvider"
    }
    remote {
      transport = "akka.remote.netty.NettyRemoteTransport"
      netty {
        hostname = "localhost"
        port = 5678
      }
    }
  }
""")))

val server = serverSystem.actorOf(Props[Server], name = "server")
Thread.sleep(500)
println("started")
Thread.sleep(500)

val clientSystem = ActorSystem("client", ConfigFactory.load(ConfigFactory.parseString("""
  akka {
    actor {
      provider = …
Run Code Online (Sandbox Code Playgroud)

scala akka

6
推荐指数
1
解决办法
2254
查看次数

标签 统计

akka ×1

scala ×1