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\