当前位置： 移动技术网 > IT编程>开发语言>.net > .Net消息队列的使用方法

.Net消息队列的使用方法

2017年12月12日  | 移动技术网IT编程  | 我要评论

通乐信息网,南通火车站网上订票,箭

.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<msgmodel>();
            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 + "<br/>");
        }
        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}<br/>", message.label, message.body.tostring(), datetime.now));
                }
            }
            else
            {
                response.write("没有消息了！<br/>");
            }
        }
        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+"<br/>");
        }
        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}<br/>", message.label, msg, datetime.now));
                }
            }
            else
            {
                response.write("没有消息了！<br/>");
            }
        }
        private t receivecomplexmsg<t>()
        {
            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);
        }

        /// <summary>
        /// 创建消息队列
        /// </summary>
        /// <param name="name">消息队列名称</param>
        /// <returns></returns>
        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("创建成功！<br/>");
            }
            else
            {
                //system.messaging.messagequeue.delete(".\\private$\\" + name);//删除一个消息队列
                response.write("已经存在<br/>");
            }
        }

    }
    [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);
        }
    }
}

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网