Hi,


> But everything is ok for websocket server A. There was only a tcp
> connection between it and businessserver. And it received
> ConnectionRegistered messages.
>
>
> What's wrong with websocket server B? Is it ok for two tcp connections
> between websocket server B and business server? What I should do to avoid
> it?
>

It is normal to have two TCP connections between Actor Systems. By default
an ActorSystem tries to reuse incoming connections for outgoing messages.
However, in cases where the two systems open the connections concurrently
(for example you restart one of them, while the other tries to connect to
it, so when it comes up they both try to connect) there might be two such
connections alive. While there is a theoretical opportunity for the two
systems to reconcile and agree on closing one of them, it is not a simple
thing to do safely in practice so we didn't bother so far.

You must also be prepared for temporary message losses between reconnects
since Akka does not guarantee delivery and does not buffer messages
forever. See
http://doc.akka.io/docs/akka/2.4.0/scala/remoting.html#Lifecycle_and_Failure_Recovery_Model
for details.

-Endre


>
>
> The netstat's output:
> [root@dev-sig-server ~]# netstat -anp | grep 2554
> tcp        0      0 10.170.187.126:2554         0.0.0.0:*
> LISTEN                             4119/java
> tcp        0      0 10.170.187.126:2554         10.162.209.21:32833
> ESTABLISHED                4119/java
> tcp        0      0 10.170.187.126:2554         10.162.198.161:33326
> ESTABLISHED               4119/java
> tcp        0      0 10.170.187.126:2554         10.162.209.21:32843
> ESTABLISHED                 4119/java
>
>
> We use akka-remote_2.10-2.3.12.jar
>
> business server's application.conf:
> akka {
>     actor {
>         provider = "akka.remote.RemoteActorRefProvider"
>     }
>     remote {
>          log-received-messages = on
>          log-sent-messages = on
>
>          enabled-transports = ["akka.remote.netty.tcp"]
>
>          netty.tcp {
>             hostname = 10.170.187.126
>             port = 2554
>          }
>     }
>
>     loggers = ["akka.event.slf4j.Slf4jLogger"]
>
>     loglevel = "DEBUG"
> }
> The websocket server's application.conf is similar.
>
> --
> >>>>>>>>>> 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 [email protected].
> To post to this group, send email to [email protected].
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 
Akka Team
Typesafe - Reactive apps on the JVM
Blog: letitcrash.com
Twitter: @akkateam

-- 
>>>>>>>>>>      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 [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Reply via email to