操作消息队列代码,Asp.NET代码库,德仔网

代码语言
代码分类
【Asp.NET】操作消息队列
作者:知冀 / 发布于2016/9/9/ 895
public partial class _Default : System.Web.UI.Page
{
   private string queuePath = @".\Private$\mydemoqueues";
   protected void Page_Load(object sender, EventArgs e)
   {
       //异步获取消息
       GetQueueMessage();
   }
   protected void Button1_Click(object sender, EventArgs e)
   {
       MessageQueue mq;
       if(MessageQueue.Exists(@".\Private$\mydemoqueues"))
       {
           mq=new MessageQueue(@".\Private$\mydemoqueues");
       }
       else
       {
           mq = MessageQueue.Create(@".\Private$\mydemoqueues");    
       }
       BinaryWriter writer=new BinaryWriter(new MemoryStream());
       writer.Write(this.TextBox1.Text.Trim());
       Message msg=new Message();
       msg.BodyStream = writer.BaseStream;
       msg.Label = "发送信息,飘渺峰测试";
       mq.Send(msg);

   }
   protected void Button2_Click(object sender, EventArgs e)
   {
       MessageQueue mq;
       Message msg=new Message();
       string result;
       if (MessageQueue.Exists(queuePath))
       {
           mq=new MessageQueue(queuePath);
       }
       else
       {
           mq = MessageQueue.Create(queuePath);
       }
       try
       {
           mq.MaximumQueueSize = 1000000;
           msg = mq.Receive(new TimeSpan(0, 0, 3));
           BinaryReader br=new BinaryReader(msg.BodyStream);
           result=new string(br.ReadChars(Convert.ToInt32(msg.BodyStream.Length)));
           this.TextBox2.Text = result;
           mq.Close();
       }
       catch (Exception)
       {
           Response.Write("没有消息可以接收!");
       }
   }
   /// <summary>
   /// 异步获取消息队列
   /// </summary>
   private void GetQueueMessage()
   {
       MessageQueue mq=new MessageQueue(queuePath);
       mq.Formatter = new XmlMessageFormatter(new Type[] {typeof (string)});
       mq.PeekCompleted+=new PeekCompletedEventHandler(MyMessageCompleted);
       mq.BeginPeek();
       return;
   }

   private void MyMessageCompleted(object sender, PeekCompletedEventArgs e)
   {
       MessageQueue mq = (MessageQueue) sender;
       Message msg = mq.EndPeek(e.AsyncResult);
       BinaryReader reader=new BinaryReader(msg.BodyStream);
       string temp=new string(reader.ReadChars(Convert.ToInt32(msg.BodyStream.Length)));
       //Response.Write("这是异步队列信息："+temp);
       this.TextBox2.Text = temp;
       mq.BeginPeek();
       return;
   }

   private void SendMessage()
   {
       MessageQueue mq;
       if (MessageQueue.Exists(@".\Private$\mydemoqueues"))
       {
           mq = new MessageQueue(@".\Private$\mydemoqueues");
       }
       else
       {
           mq = MessageQueue.Create(@".\Private$\mydemoqueues");
       }
       BinaryWriter writer = new BinaryWriter(new MemoryStream());
       writer.Write("sdfsdfsd");
       Message msg = new Message();
       msg.BodyStream = writer.BaseStream;
       msg.Label = "发送信息,飘渺峰测试";
       mq.Send(msg);
   }
试试其它关键字
　操作消息队列　
同语言下
可能有用的
知冀贡献的其它代码(14)