上次我主要学习的是MSMQ的基本的概念、安装消息队列和新建了一个简单的队列。
现在我就继续学习关于消息队列的接收
先还是概念
消息的接收又分成同步和异步方式两种,同步接收在规定时间内从消息队列中取出收到的第一条消息,当消息队列中没有消息时,程序处于等待状态;异步接收方式则是定义了一个事件处理函数,当消息队列中第一个消息到达时立即触发该函数。
接下来我就做个实验:
{
string queuename = “.\\private$\\testQueue”;//队列名称
MessageQueue q;
if (MessageQueue.Exists(queuename))
{
q = new System.Messaging.MessageQueue(queuename);
}
else
{
q = MessageQueue.Create(queuename);
}
Message m = new Message();
m.Label = “MessageLabel”; //描述消息的字串
m.Body = Send.Text; //消息的主体
q.Send(m); //发送
}
发送消息,上次做过一个,很简单
然后我就做了同步接收的方法:
{
string queuename = “.\\private$\\testQueue”;//队列名称
MessageQueue q;
q = new System.Messaging.MessageQueue(queuename);
Message m = q.Receive();
m.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
Recieve.Text = m.Body.ToString();
}
然后看结果
然后我们在证实下“同步接收在规定时间内从消息队列中取出收到的第一条消息,当消息队列中没有消息时,程序处于等待状态” 。
大家有看到进度条吗?它就一直在等待中,然后我再打开一个页面,再发送一个消息,我们就能看到,他马上就能接收
做完了同步的,然后我继续在实验异步的,看看消息队列是怎么操作的
{
string queuename = “.\\private$\\testQueue”; //队列名称
MessageQueue q;
q = new System.Messaging.MessageQueue(queuename);
Message m=q.Peek(); //不删除接收到的消息
//被动方式,异步调用方式,不会阻塞当前线程
q.ReceiveCompleted +=new ReceiveCompletedEventHandler( ReceivedEvt); //事件
q.BeginReceive();
}
public void ReceivedEvt( object source, ReceiveCompletedEventArgs asyncResult)
{
//其中ReceivedEvt要么为静态函数,要么必须是属于实例化的对象的可访问函数
try
{
MessageQueue mq = (MessageQueue)source;
Message m = mq.EndReceive(asyncResult.AsyncResult);
//此事m为异步接收到的消息
//在此插入处理消息的代码
m.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
t_Recieve.Text = m.Body.ToString();
mq.BeginReceive();//接收下一次事件
}
catch (MessageQueueException)
{
}
return;
}
首先定义了一个事件,当第一个消息到达的时候,就触发事件,读取消息.首先我们先来看结果
我们按发送消息,然后在按接受消息,发现他竟然是等待,为什么呢?
下面是我个人的理解,不是对否,希望有人指出
首先在按发送消息的时候,其实就有了第一个消息,然后就触发了事件,已经把消息读了出来,所以在按接受按钮的时候,就没有了消息,就只能等待,可是还有个问题,既然实现了事件,那事件里面不是有对文本框进行赋值的吗?其实他只要是异步的原因,因为这个事件在后台运行的,真正的asp.net的代码已经返回给客户端了,不知道我这样理解是否正确
今天只要是学习了同步和异步的接收消息,但是还有很多的问题还没搞清楚,比如 消息的并发性,怎么结合数据库使用,怎么样发送复杂的消息等等,这些问题还有待解决
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/109905.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...