akka远程演员运行本地演员

Question

我正在学习akka-remote并尝试重新学习http://www.typesafe.com/activator/template/akka-sample-remote-scala我自己

当我尝试在两个独立的JVM中运行项目时，我看到

$ clear;java -jar akkaio-remote/target/akka-remote-jar-with-dependencies.jar com.harit.akkaio.remote.RemoteApp ProcessingActor
ProcessingActorSystem Started

和

$ clear;java -jar akkaio-remote/target/akka-remote-jar-with-dependencies.jar com.harit.akkaio.remote.RemoteApp WatchingActor
WatchingActorSystem Started
asking processor to process
processing big things

我要求我的Processing System在端口2552 上运行

include "common"
akka {
  # LISTEN on tcp port 2552
  remote.netty.tcp.port = 2552
}

我告诉我的另一个系统（WatchingSystem）在2554端口上运行，但在2552端口上启动processingActor

include "common"
akka {
  actor {
    deployment {
      "/processingActor/*" {
        remote = "akka.tcp://ProcessingActorSystem@127.0.0.1:2552"
      }
    }
  }
  remote.netty.tcp.port = 2554
}

CCD_ 8是关于使用正确的提供者

akka {
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote {
    netty.tcp {
      hostname = "127.0.0.1"
    }
  }
}

问题/关注

1. 从日志中，我看到processingActor在WatchingActorSystem上运行，而不是在ProcessingActorSystem上运行，这是怎么回事
2. 我怎么能看到这两个ActorSystems正在相互连接。我没有看到日志记录。然而，在这个例子中，我分享了日志记录的发生。我错过了什么

整个代码发布在Github上，并且运行

Answer 1

1）您的部署配置设置为processingActor的所有子级都是远程的，如akka配置文档中所述

您应该将其设置为：

deployment {
  "/processingActor" {
    remote = "akka.tcp://ProcessingActorSystem@127.0.0.1:2552"
  }

2） 您需要将日志级别设置为有用的级别，如akka日志文档