IBM MQ 與 IBM Websphere 聯(lián)合工作的幾點(diǎn)配置
一,配置IBM MQ作為IBM Websphere JMS服務(wù)器
?1。在WAS管理工具中配置MQ_INSTALL_ROOT 環(huán)境變量為 MQ的安裝路徑；
?2。配置WebSphere MQ JMS 提供程序，創(chuàng)建
???WebSphere MQ 隊(duì)列連接工廠，指定 Queue Manager 為IBM MQ中的隊(duì)列管理器名；
???WebSphere MQ 隊(duì)列目的地，指定 基本隊(duì)列名 為IBM MQ中的 隊(duì)列名；
?3。創(chuàng)建 消息偵聽器服務(wù) 中的 偵聽器端口，供Message Driver Bean 使用；
?
?
二,采用java 代碼向遠(yuǎn)程MQ 隊(duì)列發(fā)送消息
?1。引用 com.ibm.mq.jar
?2。代碼
?
?MQQueueManager qMgr;
?
?MQEnvironment.hostname="192.168.1.102"; // 服務(wù)器的IP地址
?MQEnvironment.port = 1415; //-- 通道端口號(hào)
?//MQEnvironment.channel = "S_dailh"; //-- 通道方式
?MQEnvironment.channel = "unihzc"; //-- 通道方式
?MQEnvironment.CCSID = 1381; //-- 傳輸字符集
?MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES);?
?try{
??//qMgr=new MQQueueManager("QM_dailh",MQC.MQCNO_STANDARD_BINDING);
??qMgr=new MQQueueManager("QM_unihz",MQC.MQCNO_STANDARD_BINDING);
??int openOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE;
??//MQQueue queue=qMgr.accessQueue("testjms",openOptions,null,null,null);
??MQQueue queue=qMgr.accessQueue("unihzq",openOptions,null,null,null);
??//建立連接
??MQMessage hello=new MQMessage();//要寫入隊(duì)列的消息
??try{
???hello.format=MQC.MQFMT_STRING ;
???hello.characterSet=1381 ;
???hello.writeString("這是測(cè)試！!!!!!!!!");
??}catch(java.io.IOException ex){
???out.println("error 2");
??}finally{
??};
??MQPutMessageOptions pmo = new MQPutMessageOptions();
??//將消息依次寫入隊(duì)列
??for (int i=1;i<=5;i++){
???hello.expiry=-1; //設(shè)置消息用不過期
???queue.put(hello);//將消息放入隊(duì)列
??}
??queue.close() ;//關(guān)閉隊(duì)列
??qMgr.disconnect(); //斷開連接
?}catch(Exception ex){
??ex.printStackTrace();
?}finally{
?};??
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=465148