微软消息队列 MessageQueue 简单使用

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

1.在服务电脑上打开消息队列

①进入控制面板》程序》启用或关闭windows功能

②将需要的勾选（我自己全选了哈哈哈）

③我的电脑右键打开管理见到消息队列在专用队列上新建专用队列

⑤填写名称还有选择是否是事务性

好到这里就基本准备完成

下面就要使用队列来发送消息

//创建消息队列并发送消息到队列
try
{
//连接到本地新创建的队列
MessageQueue myQueue = new MessageQueue(".\\private$\\test2");
//创建一个消息
System.Messaging.Message myMessage = new System.Messaging.Message();
//给消息体赋值
myMessage.Body = "你好我是消息体";
myMessage.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
//发送消息到队列中（创建队列时勾选了事务性之后不能直接使用 public void Send(object obj) 这个方法因为其不支持事务） // 我要使用下面这个支持事务的发送方法
myQueue.Send(myMessage,System.Messaging.MessageQueueTransactionType.Single); }
catch (ArgumentException ex)
{
Console.WriteLine(ex.Message);
}

发完消息之后就要接收消息

消息的接受使用Receive()方法

但是该方法会阻塞线程

所以建议将其放到一个独立的线程中，不让其影响其他线程的运行

//创建一个任务让其不断的在接收消息队列发出的消息
Task t = Task.Factory.StartNew(() => {
while (true)
{
//创建队列要跟发消息的队列同一个名称
MessageQueue mq = new MessageQueue(@".\private$\test2"); // 如果不用多线程就会阻塞在Receive
System.Messaging.Message m = mq.Receive(); //定义内容格式
m.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) }); //接收到消息后回去更新主线程的UI界面
Action<String> AsyncUIDelegate = delegate (string n)
{
this.ReceiveText2.Text = n; //对ui的操作
};//定义一个委托
this.ReceiveText2.Invoke(AsyncUIDelegate, new object[] { m.Body.ToString() });
}
});

测试效果：