在C#中使用MSMQ的方法

更新时间：2021年01月25日 11:36:57 作者：码农译站

这篇文章主要介绍了在C#中使用MSMQ的方法，帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下

MSMQ (Microsoft消息队列)是Windows中默认可用的消息队列。作为跨计算机系统发送和接收消息的可靠方法，MSMQ提供了一个可伸缩、线程安全、简单和使用方便的队列，同时为你提供了在Windows数据库中持久化消息的机会。MSDN指出:“消息队列(MSMQ)技术使在不同时间运行的应用程序能够在可能暂时离线的异构网络和系统之间进行通信。应用程序将消息发送到队列并从队列读取消息。”

在使用MSMQ时，通常有两个不同的应用程序——发送者和接收者。当消息由发送者发送时，接收者应用程序不需要处于执行状态——消息实际上存储在由主机操作系统维护的队列中，当接收方应用程序需要它们时，这些消息就会脱离队列。

创建一个队列

你可以通过控制面板上的“打开或关闭Windows功能”选项打开你系统中的MSMQ。在系统中安装了MSMQ之后，创建队列就很简单了。只要到“我的电脑”，右击并选择管理。在“计算机管理”窗口中，你可以从“消息队列”节点创建一个新队列。还可以通过编程方式创建队列。

C#中的MSMQ

要使用MSMQ，你需要引入System.Messaging命名空间。要以编程方式创建队列，需要利用MessageQueue类的Create方法。下面的代码片段说明了这一点。

MessageQueue.Create(@".\Private$\IDG");

要创建队列并向其发送消息，可以使用以下代码片段：

messageQueue = new MessageQueue(@".\Private$\IDG");
messageQueue.Label = "This is a test queue.";
messageQueue.Send("This is a test message.", "IDG");

现在，假设你想检查队列是否存在，如果存在，则发送一条消息给它。如果队列不存在，你可能希望创建一个新队列，然后向它发送消息。这正是下面的代码清单所做的。

static void Main(string[] args)
{
  MessageQueue messageQueue = null;
  string description = "This is a test queue.";
  string message = "This is a test message.";
  string path = @".\Private$\IDG";
  try
  {
    if (MessageQueue.Exists(path))
    {
      messageQueue = new MessageQueue(path);
      messageQueue.Label = description;
    }
    else
    {
      MessageQueue.Create(path);
      messageQueue = new MessageQueue(path);
      messageQueue.Label = description;
    }
    messageQueue.Send(message);
  }
  catch
  {
    throw;
  }
  finally
  {
    messageQueue.Dispose();
  }
}

下面的代码清单演示了如何使用c#处理存储在消息队列中的消息。

private static List<string> ReadQueue(string path)
{
  List<string> lstMessages = new List<string>();
  using (MessageQueue messageQueue = new MessageQueue(path))
  {
    System.Messaging.Message[] messages = messageQueue.GetAllMessages();
    foreach (System.Messaging.Message message in messages)
    {
      message.Formatter = new XmlMessageFormatter(
      new String[] { "System.String, mscorlib" });
      string msg = message.Body.ToString();
      lstMessages.Add(msg);
    }
  }
  return lstMessages;
}

接下来，可以调用ReadQueue方法来检索存储在消息队列中的消息，如下面的代码片段所示。

string path = @".\Private$\IDG";
List<string> lstMessages = ReadQueue(path);

你还可以在消息队列中存储对象。例如，假设你需要将日志消息存储到队列中。日志消息存储在LogMessage类的一个实例中，该实例包含与日志消息的详细信息相关的必要属性。下面是LogMessage类——我只使用了两个属性来使它变得简单。

public class LogMessage
{
  public string MessageText { get; set; }
  public DateTime MessageTime { get; set; }
}

你应该修改LogMessage类，以包含其他必要的属性，例如，消息严重性等。下面的方法说明了如何将LogMessage类的实例存储到消息队列中。

private static void SendMessage(string queueName, LogMessage msg)
{
  MessageQueue messageQueue = null;
  if (!MessageQueue.Exists(queueName))
    messageQueue = MessageQueue.Create(queueName);
  else
    messageQueue = new MessageQueue(queueName);
  try
  {
    messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(LogMessage) });
    messageQueue.Send(msg);
  }
  catch
  {
    //Write code here to do the necessary error handling.
  }
  finally
  {
    messageQueue.Close();
  }
}

下面的代码片段说明了如何创建LogMessage类的实例，向其填充数据，然后调用SendMessage方法来存储在消息队列中创建的实例。

LogMessage msg = new LogMessage()
{
  MessageText = "This is a test message.",
  MessageTime = DateTime.Now
};
SendMessage(@".\Private$\IDGLog", msg);

下面的代码清单演示了如何读取存储在消息队列中的LogMessage实例。

private static LogMessage ReceiveMessage(string queueName)
{
  if (!MessageQueue.Exists(queueName))
    return null;
  MessageQueue messageQueue = new MessageQueue(queueName);
  LogMessage logMessage = null;
  try
  {
    messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(LogMessage) });
    logMessage = (LogMessage)messageQueue.Receive().Body;
  }
  catch { }
  finally
  {
    messageQueue.Close();
  }
  return logMessage;
}

以上就是在C#中使用MSMQ的方法的详细内容，更多关于c# 使用msmq的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

c#
MSMQ

C#微信公众号开发之使用MessageHandler简化消息处理流程
这篇文章介绍了C#微信公众号开发之使用MessageHandler简化消息处理流程，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-06-06
winform基于异步委托实现多线程摇奖器
这篇文章主要介绍了winform基于异步委托实现多线程摇奖器的方法,包含了线程的运用及随机数的生成,需要的朋友可以参考下
2014-10-10
C#中常用的正则表达式
本文主要介绍了C#中常用的正则表达式。具有一定的参考价值，下面跟着小编一起来看下吧
2017-01-01
C#中IList<T>与List<T>的区别深入解析
本篇文章主要是对C#中IList<T>与List<T>的区别进行了详细的分析介绍，需要的朋友可以过来参考下，希望对大家有所帮助
2014-01-01
c# 网络编程之tcp
这篇文章主要介绍了c# 网络编程之tcp的的相关资料，帮助大家更好的理解和学习使用c#，感兴趣的朋友可以了解下
2021-02-02
C#实现密码验证与输错密码账户锁定
这篇文章介绍了C#实现密码验证与输错密码账户锁定的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-04-04
C#实现语音播报功能
这篇文章主要为大家详细介绍了C#实现语音播报功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-03-03
C#创建缩略图操作类实例
这篇文章主要介绍了C#创建缩略图操作类,实例分析了C#创建缩略图的相关技巧,非常具有实用价值,需要的朋友可以参考下
2015-04-04
详解C#中delegate/event/EventHandler/Action/Func的使用和区别
这篇文章主要为大家详细介绍了C#中delegate、event、EventHandler、Action和Func的使用与区别，文中的示例代码讲解详细，感兴趣的可以了解一下
2023-04-04
C#实现AI五子棋游戏的示例代码
这篇文章主要为大家详细介绍了C#如何智能AI五子棋游戏中的人工下棋操作以及对应的机器操作，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-11-11