IBM WebSphere MQ介绍安装以及配置服务详解

import java.io.File;import java.io.FileInputStream;import java.io.InputStream;import java.util.Properties;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import com.ibm.mq.MQC;import com.ibm.mq.MQEnvironment;import com.ibm.mq.MQException;import com.ibm.mq.MQGetMessageOptions;import com.ibm.mq.MQMessage;import com.ibm.mq.MQQueue;import com.ibm.mq.MQQueueManager;/** * 函数功能： MQjava客户端实现 */public class MQClient { ???/** ????* Logger for this class ????*/ ???private static final Log logger = LogFactory.getLog(MQClient.class); ???private String strExtraSendXmlFileName = "D:\\jndi.properties"; ???private static Properties props; ???static { ???props = new Properties(); ???props.put("mqHostName", "139.31.89.67"); ???props.put("mqPort", "4032"); ???props.put("mqCCSID", "1381"); ???props.put("mqUserName", "liujx"); ???props.put("mqPassword", "linux"); ???props.put("mqQManager", "Monitor_Queue_Manager"); ???props.put("mqChannel", "Monitor_Conn_Chanel"); ???props.put("mqLocalOutQueue", "Q_RECEIVE"); ???props.put("mqLocalInQueue", "Q_RECEIVE"); ???} ???/** ????* ?????* 函数功能：TODO 主测试方法 <br> ????* 相关参数： <br> ????* ?????* @param args ????* ???????????修改记录： <br> ????*/ ???public static void main(String[] args) { ???MQClient test = new MQClient(); ???// 发送消息 ???test.putMsg(); ???// 接收消息 ???test.getMsg(); ???} ???public void putMsg() { ???// MQ发送数据 ???try { ???????// 建立MQ客户端应用上下文环境 ???????MQEnvironment.hostname = props.getProperty("mqHostName"); ???????MQEnvironment.port = Integer.parseInt(props.getProperty("mqPort")); ???????MQEnvironment.CCSID = Integer ???????????.parseInt(props.getProperty("mqCCSID")); ???????MQEnvironment.channel = props.getProperty("mqChannel"); ???????MQEnvironment.userID = props.getProperty("mqUserName"); ???????MQEnvironment.password = props.getProperty("mqPassword"); ???????// 连接队列管理器 ???????MQQueueManager qMgr = new MQQueueManager( ???????????props.getProperty("mqQManager")); ???????int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING; ???????// 打开队列 ???????MQQueue q = null; ???????try { ???????q = qMgr.accessQueue(props.getProperty("mqLocalOutQueue"), ???????????openOptions); ???????} catch (MQException me) { ???????System.out.println("打开队列出现通讯异常" + me.getMessage() + "\n"); ???????return; ???????} ???????InputStream fins = new FileInputStream(new File( ???????????strExtraSendXmlFileName)); ???????byte[] data = new byte[fins.available()]; ???????fins.read(data); ???????fins.close(); ???????MQMessage msg = new MQMessage(); ???????msg.write(data); ???????// 放入消息 ???????q.put(msg); ???????System.out.println("客户端发送数据包成功.."); ???????// 关闭队列 ???????q.close(); ???????// 断开队列管理器连接 ???????qMgr.disconnect(); ???} catch (MQException e) { ???????if (logger.isDebugEnabled()) ???????logger.debug(e.getMessage()); ???????e.printStackTrace(); ???} catch (Exception e) { ???????if (logger.isDebugEnabled()) ???????logger.debug(e.getMessage()); ???????e.printStackTrace(); ???} ???} ???/** ????* ?????* 函数功能：TODO 获取数据 <br> ????* 修改记录： <br> ????*/ ???public void getMsg() { ???// MQ接收数据 ???try { ???????// 建立用上下文环境 ???????MQEnvironment.hostname = props.getProperty("mqHostName"); ???????MQEnvironment.port = Integer.parseInt(props.getProperty("mqPort")); ???????MQEnvironment.CCSID = Integer ???????????.parseInt(props.getProperty("mqCCSID")); ???????MQEnvironment.channel = props.getProperty("mqChannel"); ???????MQEnvironment.userID = props.getProperty("mqUserName"); ???????MQEnvironment.password = props.getProperty("mqPassword"); ???????// 建立队列管理器 ???????MQQueueManager qMgr = new MQQueueManager( ???????????props.getProperty("mqQManager")); ???????int openOptions = MQC.MQOO_INPUT_AS_Q_DEF ???????????| MQC.MQOO_FAIL_IF_QUIESCING; ???????// 打开队列 ???????MQQueue q = qMgr.accessQueue(props.getProperty("mqLocalInQueue"), ???????????openOptions); ???????MQGetMessageOptions mgo = new MQGetMessageOptions(); ???????mgo.options |= MQC.MQGMO_NO_WAIT; ???????// 构造返回消息 ???????MQMessage msg = new MQMessage(); ???????if ((msg = fetchOneMsg(q)) != null) { ???????byte[] xmlData = new byte[msg.getDataLength()]; ???????msg.readFully(xmlData); ???????logger.info(new String(xmlData)); ???????System.out.println("接收服务器端返回数据包成功..\n接收数据为:\n" ???????????+ new String(xmlData)); ???????} ???????// 关闭队列 ???????q.close(); ???????// 断开队列管理器 ???????qMgr.disconnect(); ???} catch (MQException e) { ???????logger.error(e); ???????e.printStackTrace(); ???} catch (Exception e) { ???????logger.error(e); ???????e.printStackTrace(); ???} ???} ???/** ????* ?????* 函数功能：TODO 从队列中取出消息 <br> ????* 相关参数： <br> ????* ?????* @param q ????* @return ????* @throws Exception ????* ????????????修改记录： <br> ????*/ ???private static MQMessage fetchOneMsg(MQQueue q) throws Exception { ???MQGetMessageOptions mgo = new MQGetMessageOptions(); ???mgo.options |= MQC.MQGMO_NO_WAIT; ???MQMessage msg = new MQMessage(); ???try { ???????// 获取消息 ???????q.get(msg, mgo); ???} catch (MQException e) { ???????return null; ???} ???return msg; ???}}