Thanks Max!!!! That did it.
Haven’t found many references to that option, not even in Pieter’s book. Thanks a million! Aaron Friesen From: zeromq-dev [mailto:[email protected]] On Behalf Of Max Kozlovsky Sent: Tuesday, November 08, 2016 1:17 PM To: ZeroMQ development list <[email protected]> Subject: Re: [zeromq-dev] Unsuccessful send/receive on Router following reconnect Hi, Make sure you have ZMQ_ROUTER_HANDOVER option set on the sockets if you want to reuse the identity across process restarts. Max On Tue, Nov 8, 2016 at 12:01 PM, Wilson Chong <[email protected]<mailto:[email protected]>> wrote: 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 <[email protected]<mailto:[email protected]>> 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:[email protected]<mailto:[email protected]>] On Behalf Of Wilson Chong Sent: Tuesday, November 08, 2016 10:41 AM To: ZeroMQ development list <[email protected]<mailto:[email protected]>> 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 <[email protected]<mailto:[email protected]>> 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 [email protected]<mailto:[email protected]> http://lists.zeromq.org/mailman/listinfo/zeromq-dev _______________________________________________ zeromq-dev mailing list [email protected]<mailto:[email protected]> http://lists.zeromq.org/mailman/listinfo/zeromq-dev _______________________________________________ zeromq-dev mailing list [email protected]<mailto:[email protected]> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
