1.创建队列管理器时勾选创建服务器链接通道；

2.创建一个本地队列

命名为Q1

3.创建通道

右击通道->新建->服务器链接通道

命名为SERVERQM2

4.代码示例调用

package com.ibmmq.util.mqutil;import com.ibm.mq.*;
import com.ibm.mq.constants.MQConstants;public class MqDemo {private MQQueueManager qMgr;private MQQueue sendQueue;private MQQueue receiveQueue;private static int CCSID = 1381;//编码字符标识，通道-属性-常规private static String hostname = "192.168.31.239";int port = 1415;static String queueManagerName = "QM_2";static String queueName = "Q1";static String channel = "SERVERQM2";static String userId = "administrator";static String password = "zcy123456";public MqDemo() throws MQException {MQEnvironment.hostname = hostname;MQEnvironment.port = port;MQEnvironment.channel = channel;MQEnvironment.CCSID = CCSID;MQEnvironment.userID = userId;     //MQ中拥有权限的用户名MQEnvironment.password = password; //用户名对应的密码qMgr = new MQQueueManager(queueManagerName);//创建队列管理器}public void sendMsg(String msgStr) {int openOptions  = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE;try {// 建立通道的连接sendQueue = qMgr.accessQueue(queueName, openOptions, null, null, null);MQMessage msg = new MQMessage();// 要写入队列的消息msg.format = MQConstants.MQFMT_STRING;msg.characterSet = CCSID;msg.encoding = CCSID;msg.writeUTF(msgStr);MQPutMessageOptions pmo = new MQPutMessageOptions();msg.expiry = -1; // 设置消息永不过期sendQueue.put(msg, pmo);// 将消息放入队列qMgr.disconnect();} catch (Exception e) {e.printStackTrace();} finally {if (sendQueue != null) {try {sendQueue.close();} catch (MQException e) {e.printStackTrace();}}}}public void receiveMsg() {int openOptions = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE;try {receiveQueue = qMgr.accessQueue(queueName, openOptions, null, null, null);int depth = receiveQueue.getCurrentDepth();System.out.println("该队列当前的深度为:" + depth);// 将队列的里的消息读出来while (depth-- > 0) {MQMessage rcvMessage = new MQMessage();// 要读的队列的消息MQGetMessageOptions gmo = new MQGetMessageOptions();receiveQueue.get(rcvMessage, gmo);String msgText = rcvMessage.readUTF();System.out.println("消息的内容:" + msgText);}} catch (Exception e) {e.printStackTrace();} finally {if (receiveQueue != null) {try {receiveQueue.close();} catch (MQException e) {e.printStackTrace();}}try {qMgr.disconnect();} catch (MQException e) {e.printStackTrace();}}}public static void main(String[] args) throws MQException {new MqDemo().sendMsg("我是第一条消息");new MqDemo().sendMsg("我是第二条消息");new MqDemo().receiveMsg();}
}