使用Scala 2.11.1在akka 2.3.4中未找到协议的传输

Question

解析器+=“TypeSafe Repository”（位于“http://repo.typesafe.com/typesafe/releases/”）

解析器+=“Sonatype Releases”，网址为“http://oss.sonatype.org/content/repositories/releases”

libraryDependencies+=“com.typesafe.akka”%%“akka-actor”%“2.3.4”

akka {
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote { 
        enabled-transports = ["akka.remote.netty.tcp"]

        netty.tcp.hostname = "10.126.13.61" 
        netty.tcp.port = 2552
        netty.tcp.message-frame-size = 20 MiB
        //netty.tcp {
      //    write-buffer-high-water-mark = 148000b
          //  send-buffer-size = 148000b
           // receive-buffer-size = 148000b
        //}
  }

  event-handlers = []
  loglevel=WARNING

}    


my-custom-dispatcher {
//    type = PinnedDispatcher
    executor = thread-pool-executor
    # 10 years should be enough
//    thread-pool-executor.keep-alive-time = 315360000s
    # note that disabling core timeout altogether doesn't work
    # until ticket 2856 is fixed
    thread-pool-executor.allow-core-timeout = off
  mailbox-type = "akka.dispatch.UnboundedDequeBasedMailbox"
}

  private var system: Option[ActorSystem] = None
  def getSystem(machinefile: String) = synchronized {
    system match {
      case None =>
        system = Some(ActorSystem("FooPar" + indexOf(hostName, machinefile),
          ConfigFactory.parseString(conf))); system
      case Some(sys) => system
    }
  }

也就是说，我不显式创建address对象。

Answer 1

在创建akka.actor.address的实例时，这看起来像是一个问题。要使远程处理工作，第一个参数必须是“akka.tcp”而不是“akka”:

val addr = Address("akka.tcp", "actorSystem", hostname, port)

那么当您想要获取对执行元的引用时：

val path = RootActorPath(addr) / "user" / "actorName"
val actorRef = context.actorSelection(path)

（注意，上下文也可能是系统)