MQ队列管理

分享一段代码，很实用。

下面这段java代码是我在国外一个论坛上发现的，源地址已经忘了。代码的作用是可以删除正在使用的mq的队列消息，管理mq的人一定知道它的美妙了吧，哈哈。

我拿来改了下，增加了2个参数支持：ccsid和channel。上代码：

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

/**
 * A simply Java class to destructively read (delete) all message on a queue.
 * 
 * @author Roger Lacroix, Capitalware Inc.
 * @return 0 for ok or 1 for failed.
 * @version 1.0.0
 * @license Apache 2 License
 */

/**
 * lichmama reedited
 * change: add parameters to set ccsid and channel
 */

public class EmptyQ
{
   private Hashtable params = null;
   public int port = 1414;
   public String hostname;
   public String channel;
   public String qManager;
   public String inputQName;
   public int ccsid = 1208;

   /**
    * The constructor
    */
   public EmptyQ()
   {
      super();
   }
   
   /**
    * Check if all of the parameters were passed to the class file.
    * @return true/false
    */
   private boolean allParamsPresent()
   {
      boolean b =  params.containsKey("-s") && params.containsKey("-h") && params.containsKey("-p") && params.containsKey("-c") && params.containsKey("-m") && params.containsKey("-q");
      if (b)
      {
         try
         {
            port = Integer.parseInt((String) params.get("-p"));
            ccsid = Integer.parseInt((String) params.get("-s"));
         }
         catch (NumberFormatException e)
         {
            b = false;
         }
         // Set up MQ environment
         hostname = (String) params.get("-h");
         channel = (String) params.get("-c");
         qManager = (String) params.get("-m");
         inputQName = (String) params.get("-q");

      }
      return b;
   }
   
   /**
    * Initialize MQ environment variables
    * @param args
    * @throws IllegalArgumentException
    */
   private void init(String[] args) throws IllegalArgumentException
   {
      params = new Hashtable(5);
      if (args.length > 0 && (args.length % 2) == 0)
      {
         for (int i = 0; i < args.length; i += 2)
            params.put(args[i], args[i + 1]);
      }
      else
      {
         throw new IllegalArgumentException();
      }
      if (allParamsPresent())
      {
         // Set up MQ environment
         MQEnvironment.hostname = hostname;
         MQEnvironment.channel = channel;
         MQEnvironment.port = port;
         //CCSID: DIS QMGR CCSID
         MQEnvironment.CCSID = ccsid;
         MQException.log = null; /* Tell MQ client library not to output anything. */
      }
      else
      {
         throw new IllegalArgumentException();
      }
   }
   
   /**
    * Main entry point.
    * @param args
    */
   public static void main(String[] args)
   {

      EmptyQ readQ = new EmptyQ();

      try
      {
         readQ.init(args);
         readQ.emptyIt();
      }
      catch (IllegalArgumentException e)
      {
         System.err.println("Usage: java EmptyQ <-s ccsid> <-h host> <-p port> <-c channel> <-m QueueManagerName> <-q QueueName>");
         System.exit(1);
      }
   }
   
   /**
    * Connect to a queue manager, open a queue then destructively get (delete)
    * all messages on the queue.   
    */
   private void emptyIt()
   {
      boolean loopAgain = true;
      MQQueueManager _queueManager = null;
      MQQueue queue = null;
      int openOptions = MQC.MQOO_INQUIRE + MQC.MQOO_FAIL_IF_QUIESCING + MQC.MQOO_INPUT_SHARED;
      System.out.println("EmptyQ v1.0.0 by Capitalware Inc.");
      try
      {
         _queueManager = new MQQueueManager(qManager);
         System.out.println("EmptyQ: Connected to queue manager "+qManager);
         
         try
         {
            queue = _queueManager.accessQueue(inputQName, openOptions, null, null, null);
            System.out.println("EmptyQ: Opened queue "+inputQName);
            
            int depth = queue.getCurrentDepth();
            System.out.println("EmptyQ: Current depth: " + depth);

            MQGetMessageOptions getOptions = new MQGetMessageOptions();
            getOptions.options = MQC.MQGMO_NO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING + MQC.MQGMO_ACCEPT_TRUNCATED_MSG;
            
            MQMessage message;
            while (loopAgain)
            {
               message = new MQMessage();
               try
               {
                  queue.get(message, getOptions, 1);
               }
               catch (MQException e)
               {
                  if (e.completionCode == 1 && e.reasonCode == MQException.MQRC_TRUNCATED_MSG_ACCEPTED)
                  {
                      // Just what we expected!!
                  }
                  else
                  {
                     loopAgain = false;
                     if (e.completionCode == 2 && e.reasonCode == MQException.MQRC_NO_MSG_AVAILABLE)
                     {
                        // Good, we are now done - no error!!
                     }
                     else
                     {
                        System.err.println("EmptyQ: MQException: " + e.getLocalizedMessage());
                     }
                  }
               }
            }
            System.out.println("EmptyQ: Queue emptied.");
         }
         catch (MQException e1)
         {
            System.err.println("EmptyQ: MQException: " + e1.getLocalizedMessage());
         }
         finally
         {
            if (queue != null)
            {
               queue.close();
               System.out.println("EmptyQ: Closed queue "+inputQName);
            }

            if (_queueManager != null)
            {
               _queueManager.disconnect();
               System.out.println("EmptyQ: Disconnect from "+qManager);
            }
         }
      }
      catch (MQException e1)
      {
         System.err.println("EmptyQ: MQException: " + e1.getLocalizedMessage());
      }
   }
}

下面，再贴一个我用shell写的壳：

#!/bin/bash
#       File:   clearMQ.sh
#       Whatfor:empty the queue's curdepth WHEN IT OVERSTOCKS,
#               and all the performance depends on EmptyQ.class,
#               which [@author Roger Lacroix, Capitalware Inc.] made it.thx this guy:)
#       Auth:   nextgodhand@163.com
#       Usage:  ./clearMQ.sh <QueueManagerName> <QueueName> [CHANNEL_NAME]
#

#set user env. 
#. ~/.bash_profile

if [ $# -lt 2 ]; then
        echo "Usage: $0 <QueueManagerName> <QueueName> [CHANNEL_NAME]"
        exit 1
fi

QMGR=$1
QNME=$2
CHNN=$3

if [ -z "`dspmq|grep "$QMGR"`" ]; then
        echo "Error: $QMGR not running."
        exit 2
fi

if [ -z "`echo "DIS QUEUE(*)"|runmqsc $QMGR|grep "($QNME)"`" ]; then
        echo "Error: $QNME not exists in $QMGR."
        exit 3
fi

if [ -z "$CHNN" ]; then
        CHNN="SYSTEM.ADMIN.SVRCONN"
fi

CCSID=`echo "DIS QMGR CCSID"|runmqsc $QMGR|grep -oE "CCSID([0-9]+)"|awk -F'(' '{printf "%d",$2}'`
PORT=`ps -fumqm|grep runmqlsr|grep " $QMGR "|awk '{print $NF}'`

java -cp .:$CLASSPATH EmptyQ -s $CCSID -h localhost -c $CHNN -p $PORT -m $QMGR -q $QNME

 使用起来很方便：

 ./clearMQ.sh mq_xxx queue_yyy