标签：
NetMQ （ZeroMQ to .Net），ØMQ号称史上最快中间件。它对socket通信进行了封装，使得我们不需要写socket函数调用就能完成复杂的网络通信。和一般意义上的消息队列产品不同的是，它没有消息队列服务器，而更像是一个网络通信库。从网络通信的角度看，它处于会话层之上，应用层之下。【ZeroMQ 官网】：http://zeromq.org
ØMQ有4个基本通信模型：分别是一对一结对模型（Exclusive-Pair）、请求回应模型（Request-Reply）、发布订阅模型（Publish-Subscribe）、推拉模型（Push-Pull）。
Request-reply pattern 请求-回复模型
Publish-subscribe pattern 发布-订阅模式
Pipeline pattern 管道模式
Exclusive pair pattern 独立对模式
下面是订阅发布的示例代码：
发布服务端：
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);
}
}
标签：
原文地址：http://www.cnblogs.com/dreign/p/4260306.html
