入门新手可以看看，关于Java连接WebsphereMQ（也就是MQSeries）的内容

        目前我正在实习，我的leader布置我研究WebsphereMQ。

        WebsphereMQ可以在IBM的网站下载，安装之后有两个要注意的点。

        第一个有可能出现的问题是：AMQ7077: 你未被授权来进行请求的操作。这个问题是没有用管理员身份运行程序造成的，要以管理员身份重新启动程序。

        第二个可能出现的问题是：AMQ7257:安装“Installation1”(C:\Program Files (x86)\IBM\WebSphere MQ) 的 MQ服务必须正在运行。这个问题是没有开启服务项造成的。点计算机-管理-服务-把IBM MQ的服务项启用。

        接下来说配置的问题，我通过虚拟机模拟了另外一台电脑进行信息的接收，主机作为信息的发送方（虚拟机和主机都安装了WebsphereMQ）。（在上一个帖子中我写的就是关于虚拟机ip的问题，可以对这篇文章进行补充）在主机的WebsphereMQ上要做以下的操作：

        1、建立实现发送作用的队列管理器send，（端口号默认的是1414，可以自己随便改一个，但要记住了，待会会用到）

        2、在send中建立本地队列XQ，用法设置为传输

        3、继续建立远程队列RQ，远程队列为LQ（这个待会在虚拟机上建立），远程队列管理器是receive（这个也将在虚拟机上创建），传输队列是XQ

        4、创建发送方的通道SToR，连接名称的格式是：xxx.xxx.xxx.xxx(xxxx) ， 也就是：虚拟机的ip，然后一个括号，里头写虚拟机上的接收队列管理器receive的端口号；传输队列是XQ

        5、创建服务器连接通道，起名DC.SVRCONN，这个要记住了，待会要用到。

        主机配置完毕，接下来看虚拟机的操作：

        6、建立队列管理器receive，在步骤3有提到过

        7、建立本地队列LQ，在步骤3有提到过

        8、建立接收方通道 SToR (和步骤4中的发送方通道相对应)

        9、同5，创建服务器连接通道，名称必须一样

        这些配置工作做完之后就可以做测试了，在主机的RQ上放入测试信息，启动传输通道，然后在虚拟机上的LQ查看是否收到信息。

        接下来是用java实现方面的了，推荐大家看一些东西，我看的是《MQ编程模式中文版7》，自己百度一下是可以下载到这份PDF的。

        在主机上编程的时候会用到com.ibm.mq的jar包，这个jar包eclips是不带的，所以要导入。具体的文件可以在MQ的安装目录下的java/lib中找到。

        以下是我的代码

import java.io.IOException;
import java.util.Hashtable;

import com.ibm.mq.MQException;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;

public class MQ0{
	//定义队列管理器和队列的名称（发送方的参数）
	private static String qmName = "QM0";
	private static String qName = "RQ8";
	private static MQQueueManager qMgr;
	private static Hashtable properties = new Hashtable();

	
	public static void main(String args[]) {
		
		try {			
			//以下参数是接收机器的参数
			properties.put("hostname", "192.168.1.2");
			properties.put("port", new Integer(1414));
			properties.put("channel", "DC.SVRCONN");
			properties.put("CCSID", new Integer(1381));
			properties.put("transport","MQSeries");
			
		
			// 建立与队列管理器的连接。Create a connection to the queue manager
			
			//MQQueueManager qMgr = new MQQueueManager(qmName,properties);
			//不知道为什么多了一个properties就不行了
			MQQueueManager qMgr = new MQQueueManager(qmName);
			
			// 设置希望打开的选项？？？什么意思Set up the options on the queue we wish to open...
			int openOptions = 16;
			
			
			// Now specify the queue that we wish to open,
			// and the open options...
			//选择队列、打开选项
			MQQueue remoteQ = qMgr.accessQueue(qName, openOptions);
			
			//创建一条信息
			// Define a simple WebSphere MQ message, and write some text in UTF format..
			MQMessage putMessage = new MQMessage();
			putMessage.writeUTF("test123456");
			
			// specify the message options...
			MQPutMessageOptions pmo = new MQPutMessageOptions();
			

			// accept the defaults, same as MQPMO_DEFAULT
			// put the message on the queue
		    //将消息放入队列
			remoteQ.put(putMessage,pmo);
			System.out.println("Message has been input into the Remote Queue");
			
			// 关闭队列。Close the queue...
			remoteQ.close();
			
			// 断开连接。Disconnect from the queue manager
			qMgr.disconnect();
		}
		/*
		 * 异常处理代码			 * 
		 */
		catch (MQException ex) {
			// If an error has occurred in the above, try to identify what went wrong
			// Was it a WebSphere MQ error?
			System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode);
		}
		catch (IOException ex) {
			// Was it a Java buffer space error?
			System.out.println("An error occurred whilst writing to the message buffer: " + ex);
		}
		catch(Exception ex){
			ex.printStackTrace();
		}
	}
}
           

        运行之后如果结果正常的话就会有“Message has been input into the Remote Queue”这样的提示。接着在虚拟机中查看LQ中是否存在消息。

       接下来是接受方的代码，可在虚拟机上接收。

import java.io.IOException;
import java.util.Hashtable;
import com.ibm.mq.*;

public class MQ8{
	//定义队列管理器和队列的名称（发送方的参数）
	private static String qmName = "recieve";
	private static String qName = "LQ";
	private static MQQueueManager qMgr;
	
	public static void main(String args[]) {
		
		try {				
			// 建立与队列管理器的连接。Create a connection to the queue manager
			
			MQQueueManager qMgr = new MQQueueManager(qmName);
			
			// 设置选项
			int openOptions = MQC.MQOO_INPUT_SHARED | MQC.MQOO_FAIL_IF_QUIESCING;;
			
			
			//选择队列、打开选项
			MQQueue remoteQ = qMgr.accessQueue(qName, openOptions);
			
			//创建一条空的信息用于接收
				MQMessage getMessage = new MQMessage();
		
				
			//MQPutMessageOptions pmo = new MQPutMessageOptions();
			
				MQGetMessageOptions gmo = new MQGetMessageOptions();
			     // Get messages under sync point control.
			     // 在同步点控制下获取消息.
			     gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT;
			     // Wait if no messages on the Queue.
			     // 如果在队列上没有消息则等待.
			     gmo.options = gmo.options + MQC.MQGMO_WAIT;
			     // Fail if QeueManager Quiescing.
			     // 如果队列管理器停顿则失败.
			     gmo.options = gmo.options + MQC.MQGMO_FAIL_IF_QUIESCING;
			     // Sets the time limit for the wait.
			     // 设置等待的时间限制.
			     gmo.waitInterval = 3000;		
		
			     
		    //获取消息
			remoteQ.get(getMessage,gmo);
			System.out.println("Message has been got from the Remote Queue");
			String msgString = getMessage.readUTF();
		    System.out.println(" The Message from the Queue is :  " + msgString);
		    

			// 关闭队列。
			remoteQ.close();
			
			// 断开连接。
			qMgr.disconnect();
		}
		/*
		 * 异常处理代码			 * 
		 */
		catch (MQException ex) {
			System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode);
		}
		catch (IOException ex) {			
			System.out.println("An error occurred whilst writing to the message buffer: " + ex);
		}
		catch(Exception ex){
			ex.printStackTrace();
		}
	}
}