NetMQ用作IPC的实例

 using System;

 using System.Threading;

 using NetMQ;

 using NetMQ.Sockets;

 namespace NetMQIPCServer

 {

     class Program

     {

         private const string topic = "unity3d";

         private static bool running = true;

         static void Main(string[] args)

         {

             Console.WriteLine("Main thread id = {0}", Thread.CurrentThread.ManagedThreadId);

             // 进程内通信

             //pub.Bind("inproc://unity3d");

             //sub.Connect("inproc://unity3d");

             // 跨进程通信

             //var pub = new PublisherSocket();

             //var sub = new SubscriberSocket();

             //pub.Bind("ipc:///unity3d/0");

             //sub.Connect("ipc:///unity3d/0");

             //sub.Subscribe(topic);

             // 定向接收[NonBlock]

             //var pub = new PublisherSocket();

             //var sub = new SubscriberSocket();

             //pub.Bind("ipc:///unity3d/0");

             //sub.Connect("ipc:///unity3d/0");

             //sub.Subscribe(topic);

             //var proactor = new NetMQProactor(sub, (socket, message) =>

             //{

             //    //Console.WriteLine(message);

             //    foreach (var b in message[1].Buffer)

             //    {

             //        Console.Write("{0:x2}", b);

             //        Console.Write(" ");

             //    }

             //    Console.WriteLine("Received message in thread {0}", Thread.CurrentThread.ManagedThreadId);

             //});

             // TCP

             var pub = new PublisherSocket();

             var sub = new SubscriberSocket();

             pub.Bind("tcp://*:2017");

             sub.Connect("tcp://localhost:2017");

             sub.Subscribe(topic);

             var proactor = new NetMQProactor(sub, (socket, message) =>

             {

                 //Console.WriteLine(message);

                 foreach (var b in message[].Buffer)

                 {

                     Console.Write("{0:x2}", b);

                     Console.Write(" ");

                 }

                 Console.WriteLine("Received message in thread {0}", Thread.CurrentThread.ManagedThreadId);

             });

             // 轮询模式

             //var poller = new NetMQPoller();

             //poller.Add(sub);

             //sub.ReceiveReady += (sender, eventArgs) =>

             //{

             //    bool more = false;

             //    byte[] bytes = null;

             //    eventArgs.Socket.ReceiveFrameBytes(out more);

             //    if (more)

             //    {

             //        bytes = eventArgs.Socket.ReceiveFrameBytes();

             //        foreach (var b in bytes)

             //        {

             //            Console.Write("{0:x2}", b);

             //            Console.Write(" ");

             //        }

             //        Console.WriteLine("Received bytes in thread {0}", Thread.CurrentThread.ManagedThreadId);

             //    }

             //};

             new Thread(() =>

             {

                 while (running)

                 {

                     Console.WriteLine("PublisherSocket:Send Bytes in thread {0}.", Thread.CurrentThread.ManagedThreadId);

                     pub.SendMoreFrame(topic).SendFrame(new byte[] { 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3,

                         0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3, 0xa, 0xb, 0xc,

                         0x1, 0x2, 0x3, 0xa, 0xb, 0xc, 0x1, 0x2, 0x3 });

                     Thread.Sleep();

                 }

             }).Start();

             //new Thread(() =>

             //{

             //    bool more = false;

             //    byte[] bytes = null;

             //    while (running)

             //    {

             //        if (sub.HasIn)

             //        {

             //            sub.ReceiveFrameBytes(out more);

             //            if (more)

             //            {

             //                bytes = sub.ReceiveFrameBytes();

             //                foreach (var b in bytes)

             //                {

             //                    Console.Write("{0:x2}", b);

             //                    Console.Write(" ");

             //                }

             //                Console.WriteLine("Received bytes in thread {0}", Thread.CurrentThread.ManagedThreadId);

             //            }

             //        }

             //    }

             //}).Start();

             // 在主线程轮询[Block]

             //poller.Run();

             // 异步轮询[NonBlock]

             //poller.RunAsync();

             Console.ReadKey();

             running = false;

             Thread.Sleep();

             //poller.Stop();

             //poller.StopAsync();

             pub.Close();

             sub.Close();

             NetMQConfig.Cleanup();

         }

     }

 }