电竞

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

2020-01-16 22:21:05来源:励志吧0次阅读

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

publicclassQueueManage

{

///

///发送对象到队列中

///

///

队列名称,因为队列名称在一个应用中应该不改变的,所以大家最好写在配置文件中

///

要发出去的对象

publicstaticvoidSendQueue(stringQueuePath,MyBase.SmsQueuesq)

{

System.Messaging.MessageQueuemqSend=newSystem.Messaging.MessageQueue(QueuePath,false);

EnsureQueueExists(QueuePath);

mqSend.Send(sq);

}

///

///检查队列,如果队列不存在,则建立

///

///

队列名称

privatestaticvoidEnsureQueueExists(stringpath)

{

if(!MessageQueue.Exists(path))

{

if(!MessageQueue.Exists(path))

{

MessageQueue.Create(path);

MessageQueuemqTemp=newMessageQueue(path);

mqTemp.SetPermissions("Everyone",System.Messaging.MessageQueueAccessRights.FullControl);

///不知道该给什么样的权限好,所以就给了Everone全部权限了,当然大家最好自己控制一下

}

}

}

///

///从队列中取出对象列表

///

///

队列名称

publicstaticSystem.Collections.ArrayListGetMessage(stringQueuePath)

{

MyBase.SmsQueuesq=newMyBase.SmsQueue();

System.Messaging.MessageQueuemq=newSystem.Messaging.MessageQueue(QueuePath,false);

mq.Formatter=newXmlMessageFormatter(newType[]{typeof(MyBase.SmsQueue)});

System.Messaging.Message[]arrM=mq.GetAllMessages();

mq.Close();

System.Collections.ArrayListal=newSystem.Collections.ArrayList();

foreach(System.Messaging.MessageminarrM)

{

sq=(TimeFound.SmsGate.Base.SmsQueue)m.Body;

al.Add(sq);

}

returnal;

}

}

查看本文来源

小孩脸色发黄怎么回事
首荟通便胶囊可以治疗便秘吗
心血管堵塞吃通心络能疏通吗
治疗腰腿疼的药哪个好
分享到: