I'm pretty new to Akka and am currently trying out Akka's new Artery
backend for akka-remoting
(http://doc.akka.io/docs/akka/2.4/scala/remoting-artery.html) while also
testing the regular netty.tcp transport
(http://doc.akka.io/docs/akka/2.4/scala/remoting.html).
It looks fairly straight forward and I have two test applications running:
* A producer application which sends a message to the consumer every 3
seconds, and prints some stuff when the reply comes back
* A consumer application which prints a message when it receives one, and
then sends back a reply to sender()
However I cannot get the communication to work when running both my
applications with artery inside docker containers on the same host - it
perfectly when I use netty.tcp though!.
Below are the results I achieved:
Results using artery
Producer Consumer Result
-------------------------
IntelliJ Docker ok
Docker IntelliJ ok
IntelliJ IntelliJ ok
Docker Docker fail (no message reaches the consumer, and the producer
eventually prints handshake timeouts after 20 seconds/default timeout in
akka-remote-artery - the same error message I get when not running any
Consumer at all)
Results using netty.tcp
Producer Consumer Result
-------------------------
IntelliJ Docker ok
Docker IntelliJ ok
IntelliJ IntelliJ ok
Docker Docker ok
As you see above, I got all combinations to work except when using artery
to communicate between two local docker containers.
The akka configurations for the failing artery case are as follows
Consumer conf (prettified output of typesafe Config object logged):
{
"akka": {
"actor": {
"provider": "remote"
},
"remote": {
"artery": {
"bind": {
"hostname": "0.0.0.0",
"port": 12345
},
"canonical": {
"hostname": "192.168.99.100",
"port": 12345
},
"enabled": "on"
}
}
}
}
Producer conf (prettified output of typesafe Config object logged):
{
"akka": {
"actor": {
"provider": "remote"
},
"remote": {
"artery": {
"bind": {
"hostname": "0.0.0.0",
"port": 12346
},
"canonical": {
"hostname": "192.168.99.100",
"port": 12346
},
"enabled": "on"
}
}
}
}
192.168.99.100 is the IP of my docker machine executing both containers.
The equivalent netty.tcp config works fine (as seen in the results table
earlier in this message)
*However using artery I just get zero activity on the consumer, and
eventually the producer starts logging errors:*
[ERROR] [11/09/2016 16:24:17.201]
[producer-system-akka.remote.default-remote-dispatcher-6]
[akka.remote.artery.Association(akka://producer-system)] Outbound message
stream to [akka://consumer-system@192.168.99.100:12345] failed. Restarting
it. Handshake with [akka://consumer-system@192.168.99.100:12345] did not
complete within 20000 ms
(akka.remote.artery.OutboundHandshake$HandshakeTimeoutException) after
about 20 seconds, indicating what I assume is a timeout.
When I use netty.tcp it works just fine between the containers.
What is also strange is that it works with artery when I move one of the
applications outside of a docker container. Both
When running each application outside docker (e.g. from within intelliJ
during development) they can communicate with each other fine, but as soon
as I try to make them talk to each other with artery from docker container
to docker container, no messages get through to the consumer
Each application can be configured (cmd line args) to communicate with
either netty.tcp or artery.
I've repeatedly gone over the configurations, code and startup arguments
from scratch now so many times, and had colleagues look at it as well. We
cannot figure out at all what could be wrong here :S.
The following are the docker startup commands. The command line arguments
you see here are used to generate the conf you see above.
Consumer:
docker run --shm-size 1024M -p 12345:12345 -p 12345:12345/udp --rm
akka-remote-eval-consumer:0.1.0-SNAPSHOT --transport tcp --host
192.168.99.100 --port 12345 --bind-host 0.0.0.0 --bind-port 12345
Producer:
docker run --shm-size 1024M -p 11001:11001/udp -p 12346:12346/udp --rm
akka-remote-eval-producer:0.1.0-SNAPST --transport artery --host
192.168.99.100 --port 12346 --bind-host 0.0.0.0 --bind-port 12346
--consumer-host 192.168.99.100 --consumer-port 12345
Running this on a regular macbook pro with what I think are the latest
updates, oracle jdk8, docker running with docker-machine.
Using akka-actor and akka-remote 2.4.12
Note: We are running an older docker version if that is of any importance:
1.10.2
Any ideas of what I could be doing wrong?
/ Johan
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
