scala – 将Akka配置与我的配置相结合

2019年8月4日 261次阅读

我正在编写一个Akka微内核应用程序,并希望使用
java.net.InetAddress.getLocalHost.getHostAddress确定它自己的主机IP.如果此调用成功,那么我将使用属性akka.remote.netty.hostname的地址,但如果不是,我将回退到application.config中的值.

这与System.setProperty(“akka.remote.netty.hostname”,addr)一样正常,如Akka docs中的SimpleClusterApp所示.

当我想首先检查application.config中是否设置了其他密钥时,问题出现了.例如,以下将无法覆盖主机地址,因为(我认为)对ConfigFactory.load()的初始调用意味着后面的System.setProperty无效.

if(ConfigFactory.load().getBoolean("my-app.do-something")){
    //Do some stuff, then change the host address
    Try{
        java.net.InetAddress.getLocalHost.getHostAddress
    } match {
        case Success(addr) => 
            System.setProperty("akka.remote.netty.hostname", addr)
        case Failure(_) => 
    }
}

我必须使用单独的配置文件来配置我自己的应用程序,还是有其他方法来解决上述问题？

最佳答案 呼叫

ConfigFactory.invalidateCaches()

设置属性后.对于单元测试来说,这是一个很好的技术.

或者,使用解析的配置片段和fallbackTo,如：

def remoteConfig(hostname: String, port: Int, commonConfig: Config): Config = {
  val configStr = s"""
    akka.remote.netty.hostname = $hostname
    akka.remote.netty.port = $port
  """
  ConfigFactory.parseString(configStr).withFallback(commonConfig)
}

val baseConfig = ConfigFactory.load()
val akkaConfig = if (!baseConfig.getBoolean("my-app.do-something")) baseConfig
else
  Try(java.net.InetAddress.getLocalHost.getHostAddress).
    map(remoteConfig(_, 0, baseConfig)).
    getOrElse(baseConfig) 

val system = ActorSystem("foo", akkaConfig)
点赞