我学MSMQ(二)

我学MSMQ(二)

  上次我主要学习的是MSMQ的基本的概念、安装消息队列和新建了一个简单的队列。
      现在我就继续学习关于消息队列的接收

先还是概念
         消息的接收又分成同步和异步方式两种,同步接收在规定时间内从消息队列中取出收到的第一条消息,当消息队列中没有消息时,程序处于等待状态;异步接收方式则是定义了一个事件处理函数,当消息队列中第一个消息到达时立即触发该函数。 
接下来我就做个实验:

我学MSMQ(二)     private  void FSend()


我学MSMQ(二)    
{

我学MSMQ(二)        string queuename = “.\\private$\\testQueue”;//队列名称
我学MSMQ(二)        MessageQueue q;
我学MSMQ(二)        if (MessageQueue.Exists(queuename))
我学MSMQ(二)        {

我学MSMQ(二)            q = new System.Messaging.MessageQueue(queuename);
我学MSMQ(二)        }

我学MSMQ(二)        else
我学MSMQ(二)        {

我学MSMQ(二)            q = MessageQueue.Create(queuename);
我学MSMQ(二)        }

我学MSMQ(二)        Message m = new Message();
我学MSMQ(二)        m.Label = “MessageLabel”;      //描述消息的字串
我学MSMQ(二)        m.Body = Send.Text;        //消息的主体
我学MSMQ(二)        q.Send(m);                      //发送
我学MSMQ(二)    }

发送消息,上次做过一个,很简单
然后我就做了同步接收的方法:

我学MSMQ(二)     private  void Recevie()


我学MSMQ(二)    
{

我学MSMQ(二)        string queuename = “.\\private$\\testQueue”;//队列名称
我学MSMQ(二)        MessageQueue q;
我学MSMQ(二)        q = new System.Messaging.MessageQueue(queuename);
我学MSMQ(二)        Message m = q.Receive();
我学MSMQ(二)        m.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
我学MSMQ(二)        Recieve.Text = m.Body.ToString();
我学MSMQ(二)    }

然后看结果
我学MSMQ(二)
然后我们在证实下“同步接收在规定时间内从消息队列中取出收到的第一条消息,当消息队列中没有消息时,程序处于等待状态” 。
我学MSMQ(二)
大家有看到进度条吗?它就一直在等待中,然后我再打开一个页面,再发送一个消息,我们就能看到,他马上就能接收
我学MSMQ(二) 
做完了同步的,然后我继续在实验异步的,看看消息队列是怎么操作的

我学MSMQ(二)     private  void RecevieAsynchronism()


我学MSMQ(二)    
{

我学MSMQ(二)        string queuename = “.\\private$\\testQueue”;                                 //队列名称
我学MSMQ(二)        MessageQueue q;
我学MSMQ(二)        q = new System.Messaging.MessageQueue(queuename);
我学MSMQ(二)        Message m=q.Peek();                                                           //不删除接收到的消息
我学MSMQ(二)                                                                                    //被动方式,异步调用方式,不会阻塞当前线程
我学MSMQ(二)    q.ReceiveCompleted +=new ReceiveCompletedEventHandler( ReceivedEvt);            //事件
我学MSMQ(二)    q.BeginReceive(); 
我学MSMQ(二)                       
我学MSMQ(二)    }



我学MSMQ(二)


我学MSMQ(二)     public   void ReceivedEvt( object source, ReceiveCompletedEventArgs asyncResult)


我学MSMQ(二)    
{

我学MSMQ(二)        //其中ReceivedEvt要么为静态函数,要么必须是属于实例化的对象的可访问函数
我学MSMQ(二)        try
我学MSMQ(二)        {

我学MSMQ(二)            MessageQueue mq = (MessageQueue)source;
我学MSMQ(二)            Message m = mq.EndReceive(asyncResult.AsyncResult);
我学MSMQ(二)            //此事m为异步接收到的消息
我学MSMQ(二)            //在此插入处理消息的代码 
我学MSMQ(二)            m.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
我学MSMQ(二)            t_Recieve.Text = m.Body.ToString();
我学MSMQ(二)            mq.BeginReceive();//接收下一次事件
我学MSMQ(二)        }

我学MSMQ(二)        catch (MessageQueueException)
我学MSMQ(二)        {

我学MSMQ(二)
我学MSMQ(二)        }

我学MSMQ(二)        return;
我学MSMQ(二)    }

首先定义了一个事件,当第一个消息到达的时候,就触发事件,读取消息.首先我们先来看结果
我学MSMQ(二)
我们按发送消息,然后在按接受消息,发现他竟然是等待,为什么呢?
下面是我个人的理解,不是对否,希望有人指出
首先在按发送消息的时候,其实就有了第一个消息,然后就触发了事件,已经把消息读了出来,所以在按接受按钮的时候,就没有了消息,就只能等待,可是还有个问题,既然实现了事件,那事件里面不是有对文本框进行赋值的吗?其实他只要是异步的原因,因为这个事件在后台运行的,真正的asp.net的代码已经返回给客户端了,不知道我这样理解是否正确

今天只要是学习了同步和异步的接收消息,但是还有很多的问题还没搞清楚,比如 消息的并发性,怎么结合数据库使用,怎么样发送复杂的消息等等,这些问题还有待解决

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/109905.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • STM32F4(用SysTick实现Delay函数)[通俗易懂]

    STM32F4(用SysTick实现Delay函数)[通俗易懂]STM32F4(用SysTick实现Delay函数)1,开发环境     1,适用芯片:STM32F4全部芯片    2,固件库:STM32F4xx_DSP_StdPeriph_Lib_V1.8.0     3,IDE:MDK5172,驱动源码     Delay.h文件/**************************************

    2022年5月7日
    95
  • seo绩效考核指标_kpi考核三大指标内容

    seo绩效考核指标_kpi考核三大指标内容想要知道SEO优化有没有效果,都是需要以网站数据为前提的,包括网站收录情况、关键词排名情况、网站流量的多少及网站访客转化情况等,来算出最终的投入产出比是多少。一、内容页面关键词排名考核指标利用原创内容矩阵可以实现对某一类长尾关键词的覆盖,也是达成目标的一个基础手段,为此你可以在数据监测软件中对这部分关键词进行定期跟踪,确保达到预期效果。二、外链的数量与质量高质量的原创内容是获取高质量外链的…

    2022年9月18日
    0
  • mt4电脑版下载_mt4安卓版官网下载

    mt4电脑版下载_mt4安卓版官网下载mt4作为大部分投资者使用的交易软件,在版本上也是非常全面,涵盖了手机和电脑版。手机端和电脑版各有优势,手机端可以让交易者随时随地下单,查看行情,而电脑端利用指标分析行情上非常有优势,并且电脑端更方便于查看。今天来重点讲解一下电脑版MT4的下载和安装。电脑版的MT4首先是要找安装一个客户端,那第一步就是得下载安装包,电脑端的安装包都是去网页上下载qiejf。cn无论是软件的页面还是选择的平台的官网,都会有安装包可供下载。将安装包下载保存到电脑后,直接双击,根据提示点击下一步,安装即可。安装好了就

    2022年8月15日
    2
  • client的中文意思是什么_java中cin什么意思

    client的中文意思是什么_java中cin什么意思IE中: document.body.clientWidth==>BODY对象宽度 document.body.clientHeight==>BODY对象高度 document.documentElement.clientWidth==>可见区域宽度 document.documentElement.clientHeight==>可见区域高度 FireFox中:

    2022年9月11日
    0
  • c++图形界面开发_在界面用显示时间的步骤

    c++图形界面开发_在界面用显示时间的步骤BCGControlBarLibraryProfessionalEdition installation:整个库的源代码安装在\BCGCBPro目录下面.可执行文件(*.dll)安装在\Bin(forVisualStudio6.0)或\Bin7(forVisualStudio.NET)下面。请在你的源代码中做如下的改变:·                    

    2022年10月8日
    0
  • 迎接平价时代 光伏逆变器行业的演进和格局「建议收藏」

    迎接平价时代 光伏逆变器行业的演进和格局

    2022年3月4日
    44

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号