当前位置:  编程技术>.net/c#/asp.net

.Net消息队列的使用方法

    来源: 互联网  发布时间:2014-08-25

    本文导语:  .Net使用消息队列,借助windows组件来存储要完成的一系列任务,不用程序使用同一个队列,方便不同程序之间的数据共享和协作…… 以本人经验,这个在某个方面类似于session(当然还有很多方面不同),相同之处:session可以把...

.Net使用消息队列,借助windows组件来存储要完成的一系列任务,不用程序使用同一个队列,方便不同程序之间的数据共享和协作……

以本人经验,这个在某个方面类似于session(当然还有很多方面不同),相同之处:session可以把信息存储在aspnet_state服务中,网站重新编译或者重新启动网站,session不会丢失(session超时是正常情况,这种情况除外)。

win7中安装消息队列组件,其他操作系统请百度搜索相关资料。


 

如果服务没有自动启动,需要启动服务:

先创建队列,再使用队列,队列中的消息,发送一个多一个,接收一个少一个,先进先出。

代码如下:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Messaging;
//添加物理文件 System.Messaging 的引用
namespace testweb
{
    public partial class MSMQtest : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            //CreateNewQueue("MsgQueue");//创建一个消息队列
            //sendSimpleMsg();//每一个队列最好只发送和接收同一种格式的信息,不然不好转换格式。
            //receiveSimpleMsg();//
            //receiveSimpleMsg();
            //sendComplexMsg();
            //receiveComplexMsg();
            MsgModel m = receiveComplexMsg();
            Response.Write(m.ToString());

        }
        private void sendSimpleMsg()
        {
            //实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
            MessageQueue MQ = new MessageQueue(@".private$MsgQueue");
            //MQ.Send("消息测试", "测试消息");
            System.Messaging.Message message = new System.Messaging.Message();
            message.Label = "消息lable";
            message.Body = "消息body";
            MQ.Send(message);

            Response.Write("成功发送消息," + DateTime.Now + "
");
        }
        private void receiveSimpleMsg()
        {
            MessageQueue MQ = new MessageQueue(@".private$MsgQueue");
            //调用MessageQueue的Receive方法接收消息
            if (MQ.GetAllMessages().Length > 0)
            {
                System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
                if (message != null)
                {
                    //message.Formatter = new System.Messaging.XmlMessageFormatter(new string[] { "Message.Bussiness.VideoPath,Message" });//消息类型转换
                    message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
                    Response.Write(string.Format("接收消息成功,lable:{0},body:{1},{2}
", message.Label, message.Body.ToString(), DateTime.Now));
                }
            }
            else
            {
                Response.Write("没有消息了!
");
            }
        }
        private void sendComplexMsg()
        {
            //实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
            MessageQueue MQ = new MessageQueue(@".private$MsgQueue");
            //MQ.Send("消息测试", "测试消息");
            System.Messaging.Message message = new System.Messaging.Message();
            message.Label = "复杂消息lable";
            message.Body = new MsgModel("1", "消息1");
            MQ.Send(message);

            Response.Write("成功发送消息,"+DateTime.Now+"
");
        }
        private void receiveComplexMsg()
        {
            MessageQueue MQ = new MessageQueue(@".private$MsgQueue");
            //调用MessageQueue的Receive方法接收消息
            if (MQ.GetAllMessages().Length > 0)
            {
                System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
                if (message != null)
                {
                    message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(MsgModel) });//消息类型转换
                    MsgModel msg = (MsgModel)message.Body;
                    Response.Write(string.Format("接收消息成功,lable:{0},body:{1},{2}
", message.Label, msg, DateTime.Now));
                }
            }
            else
            {
                Response.Write("没有消息了!
");
            }
        }
        private T receiveComplexMsg()
        {
            MessageQueue MQ = new MessageQueue(@".private$MsgQueue");
            //调用MessageQueue的Receive方法接收消息
            if (MQ.GetAllMessages().Length > 0)
            {
                System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
                if (message != null)
                {
                    message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(T) });//消息类型转换
                    T msg = (T)message.Body;
                    return msg;
                }
            }

            return default(T);
        }

        ///
        /// 创建消息队列
        ///
        /// 消息队列名称
        ///
        public void CreateNewQueue(string name)
        {
            if (!System.Messaging.MessageQueue.Exists(".\private$\" + name))//检查是否已经存在同名的消息队列
            {

                System.Messaging.MessageQueue mq = System.Messaging.MessageQueue.Create(".\private$\" + name);
                mq.Label = "private$\"+name;
                Response.Write("创建成功!
");
            }
            else
            {
                //System.Messaging.MessageQueue.Delete(".\private$\" + name);//删除一个消息队列
                Response.Write("已经存在
");
            }
        }

    }
    [Serializable]
    public class MsgModel
    {
        public string id { get; set; }
        public string Name { get; set; }
        public MsgModel() { }
        public MsgModel(string _id, string _Name)
        {
            id = _id;
            Name = _Name;
        }
        public override string ToString()
        {
            if (string.IsNullOrEmpty(id) || string.IsNullOrEmpty(Name)) return "";
            return string.Format("id--{0},Name--{1}",id,Name);
        }
    }
}


    
 
 

您可能感兴趣的文章:

  • iis支持asp.net4.0的注册命令使用方法
  • .net4.0中tuple元组的使用方法
  • ASP.NET使用Subtract方法获取两个日期之间的天数
  • 请教:使用java.net中httpURLConnection类模拟post方法?、、全部分数送上!
  • ?请教:十万火急使用java.net中httpURLConnection类模拟post方法?、、全部分数送
  • asp.net错误捕获(错误处理)page_error事件使用方法
  • log4net配置和使用方法分享
  • asp.net使用URLRewriter.dll进行重写的方法举例
  • ASP.NET网站伪静态下使用中文URL的方法
  • asp.net字符串分割函数使用方法分享
  • asp.net中的*.ashx类型的文件使用方法简单
  • VB.NET中Caching的使用方法
  • 关于C# 5.0 CallerMemberName CallerFilePath CallerLineNumber 在.NET4中的使用介绍方法
  • C#实现只运行单个实例应用程序的方法(使用VB.Net的IsSingleInstance)
  • .NET的file文件上传控件使用方法 修改web.config文件上传大文件
  • asp.net使用ashx实现图片防盗链的方法
  • .NET中保证线程安全的高级方法Interlocked类使用介绍
  • asp.net数据绑定DataBind使用方法
  • GMap.Net开发之自定义Marker使用方法
  • asp.net后台如何输出js脚本使用什么方法可以实现
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • 两台linux机器如何发送消息,如win2000下面的net send ?
  • asp.net弹出消息框、确认框的代码汇总
  • asp.net 即时消息提示的实现代码
  • java命名空间javax.net类socketfactory的类成员方法: createsocket定义及介绍
  • .NET版的ExtJS库 Ext.Net
  • java命名空间java.net类datagramsocket的类成员方法: disconnect定义及介绍
  • node.js的.net扩展 node.net
  • java命名空间java.net类datagramsocket的类成员方法: close定义及介绍
  • 为什么输http://www.china-java.net,会自动改为http://www.china-java.net:8081?
  • java命名空间java.net接口cookiestore的类成员方法: get定义及介绍
  • make menuconfig时出错:net/Kconfig:221:can't open file "net/wireless/Kconfig" iis7站长之家
  • java命名空间java.net类socket的类成员方法: isbound定义及介绍
  • 【人才】有没有人会用VC6.0/VS2003.NET/VS2005.NET写WINDOWS下的驱动程序呀。
  • java命名空间java.net类datagrampacket的类成员方法: getsocketaddress定义及介绍
  • Java.NET or J#.NET is coming!
  • java命名空间java.net类multicastsocket的类成员方法: getinterface定义及介绍
  • make menuconfig时出错:net/Kconfig:221:can't open file "net/wireless/Kconfig"
  • java命名空间java.net枚举proxy.type的类成员方法: http定义及介绍
  • 用过net-snmp(ucd-snmp)的大侠用过net-snmp(ucd-snmp)请进(来者有分)
  • java命名空间java.net类urisyntaxexception的类成员方法: getreason定义及介绍
  • 常用.NET工具(包括.NET可再发行包2.0)下载
  • java命名空间java.net类datagramsocketimpl的类成员方法: getlocalport定义及介绍
  • Ja.Net
  • java命名空间java.net类httpretryexception的类成员方法: getreason定义及介绍
  • asp.net判断数据库表是否存在 asp.net修改表名的方法


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3