C#操作消息隊(duì)列

2024-07-21 02:19:32

字體：大中小

供稿：網(wǎng)友

public class queuemanage
{
///
/// 發(fā)送對象到隊(duì)列中
///
/// 隊(duì)列名稱，因?yàn)殛?duì)列名稱在一個(gè)應(yīng)用中應(yīng)該不改變的，所以大家最好寫在配置文件中
/// 要發(fā)出去的對象
public static void sendqueue(string queuepath,mybase.smsqueue sq)
{
system.messaging.messagequeue mqsend=new system.messaging.messagequeue(queuepath,false);
ensurequeueexists(queuepath);
mqsend.send(sq);
}

///
/// 檢查隊(duì)列，如果隊(duì)列不存在，則建立
///
/// 隊(duì)列名稱
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);
///不知道該給什么樣的權(quán)限好，所以就給了everone全部權(quán)限了，當(dāng)然大家最好自己控制一下
}
}
}

///
/// 從隊(duì)列中取出對象列表
///
/// 隊(duì)列名稱
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;

}

}

從以前的一個(gè)項(xiàng)目中摘抄出來的，大家參考一下吧。

上一篇：關(guān)于c#中的消息處理函數(shù)和vc中的消息處理函數(shù)區(qū)別

下一篇：關(guān)于webservice的異步調(diào)用簡單實(shí)例