NetMQAdapter

A tool based on NetMQ4

Using/Documentation

Before using NetMQAdapter, make sure to read the ZeroMQ Guide.

Here is a simple example:

// Using AutoResetEvent to wait result, because sending data and receiving data are asynchronous
AutoResetEvent eventRaised = new AutoResetEvent(false);
using (var poller = new PollerAdapter()) // Create a poller to control all sockets
{
    ISocket server = poller.AddSocket(SocketType.Router, "tcp://localhost:5556", true, "TestServer", Guid.NewGuid().ToString()); // Bind
    ISocket client = poller.AddSocket(SocketType.Dealer, "tcp://localhost:5556", false, "TestClient", Guid.NewGuid().ToString()); // connect

    // Receive event on server
    server.Received += (s, e) =>
    {
        // Receive the message from the server socket
        byte[] identity = e.Item[0];
        string receiveData = "";
        for (int i = 1; i < e.Item.Length; i++)
        {
            if (e.Item[i] == null) { break; }
            else { receiveData += Encoding.UTF8.GetString(e.Item[i]); }
        }
        Console.WriteLine("From Client: {0}", receiveData);

        // Send a response back from the server
        byte[][] sendMessage = { e.Item[0], Encoding.UTF8.GetBytes("Hi Back") };
        server.SendData(sendMessage);
    };

    // Receive event on client
    client.Received += (s, e) =>
    {
        // Receive the response from the client socket
        string result = "";
        for (int i = 0; i < e.Item.Length; i++)
        {
            if (e.Item[i] == null) { break; }
            else{ result += Encoding.UTF8.GetString(e.Item[i]); }
        }

        Console.WriteLine("From Server: {0}", result);
        // Trigger AutoResetEvent
        eventRaised.Set();
    };
    
    // Active poller
    poller.Start();
    
    // Send a message from the client socket
    byte[][] client1Data = { Encoding.UTF8.GetBytes("Hello") };
    client.SendData(client1Data);
    
    eventRaised.WaitOne(3000);
    poller.StopAll();
}