java连接mq的demo

项目介绍博客：http://blog.csdn.net/qq_17616169/article/details/54633005

package demo;

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.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;

public class Mq {
	static MQQueueManager qMgr;
	static int CCSID = 1381;
	static String queueString = “LOCALQUEUE“;

	public static void connect（） throws MQException {
		MQEnvironment.hostname = “127.0.0.1“;
		MQEnvironment.channel = “SERVERCONN“;
		MQEnvironment.port = 1414;
		MQEnvironment.CCSID = CCSID;
		MQEnvironment.userID = “MUSR_MQADMIN“;
		MQEnvironment.password = “123456“;

		qMgr = new MQQueueManager（“MyTest“）;

	}

	public static void sendMsg（String msgStr） {
		int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE;
		MQQueue queue = null;
		try {
			// 建立Q1通道的连接
			queue = qMgr.accessQueue（queueString openOptions null null null）;
			MQMessage msg = new MQMessage（）;// 要写入队列的消息
			msg.format = MQC.MQFMT_STRING;
			msg.characterSet = CCSID;
			msg.encoding = CCSID;
			// msg.writeobject（msgStr）; //将消息写入消息对象中
			msg.writeString（msgStr）;
			MQPutMessageOptions pmo = new MQPutMessageOptions（）;
			msg.expiry = -1; // 设置消息用不过期
			queue.put（msg pmo）;// 将消息放入队列
		} catch （Exception e） {
			// TODO Auto-generated catch block
			e.printStackTrace（）;
		} finally {
			if （queue != null） {
				try {
					queue.close（）;
				} catch （MQException e） {
					// TODO Auto-generated catch block
					e.printStackTrace（）;
				}
			}
		}
	}

	public static void receiveMsg（） {
		int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE;
		MQQueue queue = null;
		try {
			queue = qMgr.accessQueue（queueString openOptions null null null）;
			System.out.println（“该队列当前的深度为:“ + queue.getCurrentDepth（））;
			System.out.println（“===========================“）;
			int depth = queue.getCurrentDepth（）;
			// 将队列的里的消息读出来
			while （depth-- > 0） {
				MQMessage msg = new MQMessage（）;// 要读的队列的消息
				MQGetMessageOptions gmo = new MQGetMessageOptions（）;
				queue.get（msg gmo）;
				System.out.println（“消息的大小为：“ + msg.getDataLength（））;
				System.out.println（“消息的内容：\n“ + msg.readStringOfByteLength（msg.getDataLength（）））;
				System.out.println（“---------------------------“）;
			}
		} catch （Exception e） {
			// TODO Auto-generated catch block
			e.printStackTrace（）;
		} finally {
			if （queue != null） {
				try {
					queue.close（）;
				} catch （MQException e） {
					// TODO Auto-generated catch block
					e.printStackTrace（）;
				}
			}
		}
	}

	public static void main（String[] args） throws MQException {
		connect（）;
		sendMsg（“我来测试一下“）;
		receiveMsg（）;
	}
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        1835  2017-01-19 14:06  mq_demo3\.classpath
     文件        1084  2017-01-18 20:51  mq_demo3\.project
     文件         639  2017-01-18 16:05  mq_demo3\.settings\.jsdtscope
     文件         430  2017-01-18 20:51  mq_demo3\.settings\org.eclipse.jdt.core.prefs
     文件          90  2017-01-18 16:05  mq_demo3\.settings\org.eclipse.m2e.core.prefs
     文件         680  2017-01-18 20:51  mq_demo3\.settings\org.eclipse.wst.common.component
     文件         252  2017-01-18 20:51  mq_demo3\.settings\org.eclipse.wst.common.project.facet.core.xml
     文件          49  2017-01-18 16:05  mq_demo3\.settings\org.eclipse.wst.jsdt.ui.superType.container
     文件           6  2017-01-18 16:05  mq_demo3\.settings\org.eclipse.wst.jsdt.ui.superType.name
     文件          50  2017-01-18 16:05  mq_demo3\.settings\org.eclipse.wst.validation.prefs
     文件         904  2017-01-20 17:04  mq_demo3\pom.xml
     文件       34921  2017-01-19 13:55  mq_demo3\src\lib\aspectjrt.jar
     文件      689102  2017-01-19 13:55  mq_demo3\src\lib\com.ibm.mq.fta.jar
     文件      456233  2017-01-19 12:07  mq_demo3\src\lib\com.ibm.mq.jar
     文件     3275610  2017-01-19 14:06  mq_demo3\src\lib\com.ibm.mq.jmqi.jar
     文件       19486  2017-01-19 13:55  mq_demo3\src\lib\com.ibm.mq.jms.Nojndi.jar
     文件      135674  2017-01-19 13:55  mq_demo3\src\lib\com.ibm.mq.soap.jar
     文件        2474  2017-01-19 13:55  mq_demo3\src\lib\com.ibm.mqetclient.jar
     文件     1300741  2017-01-19 13:55  mq_demo3\src\lib\com.ibm.mqjms.jar
     文件        2962  2017-01-20 17:21  mq_demo3\src\main\java\demo\Mq.java
     目录           0  2017-01-20 18:05  mq_demo3\src\main\resources\
     文件         222  2017-01-18 16:05  mq_demo3\src\main\webapp\WEB-INF\web.xml
     文件        3714  2017-01-20 17:21  mq_demo3\target\classes\demo\Mq.class
     文件         114  2017-01-20 17:04  mq_demo3\target\m2e-wtp\web-resources\meta-INF\MANIFEST.MF
     文件         219  2017-01-20 17:04  mq_demo3\target\m2e-wtp\web-resources\meta-INF\maven\com.demo\mq_demo3\pom.properties
     文件         904  2017-01-20 17:04  mq_demo3\target\m2e-wtp\web-resources\meta-INF\maven\com.demo\mq_demo3\pom.xml
     目录           0  2017-01-20 18:05  mq_demo3\target\test-classes\