[zeromq-dev] Unsuccessful send/receive on Router following reconnect

[Wilson Chong]

my answer is actually based on my own experience. if i tried using
"durable" socket by assigning an identity manually to the socket, it won't
reconnect once it disconnects.

i've read somewhere before that there's plan to phase out the "durable"
socket, but i wasn't able to follow it, not sure what really happen.


On Wed, Nov 9, 2016 at 2:28 AM, Aaron Friesen <AFriesen at spirae.com> wrote:

> Wilson,
>
>
>
> Can you explain how removing that line would help?
>
>
>
> For Router-to-Router, one or both ends has to have a known identity.  In
> my case, since each peer has a known GUID associated with it, that becomes
> its Identity, specifically, the line you are telling me to remove.
>
>
>
> Plus, everything works when all processes are started the first time, even
> late joiners.  The problem only occurs when one of them has to restart.
>
>
>
> Aaron
>
>
>
> *From:* zeromq-dev [mailto:zeromq-dev-bounces at lists.zeromq.org] *On
> Behalf Of *Wilson Chong
> *Sent:* Tuesday, November 08, 2016 10:41 AM
> *To:* ZeroMQ development list <zeromq-dev at lists.zeromq.org>
> *Subject:* Re: [zeromq-dev] Unsuccessful send/receive on Router following
> reconnect
>
>
>
>
>
> try remove the line _requestSocket.Identity = Encoding.UTF8.GetBytes(_
> selfID);
>
>
>
> On Wed, Nov 9, 2016 at 1:07 AM, Aaron Friesen <AFriesen at spirae.com> wrote:
>
> Thanks in advance for assistance.
>
>
>
> Using ZeroMQ C# bindings (4.1.0.21) with libzmq (4.1.5.0) on Windows (7,
> Server 2008 R2, and Server 2012).
>
>
>
> For request/response functionality I am using a single Router socket (tcp)
> in each of several interconnected processes.
>
>
>
> Each process has an identifier (GUID) that is known by all other
> processes, which is used as the Identity on the socket.
>
>
>
> Each process performs a Bind on a specific port (also known by all other
> processes), and also performs a Connect to each of the other Router sockets
> in the other processes.
>
>
>
> For example, if 5 processes are used, visualize a completely
> interconnected star.
>
>
>
> When all 5 processes are initially started, communication works great.  I
> can send and receive messages between any of the 5.
>
>
>
> The problem comes if for some reason I must restart one of the 5.  Once
> that process is restarted, communication with the other 4 seems to go
> nowhere, for both incoming and outgoing traffic.
>
>
>
> I have monitors on all of the sockets which seems to show that everything
> is reconnecting.
>
>
>
> I also have RouterMandatory set to Report.  Sends from the newly restarted
> process do not Report when attempting to Send to the other processes, and
> the other processes do not Report when attempting to Send to the restarted
> process.
>
>
>
> If I stop one of the other remaining processes, then attempts to Send to
> that process Report as expected.
>
>
>
> I also have pub/sub socket connections, with each process publishing a
> heartbeat, and those sockets all successfully reconnect.
>
>
>
> I am testing all of this from (in this example) a 6th process that simply
> connects to the other 5 processes (also using a Router socket, no Bind
> involved), and it successfully reconnects to the restarted process without
> any problems and can send messages (and receive subsequent response) with
> any of the other 5, including any processes that are restarted.  This 6th
> process does not publish to the other 5, but does subscribe to the
> heartbeats.  I am convinced that the fact that 6th process successfully
> reconnects is a clue to what I am doing wrong, but it has been insufficient
> for me to find out what the root problem really is.
>
>
>
> The only other thing to note is that Linger is set to zero prior to
> Bind/Connect.
>
>
>
> The code for all processes for setting up the Router socket is:
>
>
>
>             using (_requestSocket = new ZSocket(_context, ZSocketType
> .ROUTER))
>
>             {
>
>                 try
>
>                 {
>
>                     _requestSocket.Monitor(Endpoint_RequestMonitor, out
> error);
>
>                     Debug.Assert(error == ZError.None);
>
>
>
>                     _requestSocket.Identity = Encoding.UTF8.GetBytes(_
> selfID);
>
>                     _requestSocket.Linger = TimeSpan.Zero;
>
>                     _requestSocket.RouterMandatory = RouterMandatory
> .Report;
>
>
>
>                     _requestSocket.Bind(Endpoint_RequestInproc, out
> error);
>
>                     Debug.Assert(error == ZError.None);
>
>
>
>                     endpoint = string.Format("tcp://*:{0}", _requestPort);
>
>                     _requestSocket.Bind(endpoint, out error);
>
>                     Debug.Assert(error == ZError.None);
>
>                 }
>
>                 catch (Exception ex)
>
>                 {
>
>                     Environment.Exit(-1);
>
>                 }
>
>
>
> Thanks for any assistance or advice you can provide,
>
>
>
> Aaron
>
>
>
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20161109/840b14f1/attachment.htm>