【IT168 技术文档】websphere mq : 用于传输信息 具有跨平台的功能。

　　1 安装websphere mq 并启动

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

　　3 建立queue 类型选择 Local类型 的 (如lq )

　　3 建立channels 类型选择Server Connection (如BridgeChannel)

　　java 代码如下：

　　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

　　MQEnvironment.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< 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);
　　}
　　}
　　}