Java鏈接IBM MQ

package com.hometest.IBMMqTest;

import java.io.IOException;
import java.io.UnsupportedEncodingException;

import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.MQConstants;

public class TestMQ {

private MQQueueManager qmanager = null;
private MQQueue queue = null;
private static final String MQ_HOST ="";
private static final Integer MQ_PORT =1414;
private static final String MQ_CHANNEL ="";
private static final String MQ_QUEUEMANAGER_NAME = "MQ_APP";
private static final String MQ_QUEUE_NAME = "Queue1";

public static void main(String[] args) {
// TODO Auto-generated method stub
TestMQ mq = new TestMQ();

try {
mq.send("hello everyone");
// mq.send("WHAT");
System.out.println(mq.receive());
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// mq.receiveAll();
// Integer depth = mq.getQueueDepth();
// System.out.println("The current depth of queue is " + depth);
mq.close();
}

public TestMQ() {
try {
MQEnvironment.hostname = MQ_HOST;
MQEnvironment.port = MQ_PORT;
MQEnvironment.channel = MQ_CHANNEL;
qmanager = new MQQueueManager(MQ_QUEUEMANAGER_NAME);
int openOptions = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_INQUIRE | MQConstants.MQOO_OUTPUT;
queue = qmanager.accessQueue(MQ_QUEUE_NAME, openOptions);
} catch (MQException e) {
e.printStackTrace();
}
}

public Integer getQueueDepth() {
Integer depth = 0;
try {
if (queue != null && queue.isOpen()) {
depth = queue.getCurrentDepth();
}
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return depth;
}

public void close() {
if (queue != null && queue.isOpen()) {
try {
queue.close();
} catch (MQException e) {
e.printStackTrace();
}
}
if (qmanager != null && qmanager.isConnected()) {
try {
qmanager.disconnect();
} catch (MQException e) {
e.printStackTrace();
}
}
}

public void send(String msg) throws MQException { try { MQPutMessageOptions mqPutMessageOptions = new MQPutMessageOptions(); MQMessage mqMessage = new MQMessage(); mqMessage.write(msg.getBytes("utf-8")); queue.put(mqMessage, mqPutMessageOptions); System.out.println("Sent a message:" + msg); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public String receive() throws MQException{ MQMessage mqMsg = new MQMessage(); MQGetMessageOptions mqGetMessageOptions = new MQGetMessageOptions(); try { queue.get(mqMsg, mqGetMessageOptions); int len = mqMsg.getDataLength(); byte[] message = new byte[len]; mqMsg.readFully(message, 0, len); String str = new String(message); System.out.println("Received a message:" + str); return str; } catch (MQException e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } public void receiveAll() { try { int depth = queue.getCurrentDepth(); System.out.println("The current depth of queue is " + depth); System.out.println("Now receive all messages...."); while(depth-- > 0){ MQMessage mqMsg = new MQMessage(); MQGetMessageOptions mqGetMessageOptions = new MQGetMessageOptions(); queue.get(mqMsg, mqGetMessageOptions); int len = mqMsg.getDataLength(); byte[] message = new byte[len]; mqMsg.readFully(message, 0, len); System.out.println(new String(message)); } } catch (MQException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }