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