随着设备种类的多样化和通信方式的扩展，为了增强设施和便利性，选择合适的技术来连接不同的生态系统和环境变得尤为重要。一个关键的问题是如何选择最佳且适当的技术来布线每个生态系统和环境。
消息队列是一种在不同平台间发布消息的技术，它具有可靠性、可扩展性、简单性、线程安全性以及方便调试的特点。MSMQ（Microsoft Message Queue）允许在异构网络和平台之间发布消息。
消息队列的一个应用场景是在物联网(IoT)中，其中设备高度解耦且环境异构。在这种场景中，存在发送者和接收者，如下图所示：
消息队列的另一个竞争对手是Web服务。在Web服务中，如果丢失消息，大部分的错误处理责任落在客户端身上，而消息队列的持久性则更强。
MSMQ基于Windows特性。可以通过以下步骤安装Microsoft消息队列：
Control Panel -> Turn Windows features on or off -> (Select) Microsoft Message Queue (MSMQ) Server
接下来是编码时间：
选择项目类型是可选的，例如，它可以是Windows应用程序或WPF作为发布者。
File -> New -> Web Site
右键点击引用 -> 选择添加引用。
可以将消息作为对象传递给发送者，使用以下结构，并在发送端使用Serializable属性。
C#
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
namespace MSMQWebApp
{
[Serializable]
public class Product
{
public int Id { get; set; }
public string Name { get; set; }
}
}
为了访问Windows队列：
Control Panel -> Administrative Tools -> Computer Management -> Services and Applications -> Message Queuing
重要的部分是创建一个路径，这个路径与发布和订阅系统的topic相同。
C#
using System;
using System.Collections.Generic;
using System.Linq;
using System.Messaging;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
namespace MSMQWebApp
{
public partial class UsingMSMQ : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
}
protected void Button1_Click(object sender, EventArgs e)
{
System.Messaging.Message msg = new System.Messaging.Message();
msg.Label = "Hello From The Web Application";
msg.Body = "This is body";
MessageQueue mq = new MessageQueue(@".\private$\WebWinMsg");
mq.Path = @".\private$\WebWinMsg";
if (MessageQueue.Exists(mq.Path) == false)
{
MessageQueue.Create(mq.Path);
}
else
{
mq = new MessageQueue(mq.Path);
}
mq.Send(msg, "For Windows Application");
}
protected void SendObj_Click(object sender, EventArgs e)
{
System.Messaging.Message msg = new System.Messaging.Message();
msg.Label = "Hello From The Web Application Object";
List product = new List()
{
new Product{ Id = 1, Name = "Product A"},
new Product{ Id = 2, Name = "Product B"}
};
msg.Body = product;
MessageQueue mq = new MessageQueue(@".\private$\WebWinMsgObj");
mq.Path = @".\private$\WebWinMsgObj";
if (MessageQueue.Exists(mq.Path) == false)
{
// Queue does not exist so create it
MessageQueue.Create(mq.Path);
}
else
{
mq = new MessageQueue(mq.Path);
}
mq.Send(product);
}
}
}
应该创建另一个应用程序，以便在任何平台上使用消息。使用Windows应用程序如下：
C#
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Messaging;
namespace MSMQWinApp
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
private void Receive_Click(object sender, EventArgs e)
{
MessageQueue mq = new MessageQueue(@".\private$\WebWinMsg");
System.Messaging.Message msg = new System.Messaging.Message();
msg = mq.Receive();
msg.Formatter = new XmlMessageFormatter(new String[] {
"System.String,mscorlib"});
string m = msg.Body.ToString();
this.listBox1.Items.Add(m.ToString());
}
private void Receive_Object_Click(object sender, EventArgs e)
{
MessageQueue myQueue = new MessageQueue(@".\myQueue");
MessageQueue mq = new MessageQueue(@".\private$\WebWinMsgObj");
// Set the formatter to indicate body contains an Order.
mq.Formatter = new XmlMessageFormatter(new Type[]
{
typeof(List)});
try
{
// Receive and format the message.
System.Messaging.Message msg = mq.Receive();
// string str= msg.Body.ToString();
List productObj = (List)msg.Body;
this.listBox2.Items.Add(productObj.Where(x => x.Id == 2).FirstOrDefault().Name);
}
catch (MessageQueueException)
{
}
}
}
}