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

[Wilson Chong]

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
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20161109/db69793c/attachment.htm>