public static class NetMQPub
    {
        readonly static ManualResetEvent _terminateEvent = new ManualResetEvent(false);
        /// <summary>
        /// NetMQ 发布模式
        /// </summary>
        public static void Start()
        {
            string[] wethers = new string[5] {"晴朗","多云","阴天","小雨","暴雪" };

            //CTRL+C 退出程序
            Console.CancelKeyPress += Console_CancelKeyPress;
            Console.WriteLine("发布多个地区天气预报：");

            using (var context = NetMQContext.Create())
            {
                using (var publisher = context.CreatePublisherSocket())
                {
                    publisher.Bind("tcp://127.0.0.1:5556");

                    var rng = new Random();
                    string msg;
                    int sleeptime = 10;

                    while (_terminateEvent.WaitOne(0) == false)
                    {
                        //随机生成天气数据
                        int zipcode = rng.Next(0, 99);
                        int temperature = rng.Next(-50, 50);
                        int wetherId = rng.Next(0, 4);

                        msg = string.Format("{0} {1} {2}", zipcode, temperature, wethers[wetherId]);
                        publisher.Send(msg,Encoding.UTF8, zmq.SendReceiveOptions.DontWait);

                        Console.WriteLine(msg);
                        Thread.Sleep(sleeptime);
                    }
                }
            }
        }

        static void Console_CancelKeyPress(object sender, ConsoleCancelEventArgs e)
        {
            Console.WriteLine("exit...");
            _terminateEvent.Set();
        }
    }

  public static class NetMQSub
    {
        public delegate void GetDataHandler(string message);
        public static event GetDataHandler OnGetData;

        /// <summary>
        /// NetMQ 订阅模式
        /// </summary>
        public static void Start()
        {            
            var rng = new Random();
            int zipcode = rng.Next(0, 99);
            Console.WriteLine("接收本地天气预报 {0}...", zipcode);

            OnGetData += new GetDataHandler(ProcessData);
    
            using (var context = NetMQContext.Create())
            using (var subscriber = context.CreateSubscriberSocket())
            {
                subscriber.Connect("tcp://127.0.0.1:5556");
                subscriber.Subscribe(zipcode.ToString(CultureInfo.InvariantCulture));

                while(true)
                {
                    string results = subscriber.ReceiveString(Encoding.UTF8);
                    Console.Write(".");

                    string[] split = results.Split(new[] { ' ' }, StringSplitOptions.RemoveEmptyEntries);

                    int zip = int.Parse(split[0]);
                    if (zip == zipcode)
                    {
                        OnGetData(results);
                    }                  
                }
            }
        }

        public static void ProcessData(string msg)
        {
            Console.WriteLine("天气情况：" + msg);
        }
    }