java

悠悠女儿香

java 中使用websphere 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); } } }