C#操作消息队列

向右看齐 2022-10-02 04:55 176阅读 0赞

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.MessageQueueAcce\*\*\*ights.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;  
  
\}  
  
\}  
  
原文地址： http://blog.csdn.net/21aspnet/article/details/1539881

转载于:https://blog.51cto.com/harlen/804482

发表评论取消回复

表情：

评论列表（有 0 条评论，176人围观）

还没有评论，来说两句吧...

相关阅读

相关 C++实现消息队列编程

C++实现消息队列编程消息队列是一种常见的进程间通信机制，它允许不同的进程通过发送和接收消息来进行通信。在C++中，我们可以使用标准库提供的消息队列类来实现消息队列编程。本

绝地灬酷狼/ 2024年03月03日 07:24/ 0 赞/ 95 阅读

相关 SpringCloud Stream操作消息队列

概述 ![format_png][] SpringCloud Stream是为微服务提供消息驱动能力的组件，使用就可以操作消息队列。应用程序通过input和outp

浅浅的花香味﹌/ 2023年07月05日 14:28/ 0 赞/ 4 阅读

相关 C#使用kafka消息队列

一：kafka介绍 kafka（官网地址：http://kafka.apache.org）是一种高吞吐量的分布式发布订阅的消息队列系统，具有高性能和高吞吐率。 1.1 术语

以你之姓@/ 2023年01月01日 03:58/ 0 赞/ 316 阅读

相关消息队列

1. 消息队列在项目中的使用背景：在分布式系统中是如何处理高并发的。由于在高并发的环境下，来不及同步处理用户发送的请求，则会导致请求发生阻塞。比如说，大量的ins

﹏ヽ暗。殇╰゛Y/ 2022年12月15日 03:23/ 0 赞/ 255 阅读

相关 C#操作消息队列

public class QueueManage \{ /// /// 发送对象到队列中 /// /// 队列名称，因为队列名称在一个应用中应该不改变的，所

向右看齐/ 2022年10月02日 04:55/ 0 赞/ 177 阅读

相关 linux c学习笔记——消息队列

ftok() \include <sys/types.h> \include <sys/ipc.h> 函数原型： key\_t ftok( const char \

╰+哭是因爲堅強的太久メ/ 2022年08月09日 16:34/ 0 赞/ 298 阅读

相关消息队列及其操作_读书笔记_8

4.5消息队列及其操作 4.5.1消息队列 (1)使用消息队列可在任务之间传递多条消息。 (2)消息队列由三部分组成：事件控制块、消息队列和消息。 1.消息指针数组

一时失言乱红尘/ 2022年07月16日 06:53/ 0 赞/ 221 阅读

相关 C#中使用消息队列服务

C\中使用Windows消息队列服务 [http://www.cnblogs.com/xinhaijulan/archive/2010/08/22/1805768.html]

痛定思痛。/ 2022年01月31日 07:34/ 0 赞/ 220 阅读

相关消息队列

为什么写这篇文章? 博主有两位朋友分别是小A和小B: 1. 小A，工作于传统软件行业(某社保局的软件外包公司)，每天工作内容就是和产品聊聊需求，改改业务逻辑。再不然就

小咪咪/ 2021年12月20日 06:51/ 0 赞/ 423 阅读

相关 linux c 消息队列简介

消息队列和共享内存、信号量一样，同属 System V IPC 通信机制。消息队列是一系列连续排列的消息，保存在内核中，通过消息队列的引用标识符来访问。使用消息队列的好处是对每

超、凢脫俗/ 2021年08月26日 15:27/ 0 赞/ 608 阅读