C# 使用 Windows 消息队列机制
2012-04-17 23:06
741 查看
C# 使用 Windows 消息队列机制
保存消息队列数据的本地磁盘地址:C:\WINDOWS\system32\msmq\storage注意:
1,要使用 windows 消息队列机制,必须在该 windows操作系统中先安装“ windows 消息队列” 组件(从操作系统光盘中) ;
2,要使用启用消息队列,必须先启动“Messenger”服务(传输客户端和服务器之间的 NET SEND 和 Alerter 服务消息。此服务与 Windows Messenger 无关。如果服务停止,Alerter 消息不会被传输。如果服务被禁用,任何直接依赖于此服务的服务将无法启动。);
控件:
代码
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Messaging;
using System.Xml.Serialization;
namespace MessageQueuingExample
{
public partial class Form1 : Form
{
//The . in the queueName represents localhost
private const string queueName = ".\\Private$\\Liuq";
//private const string queueName = "A405\\Private$\\Liuq";
//We need this class-wide to access it in the methods.
MessageQueue queue = null;
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
//Create the queue if it doesn't exist.
CreateQueue();
}
private void CreateQueue()
{
//Does the queue already exist??
if (MessageQueue.Exists(queueName))
//Yes, it's already there.
queue = new MessageQueue(queueName);
else
//No, we need to create it.
queue = MessageQueue.Create(queueName, false);
}
private void btnSendMessage_Click(object sender, EventArgs e)
{
//Instantiate our MessageContent object.
MessageContent message = new MessageContent("Hello world!");
//Send it to the queue.
queue.Send(message, "Sample Message");
MessageBox.Show("Message sent.", "MSMQ");
}
private void btnEnumerateMessages_Click(object sender, EventArgs e)
{
//Clear the textbox.
this.txtMessages.Clear();
//Get all messages on the queue.
System.Messaging.Message[] messages = queue.GetAllMessages();
//Loop through the messages.
foreach (System.Messaging.Message message in messages)
{
//Set the formatter for the message.
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[1] { typeof(MessageContent) });
//Get the MessageContent object out of the message.
MessageContent content = (MessageContent)message.Body;
//Update the textbox.
this.txtMessages.Text += content.MessageText + " - " + content.CreationDate.ToString() + "\r\n";
}
}
private void btnRemoveMessages_Click(object sender, EventArgs e)
{
//Purge all messages from the queue.
queue.Purge();
MessageBox.Show("Messages purged", "MSMQ");
}
private void btnSendHighestPriorityMessage_Click(object sender, EventArgs e)
{
//Create a XmlSerializer for the object type we're sending.
XmlSerializer serializer = new XmlSerializer(typeof(MessageContent));
//Instantiate a new message.
System.Messaging.Message queueMessage = new System.Messaging.Message();
//Set the priority to Highest.
queueMessage.Priority = MessagePriority.Highest;
//Create our MessageContent object.
MessageContent messageContent = new MessageContent("Hello world - IMPORTANT!");
//Serialize the MessageContent object into the queueMessage.
serializer.Serialize(queueMessage.BodyStream, messageContent);
//Send the message.
queue.Send(queueMessage, "HIGH PRIORITY");
MessageBox.Show("Important message sent.", "MSMQ");
}
}
}
相关文章推荐
- C# 使用 Windows 消息队列机制
- C#中使用Windows消息队列服务(MSMQ)简单示例
- C#编写Windows服务程序 (服务端),客户端使用 消息队列 实现淘宝 订单全链路效果
- C#编写Windows服务程序 (服务端),client使用 消息队列 实现淘宝 订单全链路效果
- C#中使用Windows消息队列服务(MSMQ)简单示例
- c# .net windows消息队列简单应用示例
- 二、消息队列之如何在C#中使用RabbitMQ
- Linux的消息队列,Windows的邮件槽,使用有感
- Windows消息机制的流程及PreTranslateMessage作用和使用方法
- 使用微软消息队列实现C#进程间通信
- 使用C#来操作消息队列
- 腾讯云CMQ消息队列在Windows环境下的使用
- windows编程(消息机制、消息队列、消息映射、线程同步)笔记windows编程(消息机制、消息队列、消息映射、线程同步)笔记
- 微软消息队列(MSMQ)配置使用小结(c#)
- 在C#中使用消息队列RabbitMQ
- Windows消息响应机制之三:线程与消息队列 .
- C#环境下使用Windows消息传递字符串数据的研究
- 使用微软消息队列实现C#进程间通信
- C++的console使用windows的消息机制,定时器等
- 使用微软消息队列实现C#进程间通信