MQ远程通信2--java调用 实例

按照上一篇 http://blog.chinaunix.net/uid-28811518-id-5749060.html 搭建两个队列管理器和三个队列
前提是这个环境下两个队列管理器之间已经可以远程发送和接收消息；现在想通过java程序访问队列管理器，进而实现java应用程序之间的远程通信：
1、首先要注意的是设置的环境端口问题，在win界面下可以通过，队列管理器下的监听器查看本队列管理器监听的端口号，在java 程序访问队列管理器的时候端口号一定设置正确。
2、MQEnvironment.channel="SYSTEM.DEF.SVRCONN"; 这个是服务器连接的通道，具体我也弄清楚，不过应该是默认的访问通道，不用自己创建
3、MQEnvironment.CCSID=1381;                      //服务器MQ服务使用的编码1381代表GBK
4、最后要注意的也是最终要的一点，否则java程序访问不成功，返回2035没有访问权限
我采用的是关闭通道认证的功能，这是最坏的解决办法，但是为了先调通也只有先这么做了，以后再去查看其它解决办法。a、启动队列管理器后；b、ALTER QMGR CHLAUTH(DISABLED)关闭通道认证功能
其它办法参考：blog.csdn.net/haitaofeiyang/article/details/46897323
下面是具体的发送和接收端的代码（代码是在网上找的，自己修改了下，现在可以实现通信）
发送端代码：

import java.io.IOException;
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_Send{
     //定义队列管理器和队列的名称
     private static String qmName;
     private static String qName;
     private static MQQueueManager qMgr;
     static{
         //设置环境:
         //MQEnvironment中包含控制MQQueueManager对象中的环境的构成的静态变量，MQEnvironment的值的设定会在MQQueueManager的构造函数加载的时候起作用，
         //因此必须在建立MQQueueManager对象之前设定MQEnvironment中的值.
         MQEnvironment.hostname="192.168.223.129";     //MQ服务器的IP地址
         MQEnvironment.channel="SYSTEM.DEF.SVRCONN";             //服务器连接的通道
         MQEnvironment.CCSID=1381;         //服务器MQ服务使用的编码1381代表GBK、1208代表UTF(Coded Character Set Identifier:CCSID)
         MQEnvironment.port=1415;                        //MQ端口
         qmName = "QM_ORANGE";                            //MQ的队列管理器名称
         qName = "Q1";                                //MQ远程队列的名称
         try {
             //定义并初始化队列管理器对象并连接
             //MQQueueManager可以被多线程共享，但是从MQ获取信息的时候是同步的，任何时候只有一个线程可以和MQ通信。
            qMgr = new MQQueueManager(qmName);
        } catch (MQException e) {
            // TODO Auto-generated catch block
            System.out.println("初使化MQ出错");
            e.printStackTrace();
        }
     }
     /**
      * 往MQ发送消息
      * @param message
      * @return
      */
     public static int sendMessage(String message){
         int result=0;
         try{
             //设置将要连接的队列属性
         // Note. The MQC interface defines all the constants used by the WebSphere MQ Java programming interface
         //(except for completion code constants and error code constants).
         //MQOO_INPUT_AS_Q_DEF:Open the queue to get messages using the queue-defined default.
         //MQOO_OUTPUT:Open the queue to put messages.
             /*目标为远程队列，所有这里不可以用MQOO_INPUT_AS_Q_DEF属性*/
             //int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
             /*以下选项可适合远程队列与本地队列*/
             int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
     //连接队列
     //MQQueue provides inquire, set, put and get operations for WebSphere MQ queues.
     //The inquire and set capabilities are inherited from MQManagedObject.
             /*关闭了就重新打开*/
             if(qMgr==null || !qMgr.isConnected()){
                 qMgr = new MQQueueManager(qmName);
             }
             MQQueue queue = qMgr.accessQueue(qName, openOptions);
     //定义一个简单的消息
             MQMessage putMessage = new MQMessage();
     //将数据放入消息缓冲区
             putMessage.writeUTF(message);
     //设置写入消息的属性（默认属性）
             MQPutMessageOptions pmo = new MQPutMessageOptions();
     //将消息写入队列
     queue.put(putMessage,pmo);
     queue.close();
         }catch (MQException ex) {
             System.out.println("A WebSphere MQ error occurred : Completion code "
             + ex.completionCode + " Reason code " + ex.reasonCode);
             ex.printStackTrace();
         }catch (IOException ex) {
             System.out.println("An error occurred whilst writing to the message buffer: " + ex);
         }catch(Exception ex){
             ex.printStackTrace();
         }finally{
             try {
                 qMgr.disconnect();
             } catch (MQException e) {
                 e.printStackTrace();
             }
          }
         return result;
     }
 public static void main(String args[]) {
         /*下面两个方法可同时使用，也可以单独使用*/
         sendMessage("this is a test");

     }
}

