MQ接收消息.doc

MQ发送消息及读取消息的简单操作原创作者ID:bicashyMQ应用程序的开发,,建队列管理器QM1,在QM1中建队列Q1,然后在高级中建立通道BICASHY,类型为服务器连接通道,端口号1414,这里做最简单的配置,死信、传输队列及远程队列都暂时不建。。。注:如果建另一个队列管理器QM2,其侦听端口一定不能和1414重复。Java代码 .;   ;   .;   .;   .;   .;   .;   .;   .;   .;   lassMQManager{   privateMQqueueManagerqMgr;   privatevoidgetConnMQmanager(){   ="";//MQ服务器IP   ="BICASHY";  //队列管理器对应的服务器连接通道   SID=1381;      //字符编码   =1414;      //队列管理器的端口号   try{   qMgr=newMQqueueManager("QM1");//队列管理器名称   }catch(MQExceptione){   //TODOAuto-generatedcatchblock   ();   }   }   privatevoidcloseConnMQmanager(){   if(qMgr!=null){   try{   ();   }catch(MQExceptione){   //TODOAuto-generatedcatchblock   ();   }   }   }   publicvoidsendMsg(StringmsgStr){   intopenOptions=||;   MQqueuequeue=null;   try{   //建立Q1通道的连接   queue=("Q1",openOptions,null,null,null);    MQMessagemsg=newMQMessage();//要写入队列的消息   =;   =1381;   (msgStr);//将消息写入消息对象中   MQPutMessageOptionspmo=newMQPutMessageOptions();   =-1;  //设置消息用不过期   (msg,pmo);//将消息放入队列   }catch(MQExceptione){   //TODOAuto-generatedcatchblock   ();   }catch(IOExceptione){   //TODOAuto-generatedcatchblock   ();   }finally{   if(queue!=null){   try{   ();   }catch(MQExceptione){   //TODOAuto-generatedcatchblock   ();   }   }   }   }   publicvoidreceiveMsg()   {   intopenOptions=||;   MQqueuequeue=null;   try{   queue=("Q1",openOptions,null,null,null);   ("该队列当前的深度为:"+queue