Java中使用websphere websphere mq：用于傳輸信息 具有跨平臺的功能。

1 安裝websphere mq并啟動

2 websphere mq建立queue Manager(如：MQSI_SAMPLE_QM)

3 建立queue類型選擇Local類型的(如lq)

4 建立channels類型選擇Server Connection(如BridgeChannel)

以下是引用片段：

package?test.mq;

import?com.ibm.mq.*;

/*?*??????mq??java???*/

public?class?FirstMqTest

{//?public?static?void?main(String[]?args[])

{//?FirstMqTest?first?=?new?FirstMqTest();//?first.test();//?}

public?static?void?main(String?args[])

{?FirstMqTest?first?=?new?FirstMqTest();?first.test();?}

public?void?test()

{

String?qManager?=?“MQSI_SAMPLE_QM”;

//QueueManager?name

String?qName?=?“lq”;

//Queue?Name?try

{?//configure?connection?parameters

MQEnvironment.hostname=”172.16.17.123″;

//MQ?Server?name?or?IP

MQEnvironment.port=1414;

//listenr?port

MQEnvironment.channel=”BridgeChannel”;

//Server-Connection?Channel?M

QEnvironment.CCSID?=1381;

//?Create?a?connection?to?the?QueueManager

System.out.println(“Connecting?to?queue?manager:?“+qManager);

MQQueueManager?qMgr?=?new?MQQueueManager(qManager);

//?Set?up?the?options?on?the?queue?we?wish?to?open

int?openOptions?=?MQC.MQOO_INPUT_AS_Q_DEF?|?MQC.MQOO_OUTPUT;

//?Now?specify?the?queue?that?we?wish?to?open?and?the?open?options

System.out.println(“Accessing?queue:?“+qName);

MQQueue?queue?=?qMgr.accessQueue(qName,?openOptions);

//?Define?a?simple?WebSphere?MQ?Message?…

MQMessage?msg?=?new?MQMessage();

//?…?and?write?some?text?in?UTF8

format?msg.writeUTF(“Hello,?World!”);

//?Specify?the?default?put?message?options

MQPutMessageOptions?pmo?=?new?MQPutMessageOptions();

//?Put?the?message?to?the?queue

System.out.println(“Sending?a?message…”);

/*?*????????mq???????*?*/

for(int?j=0;j%26lt;5;j++)

{?String?str?=”test11111111111″;

str?=?str+j;?msg.writeUTF(str);

queue.put(msg,?pmo);?}

queue.put(msg,?pmo);

//?Now?get?the?message?back?again.?First?define?a?WebSphere?MQ?message

//?to?receive?the?data

MQMessage?rcvMessage?=?new?MQMessage();

//?Specify?default?get?message?options

MQGetMessageOptions?gmo?=?new?MQGetMessageOptions();

//?Get?the?message?off?the?queue.

System.out.println(“…and?getting?the?message?back?again”);

queue.get(rcvMessage,?gmo);

//?And?display?the?message?text…

String?msgText?=?rcvMessage.readUTF();

System.out.println(“The?message?is:?”?+?msgText);

//?Close?the?queue

System.out.println(“Closing?the?queue”);

queue.close();

//?Disconnect?from?the?QueueManager

System.out.println(“Disconnecting?from?the?Queue?Manager”);

qMgr.disconnect();

System.out.println(“Done!”);

}

catch?(MQException?ex)?{

System.out.println(“A?WebSphere?MQ?Error?occured?:?Completion?Code?”?+?ex.completionCode?+?”?Reason?Code?”?+?ex.reasonCode);?}

catch?(java.io.IOException?ex)

{

System.out.println(“An?IOException?occured?whilst?writing?to?the?message?buffer:?”?+?ex);

}

}

}

我們一直都在努力堅持原創.......請不要一聲不吭，就悄悄拿走。

我原創，你原創，我們的內容世界才會更加精彩！

【所有原創內容版權均屬TechTarget，歡迎大家轉發分享。但未經授權，嚴禁任何媒體(平面媒體、網絡媒體、自媒體等)以及微信公眾號復制、轉載、摘編或以其他方式進行使用。】

微信公眾號

TechTarget

官方微博

TechTarget中國

總結

以上是生活随笔為你收集整理的java websphere mq_如何在java中使用WebSphere MQ？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。