.net 消息队列简单实例
时间：2010-09-28 来源：雷明
刚学习微软的消息队列，通过查找资料做了一个简单的实例，大概步骤和代码如下：
1、首页在操作系统上安装消息队列
控制面板—>添加安装程序：在IIS（window2003应用程序服务）下面，钩选"消息队列"
图一：
/Files/lmjob/clip_image002_thumb.jpg
2、新建ASP.NET Web应用程序，并添加引用"System.Messaging"类
3、创建消息、发送消息、接收消息代码：
/// <summary>
/// 创建消息队列
/// </summary>
/// <param name="name">消息队列名称</param>
/// <returns></returns>
public static string CreateNewQueue(string name)
{
if (!System.Messaging.MessageQueue.Exists(".\\private$\\" + name))//检查是否已经存在同名的消息队列
{
System.Messaging.MessageQueue mq = System.Messaging.MessageQueue.Create(".\\private$\\" + name);
mq.Label = "test";
return "ok";
}
else
{
return "已经存在";
}
}
/// <summary>
/// 同步发送消息
/// </summary>
/// <param name="input">发送的内容</param>
/// <param name="queueName">发送哪个消息队列中</param>
public static void SendMsg(string input, string queueName)
{
// System.Messaging.MessageQueue.Create(".\\private$\\test2");
System.Messaging.MessageQueue mq = new MessageQueue(".\\private$\\" + queueName);
System.Messaging.Message message = new System.Messaging.Message();
message.Body = input;
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
mq.Send(message);
}
/// <summary>
/// 同步发送消息
/// </summary>
/// <param name="input">发送的内容</param>
/// <param name="queueName">发送哪个消息队列中</param>
public static void SendMsg(string[] strList, string queueName)
{
System.Messaging.MessageQueue mq = new MessageQueue(".\\private$\\" + queueName);
System.Messaging.Message message = new System.Messaging.Message();
message.Body = strList;
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
mq.Send(message);
}
/// <summary>
/// 同步接收消息(消息为字符串)
/// </summary>
/// <param name="queueName">从哪个消息队列接受消息</param>
/// <returns></returns>
public static string ReceiveMsg(string queueName)
{
System.Messaging.MessageQueue mq = new MessageQueue(".\\private$\\" + queueName);
if (mq.GetAllMessages().Length == 0)//判断是否还有消息，如果没有消息的话Receive方法会一直独占进程直到有消息为止，所以必须判断
{
return "没有消息了";
}
else
{
Message m = mq.Receive();
m.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
return m.Body.ToString();
}
}
/// <summary>
/// 同步接收消息(消息为数组对象)
/// </summary>
/// <param name="queueName">从哪个消息队列接受消息</param>
/// <returns></returns>
public static string[] ReceiveMsgList(string queueName)
{
System.Messaging.MessageQueue mq = new MessageQueue(".\\private$\\" + queueName);
if (mq.GetAllMessages().Length == 0)//判断是否还有消息，如果没有消息的话Receive方法会一直独占进程直到有消息为止，所以必须判断
{
return null;
}
else
{
Message m = mq.Receive();
m.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string[]) });
return (string[])m.Body;
}
}
#region 发送消息事件
protected void btn_Send_Click(object sender, EventArgs e)
{
SendMsg(this.txt_Message.Text, "LmjobMsg");
//消息为数组对象
//string[] list = new string[] { "王一", "王二", "王三", "王四" };
//SendMsg(list, "LmjobMsg");
}
#endregion
#region 接收消息事件
protected void btn_Accept_Click(object sender, EventArgs e)
{
string messageBody = ReceiveMsg("LmjobMsg");
this.txt_Accept.Text = messageBody;
////如果消息为数组对象
//string[] messageBody = ReceiveMsgList("LmjobMsg");
//string messageValue = "";
//if (null != messageBody)
//{
// foreach (string a in messageBody)
// {
// messageValue += a+",";
// }
//}
//this.txt_Accept.Text = messageValue;
}
#endregion
经测试发现：1、如果接收到消息后，消息管理器在消息队列中立即删除该消息。2、消息队列可以传输多种类型数据（例：字符串、整形、对象等）
附：项目代码
/Files/lmjob/MSMQTest.rar
相关阅读 更多 +
