当前位置：首页 > 编程日记 > 正文

C#操作消息队列

编程日记 2024-11-09 03:50:00

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;

}

}

https://www.dkcj.cn/info/26696.html

C#操作消息队列

相关文章：

2021《程序员》数字科技企业研发实力榜TOP50

eclipse中java项目转换为web项目

MySQL · 引擎介绍 · Sphinx源码剖析(三)

C#给图片添加版权信息

Python + 爬虫：可视化大屏帮你选粽子

adviser vs mentor

T extends Serializable这是什么意思呢?看明白这个，你的问题就自然而然的明白了!...

C#中switch语句注意

对Cost (%CPU) 粗略的理解

后疫情时代，RTC期待新的场景大爆发

JS-DOM-元素节点

现代软件工程第十章【典型用户和场景】练习与讨论

赠书 | 读懂生成对抗神经网络 GAN，看这文就够了

把Doc文档转换成rtf格式

中国书法的造型元素与原理刘彦湖

融云任杰：强互动，RTC 下一个“爆点”场景 | 拟合

推荐一个个人感觉比较有吸引力的网站

C# 2进制、8进制、10进制、16进制...各种进制间的轻松转换

solrj操作单机solr

基于微软开源深度学习算法，用 Python 实现图像和视频修复

C#实现光盘做启动盘

为云服务立规矩——首批可信云服务认证名单公布

Java：多个文档合并输出到一个文档

线性表之顺序表(C语言实现)

C# POP3编程

终于有人把 Python 讲清楚了！

ASP.NET Core的配置（5）：配置的同步[设计篇]

C#分析数据库结构，使用XSL模板自动生成代码

超棒整理 | Python 关键字知识点大放送

linux下java进程占用高问题分析过程