如何在java中使用WebSphere MQ？

日期： 2011-03-10 来源：TechTarget中国 英文

　　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

官方微博

TechTarget中国官方微博二维码

TechTarget中国

相关推荐