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

[Aaron Friesen]

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<mailto: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<mailto: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/20161108/790d9b21/attachment.htm>