JAVA操做IBM MQ

java往MQ里面发消息和取消息

package 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;  
import com.ibm.mq.constants.MQConstants;
      
    public class test1{   
         //定义队列管理器和队列的名称   
     private static String qmName;    
     private static String qName;   
     private static MQQueueManager qMgr;   
     static{   
         //设置环境:   
             //MQEnvironment中包含控制MQQueueManager对象中的环境的构成的静态变量，MQEnvironment的值的设定会在MQQueueManager的构造函数加载的时候起做用，   
             //所以必须在创建MQQueueManager对象以前设定MQEnvironment中的值.   
         MQEnvironment.hostname="172.31.17.162";          //MQ服务器的IP地址         
         MQEnvironment.channel="SVRCONN_GW";              //服务器链接的通道   
         MQEnvironment.CCSID=1208;                      //服务器MQ服务使用的编码1381表明GBK、1208表明UTF(Coded Character Set Identifier:CCSID)   
         MQEnvironment.port=33333;                       //MQ端口   
         qmName = "QM_TEST";                          //MQ的队列管理器名称   
         qName = "TEST";                               //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;   
     }   
     /**  
      * 从队列中去获取消息，若是队列中没有消息，就会发生异常，不过没有关系，有TRY...CATCH，若是是第三方程序调用方法，若是无返回则说明无消息  
      * 第三方能够将该方法放于一个无限循环的while(true){...}之中，不须要设置等待，由于在该方法内部在没有消息的时候会自动等待。  
      * @return  
      */  
     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);
                 byte[] buf = new byte[retrieve.getMessageLength()];
                 retrieve.readFully(buf);
                     
                 System.out.println("The message is: " + new String(buf));    
                 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[]) throws InterruptedException {   
             /*下面两个方法可同时使用，也能够单独使用*/  
             //sendMessage("this is a test");
             //System.out.println("jwh");
             for (int i = 0; i < 100; i++) {
                 getMessage();
                 Thread.sleep(20000);
            }
               
             
             
         }   
    }  
    *