ZeroMQ test

Client.cs

using System;
using System.Diagnostics;
using ZeroMQ.Sockets;

namespace Client
{
    public class Program
    {
        public static void Main(string[] args)
        {
            const int numberOfMessages = 100000;
            var stopwatch = Stopwatch.StartNew();

            using (var context = ZmqContext.Create())
            {
                using (var socket = context.CreateRequestSocket())
                {
                    socket.Connect("tcp://127.0.0.1:9001");

                    for (var i = 0; i < numberOfMessages; i++)
                    {
                        socket.Send("PING".ZmqEncode());
                        socket.Receive();
                    }

                }
            }

            stopwatch.Stop();
            var elapsedMs = stopwatch.ElapsedMilliseconds;
            var messagesPerSec = numberOfMessages * 1000 / elapsedMs;

            Console.Out.WriteLine("Elapsed: {0} ms for {1} messages. ({2} / sec)", elapsedMs, numberOfMessages, messagesPerSec);
            Console.ReadLine();
        }
    }
}

Server.cs

using System;
using ZeroMQ.Sockets;

namespace Server
{
    public class Program
    {
        static void Main(string[] args)
        {
            var response = "PONG".ZmqEncode();

            using (var context = ZmqContext.Create())
            {
                using (var socket = context.CreateReplySocket())
                {
                    socket.Bind("tcp://*:9001");

                    while (true)
                    {
                        socket.Receive();
                        
                        socket.Send(response);
                    }
                }
            }
        }
    }
}