VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > temp > C#教程 >
  • c#操作消息队列

制作者:剑锋冷月 单位:无忧统计网,www.51stat.net
 

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;
}
}



相关教程