接收端代码：

import java.io.IOException;
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_Recive{
     //定义队列管理器和队列的名称
     private static String qmName;
     private static String qName;
     private static MQQueueManager qMgr;
     static{
         //设置环境:
         //MQEnvironment中包含控制MQQueueManager对象中的环境的构成的静态变量，MQEnvironment的值的设定会在MQQueueManager的构造函数加载的时候起作用，
         //因此必须在建立MQQueueManager对象之前设定MQEnvironment中的值.
         MQEnvironment.hostname="192.168.223.129";     //MQ服务器的IP地址
         MQEnvironment.channel="SYSTEM.DEF.SVRCONN";             //服务器连接的通道,这个通道是默认有的不用创建
         MQEnvironment.CCSID=1381;         //服务器MQ服务使用的编码1381代表GBK、1208代表UTF(Coded Character Set Identifier:CCSID)
         MQEnvironment.port=1416;                        //MQ端口
         qmName = "QM_APPLE";                            //MQ的队列管理器名称
         qName = "Q1";                                //MQ远程队列的名称
         try {
             //定义并初始化队列管理器对象并连接
             //MQQueueManager可以被多线程共享，但是从MQ获取信息的时候是同步的，任何时候只有一个线程可以和MQ通信。
            qMgr = new MQQueueManager(qmName);
        } catch (MQException e) {
            // TODO Auto-generated catch block
            System.out.println("初使化MQ出错");
            e.printStackTrace();
        }
     }
     public static String getMessage(){
         String message=null;
         try{
             //设置将要连接的队列属性
         // Note. The MQC interface defines all the constants used by the WebSphere MQ Java programming interface
         //(except for completion code constants and error code constants).
         //MQOO_INPUT_AS_Q_DEF:Open the queue to get messages using the queue-defined default.
         //MQOO_OUTPUT:Open the queue to put messages.
             int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
             MQMessage retrieve = new MQMessage();
             //设置取出消息的属性（默认属性）
             //Set the put message options.（设置放置消息选项）
             MQGetMessageOptions gmo = new MQGetMessageOptions();
             gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT;//Get messages under sync point control（在同步点控制下获取消息）
             gmo.options = gmo.options + MQC.MQGMO_WAIT; // Wait if no messages on the Queue（如果在队列上没有消息则等待）
             gmo.options = gmo.options + MQC.MQGMO_FAIL_IF_QUIESCING;// Fail if Qeue Manager Quiescing（如果队列管理器停顿则失败）
             gmo.waitInterval = 1000 ; // Sets the time limit for the wait.（设置等待的毫秒时间限制）
             /*关闭了就重新打开*/
             if(qMgr==null || !qMgr.isConnected()){
                 qMgr = new MQQueueManager(qmName);
             }
             MQQueue queue = qMgr.accessQueue(qName, openOptions);
     // 从队列中取出消息
     queue.get(retrieve, gmo);
             message = retrieve.readUTF();
     System.out.println("The message is: " + message);
     queue.close();
         }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();
         }finally{
             try {
                qMgr.disconnect();
            } catch (MQException e) {
                e.printStackTrace();
            }
         }
         return message;
     }
     public static void main(String args[]) {
         /*下面两个方法可同时使用，也可以单独使用*/

         getMessage();
     }
}

新手学习中，花了好几天，找了好多篇文章，终于调通了，整理出来希望能帮助到需要的人。以后慢慢研究！！！