快捷搜索:

一个关于C#操作消息队列的代码

  这是一个关于C#操作消息队列的代码,给新手朋友学习下,并不是很难,相信大家看看就能明白的。

以下是引用片段:
  public class QueueManage
  {
  ///
  /// 发送对象到队列中
  ///
  ///
  队列名称,因为队列名称在一个应用中应该不改变的,所以大家最好写在配置文件中
  ///
  要发出去的对象
  public static void SendQueue(string QueuePath,MyBase.SmsQueue sq)
  {
  System.Messaging.MessageQueue mqSend=new System.Messaging.MessageQueue(QueuePath,false);
  EnsureQueueExists(QueuePath);
  mqSend.Send(sq);
  }
  ///
  /// 检查队列,如果队列不存在,则建立
  ///
  ///
  队列名称
  private static void EnsureQueueExists(string path)
  {
  if(!MessageQueue.Exists(path))
  {
  if(!MessageQueue.Exists(path))
  {
  MessageQueue.Create(path);
  MessageQueue mqTemp=new MessageQueue(path);
  mqTemp.SetPermissions("Everyone",System.Messaging.MessageQueueAccessRights.FullControl);
  ///不知道该给什么样的权限好,所以就给了Everone全部权限了,当然大家最好自己控制一下
  }
  }
  }
  ///
  /// 从队列中取出对象列表
  ///
  ///
  队列名称
  public static System.Collections.ArrayList GetMessage(string QueuePath)
  {
  MyBase.SmsQueue sq=new MyBase.SmsQueue();
  System.Messaging.MessageQueue mq=new System.Messaging.MessageQueue(QueuePath,false);
  mq.Formatter=new XmlMessageFormatter(new Type[] {typeof(MyBase.SmsQueue)});
  System.Messaging.Message[] arrM=mq.GetAllMessages();
  mq.Close();
  System.Collections.ArrayList al=new System.Collections.ArrayList();
  foreach(System.Messaging.Message m in arrM)
  {
  sq=(TimeFound.SmsGate.Base.SmsQueue)m.Body;
  al.Add(sq);
  }
  return al;
  }
  }
 

作者:佚名责任编辑:幽灵)

天极新媒体 最酷科技资讯

扫码赢大奖

评论

* 网友发言均非本站立场,本站不在评论栏推荐任何网店、经销商,谨防上当受骗!

您可能还会对下面的文章感兴趣: