C#之消息队列的简要说明----自学笔记[4]

[入库:2005年8月18日] [更新:2007年3月24日]

本文简介:选择自 dhz123 的 blog

   this.groupbox3.resumelayout(false);
   this.resumelayout(false);

  }
  #endregion

  /// <summary>
  /// 应用程序的主入口点。
  /// </summary>
  [stathread]
  static void main()
  {
   application.run(new form1());
  }
  private void form1_load(object sender, system.eventargs e)
  {
   
   if(messagequeue.exists(@".\private$\dhzordermgmt"))
   {
    this.mq=new messagequeue(@".\private$\dhzordermgmt");
   }
   else
   {
    this.mq=messagequeue.create(@".\private$\dhzordermgmt",false);
   }
   this.richtextbox1.appendtext("==================\r\n");
   this.richtextbox1.appendtext(mq.queuename +":创建成功!\r\n");
  
  
  }
  private void button1_click(object sender, system.eventargs e)
  {
   od od=new od("代汉章","南昌",datetime.now.tolongtimestring ());
   if(this.mq.transactional)
   {
    this.mq.send(od,new system.messaging.messagequeuetransaction ());
   }
   else
   {
    this.mq.send(od);
   }
   this.richtextbox1.appendtext("发送成功!\r\n");
  }
  private void button2_click(object sender, system.eventargs e)
  {
  
   if(messagequeue.exists(@".\private$\dhzordermgmt"))
   {
    this.mq=new messagequeue(@".\private$\dhzordermgmt");
   }
   else
   {
    this.mq=messagequeue.create(@".\private$\dhzordermgmt",false);
   }
   this.richtextbox1.appendtext("==================\r\n");
   this.richtextbox1.appendtext(mq.queuename +":创建成功!\r\n");
  

  }
  private void button3_click(object sender, system.eventargs e)
  {
   if(this.mq!=null)
   {
    system.messaging.messageenumerator  msg=this.mq.getmessageenumerator ();
    while(msg.movenext ())
    {
     system.messaging .message oc=msg.current ;
     od od=oc.body  as od ;
     this.richtextbox1.appendtext(od.name +":"+od.city +":"+od.time +";\r\n");
    
    }

   }
  }
  private void button4_click(object sender, system.eventargs e)
  {
   if(messagequeue.exists(@".\private$\dhztrans"))
   {
    this.msq =new messagequeue(@".\private$\dhztrans");
   }
   else
   {
    this.msq=messagequeue.create(@".\private$\dhztrans",true);
   }
   this.richtextbox1.appendtext("==================\r\n");
   this.richtextbox1.appendtext(msq.queuename +":创建成功!\r\n");
  
  }
  private void button5_click(object sender, system.eventargs e)
  {
   
   this.msq=new messagequeue(@".\private$\dhztrans");
   if(this.msq.transactional)
   {
    od od=new od("万卿","景德镇",datetime.now.tostring("u"));
    messagequeuetransaction mytransaction = new
                messagequeuetransaction();
          mytransaction.begin();
       msq.send(od,mytransaction);
                mytransaction.commit();
    this.richtextbox1.appendtext("ok!发送成功:"+od.time+"\r\n" );
   }

  }
  private void button6_click(object sender, system.eventargs e)
  {
   this.msq=new messagequeue(@".\private$\dhztrans");
   if(this.msq .transactional )
   {
    messagequeuetransaction mytransaction = new messagequeuetransaction();

本文关键:C#之消息队列的简要说明----自学笔记
  相关方案
Google
 

本站最佳浏览方式为 分辨率 1024x768 IE 6.0(或更高版本的 IE浏览器)

go top