AKKA java示例akka-sample-remote conf

Question

我對Akka很新，但到目前爲止我非常喜歡。我已經能夠在本地運行一個小應用程序，現在我想測試遠程部署並使用遠程參與者。

爲此我審查，並編制了Java阿卡在2.0.1阿卡遠程採樣的例子..

https://github.com/akka/akka/tree/master/akka-samples/akka-sample-remote

但是當我嘗試運行編譯的例子..

java -classpath`pwd`/src/main/resources：target/akka-remote-1.1.jar sample.remote.calculator.java.JCalcApp我得到關於application.conf的錯誤

我已經多次嘗試調整示例application.conf文件b UT 最接近我去運行遠程示例應用程序的成功是..線程「main」 akka.remote.RemoteTransportException

異常：無法加載遠程傳輸層akka.remote.netty.NettyRemoteTransport

我我正在使用Maven樹蔭插件將我所有的依賴包括在jar中。這與當地的應用程序。

有人可以看看我的conf文件，讓我知道我需要改變什麼。

謝謝！

這是我application.conf文件...

//#calculator 
calculator { 
include "common" 

akka { 
    backoff-timeout = 0ms 
    remote.backoff-timeout = 0ms 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.netty.port = 2552 
    } 
} 
//#calculator 

//#remotelookup 
remotelookup { 
    include "common" 

    akka { 
    backoff-timeout = 0ms 
    remote.backoff-timeout = 0ms 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.netty.port = 2553 
    } 
} 
//#remotelookup 

//#remotecreation 
remotecreation { 
    include "common" 

    akka { 
    actor { 
     deployment { 
     /advancedCalculator { 
      remote = "akka://CalculatorApplication@127.0.0.1:2552" 
     } 
     } 
    } 
    backoff-timeout = 0ms 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.netty.port = 2554 
    } 
} 
//#remotecreation 

和common.conf ...

akka { 

    actor { 
    provider = "akka.remote.RemoteActorRefProvider" 
    } 

    remote { 
    netty { 
     hostname = "127.0.0.1" 
    } 
    } 
} 

Answer 1

好了，想通了。使用這個application.conf，這個遠程示例就可以工作。

注意：另外一定要在classpath中包含application.conf的路徑。

//#calculator 
calculator { 
    include "common" 

    akka { 
    remote.netty.max-total-memory-size = 0b 
    remote.netty.max-channel-memory-size = 0b 
    remote.netty.execution-pool-size = 4 
    remote.netty.execution-pool-keepalive = 60s 
    remote.netty.backlog = 4096 
    remote.netty.connection-timeout = 120s 
    remote.netty.outbound-local-address = "auto" 
    remote.netty.message-frame-size = 1 MiB 
    remote.netty.reconnect-delay = 5s 
    remote.netty.all-timeout = 0s 
    remote.netty.write-timeout = 0s 
    remote.netty.read-timeout = 0s 
    remote.netty.reconnection-time-window = 600s 
    remote.netty.backoff-timeout = 0ms 
    remote.netty.secure-cookie = "" 
    remote.netty.require-cookie = off 
    remote.netty.use-passive-connections = on 
    remote.backoff-timeout = 0ms 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.netty.port = 2552 
    } 
} 
//#calculator 

//#remotelookup 
remotelookup { 
    include "common" 

    akka { 
    remote.netty.max-total-memory-size = 0b 
    remote.netty.max-channel-memory-size = 0b 
    remote.netty.execution-pool-size = 4 
    remote.netty.execution-pool-keepalive = 60s 
    remote.netty.backlog = 4096 
    remote.netty.connection-timeout = 120s 
    remote.netty.outbound-local-address = "auto" 
    remote.netty.message-frame-size = 1 MiB 
    remote.netty.reconnect-delay = 5s 
    remote.netty.all-timeout = 0s 
    remote.netty.write-timeout = 0s 
    remote.netty.read-timeout = 0s 
    remote.netty.reconnection-time-window = 600s 
    remote.netty.backoff-timeout = 0ms 
    remote.netty.secure-cookie = "" 
    remote.netty.require-cookie = off 
    remote.netty.use-passive-connections = on 
    remote.backoff-timeout = 0ms 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.netty.port = 2553 
    } 
} 
//#remotelookup 

//#remotecreation 
remotecreation { 
    include "common" 

    akka { 
    actor { 
     deployment { 
     /advancedCalculator { 
      remote = "akka://CalculatorApplication@127.0.0.1:2552" 
     } 
     } 
    } 
    remote.netty.max-total-memory-size = 0b 
    remote.netty.max-channel-memory-size = 0b 
    remote.netty.execution-pool-size = 4 
    remote.netty.execution-pool-keepalive = 60s 
    remote.netty.backlog = 4096 
    remote.netty.connection-timeout = 120s 
    remote.netty.outbound-local-address = "auto" 
    remote.netty.message-frame-size = 1 MiB 
    remote.netty.reconnect-delay = 5s 
    remote.netty.all-timeout = 0s 
    remote.netty.write-timeout = 0s 
    remote.netty.read-timeout = 0s 
    remote.netty.reconnection-time-window = 600s 
    remote.netty.backoff-timeout = 0ms 
    remote.netty.secure-cookie = "" 
    remote.netty.require-cookie = off 
    remote.netty.use-passive-connections = on 
    remote.untrusted-mode = off 
    remote.remote-daemon-ack-timeout = 30s 
    remote.log-received-messages = on 
    remote.log-sent-messages = on 
    remote.transport = "akka.remote.netty.NettyRemoteTransport" 
    remote.netty.port = 2554 
    } 
} 
//#remotecreation