//
// Lazy Pirate client
// Use zmq_poll to do a safe request-reply
// To run, start lpserver and then randomly kill/restart it
// Author: Tomas Roos
// Email: moc.liamg|soorsamotp#moc.liamg|soorsamotp
using System;
using System.Text;
using System.Threading;
using ZMQ;
namespace ZMQGuide
{
internal class Program
{
private static int requestTimeout = 2500;
private static int requestRetries = 3;
private static string serverEndpoint = "tcp://127.0.0.1:5555";
private static int sequence = 0;
private static bool expectReply = true;
private static int retriesLeft = requestRetries;
private static Socket CreateServerSocket(Context context)
{
Console.WriteLine("Connecting to server…");
var client = context.Socket(SocketType.REQ);
client.Connect(serverEndpoint);
client.Linger = 0;
client.PollInHandler += PollInHandler;
return client;
}
public static void Main(string[] args)
{
using (var context = new Context(1))
{
var client = CreateServerSocket(context);
while (retriesLeft > 0)
{
sequence++;
Console.WriteLine("Sending ({0})", sequence);
client.Send(sequence.ToString(), Encoding.Unicode);
expectReply = true;
while (expectReply)
{
int count = Context.Poller(requestTimeout * 1000, client);
if (count == 0)
{
retriesLeft--;
if (retriesLeft == 0)
{
Console.WriteLine("Server seems to be offline, abandoning");
break;
}
else
{
Console.WriteLine("No response from server, retrying..");
client = null;
client = CreateServerSocket(context);
client.Send(sequence.ToString(), Encoding.Unicode);
}
}
}
}
}
}
private static void PollInHandler(Socket socket, IOMultiPlex revents)
{
var reply = socket.Recv(Encoding.Unicode);
if (Int32.Parse(reply) == sequence)
{
Console.WriteLine("Server replied OK ({0})", reply);
retriesLeft = requestRetries;
expectReply = false;
}
else
{
Console.WriteLine("Malformed reply from server: {0}", reply);
}
}
}
}