zoukankan      html  css  js  c++  java
  • C#操作消息队列的代码开发者在线 Builder.com.cn 更新时间:20080720作者: 来源:

    C#操作消息队列的代码开发者在线 Builder.com.cn更新时间:2008-07-20作者:来源:本文关键词:队列C#应用C#这是一个关于C#操作消息队列的代码,给新手朋友学习下,并不是很难,相信大家看看就能明白的。

    以下是引用片段:
    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[] );
    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;
    }
    }



  • 相关阅读:
    1.1、Go快速入坟系列之循环与分支
    1.0、Go快速入坟系列之变量、常量与算术运算符
    0.0、Go快速入坟系列配置与安装Go环境
    使用Docker部署.Net Core项目
    留言板
    List实体中不同字段值的转换
    Yum安装,Linux自带Python卸载 安装
    CentOS7系统配置国内yum源和epel源
    Centos7安装jdk1.8
    VUE下载文件,下载后台返回的response
  • 原文地址:https://www.cnblogs.com/zhiji6/p/1649402.html
Copyright © 2011-2022 走看看