新建 文本文档 (3).txt

MQ软件提供一个JAVA软件包

MQ软件提供一个JAVA软件包，里面有JMS类库，和一套MQ的类库。不熟悉MQI编程方法的程序员可以用JMS，比较熟悉MQI编程方法的程序则可以用MQ类库来编程。下面的小程序是使用Java实现从队列管理器QM_SERVER中的队列INITQ写入或读出消息。

package transfer;
import com.ibm.mq.*; 
public class SendMSG1 
{ 
　 private MQQueueManager qMgr;//定义一个队列管理器变量
　 public static void main(String args[])
　 {
　　 new SendMSG1();
　 }
　 public SendMSG1()
　 {
　　 MQEnvironment.hostname="192.168.1.18";//本地IP
　　 MQEnvironment.channel="CHANNEL1";//用来通信的通道
　　 MQEnvironment.CCSID =1381;
　　 try{
　　　 qMgr=new MQQueueManager("QM_SERVER");//队列管理器名称
　　　 int openOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE;
　　　 MQQueue queue=qMgr.accessQueue("INITQ",openOptions,null,null,null);
　　　 //建立连接
　　　 MQMessage hello=new MQMessage();//要写入队列的消息
　　　 try{
　　　　 hello.format=MQC.MQFMT_STRING ;
　　　　 hello.characterSet=1381 ;
　　　　 hello.writeString("这是测试！");
　　　 }
　　　 catch(java.io.IOException ex)
　　　 {}finally{};
　　　 MQPutMessageOptions pmo=new MQPutMessageOptions();
　　　 for (int i=1;i<=5;i++)//将消息依次写入队列
　　　 {
　　　　 hello.expiry=-1; //设置消息用不过期
　　　　 queue.put(hello);//将消息放入队列 
　　　 }
　　　 queue.close() ;//关闭队列
　　　 qMgr.disconnect() ; //断开连接 
　　 }
　　 catch(Exception ex)
　　 {}
　　 finally{};
　 } 
}