IBM_MQ_MONITOR

package com.iss.ibm.monitor; import java.io.IOException; import java.util.Date; import java.util.List; import com.ibm.mq.MQException; import com.ibm.mq.MQQueue; import com.ibm.mq.MQQueueManager; import com.iss.context.MQMonitorContext; import com.iss.context.model.ContextModel; import com.iss.context.model.MQQueueManagerModel; import com.iss.context.model.MQServerModel; import com.iss.ibm.monitor.model.QueueMonitorTotleModel; import com.iss.ibm.monitor.util.TimeUtil; /** * MQ监控入口类 * @author 王成(chengwangi@isoftstone.com) * @date 2012-11-16 下午04:41:33 */ public class MQMonitor { /* 保存配置档信息的环境 */ private final MQMonitorContext monitorContext = new MQMonitorContext(); /** * 执行监控MQ,监控信息打印在Console中 * @author 王成(chengwangi@isoftstone.com) * @date 2012-11-23 上午11:24:07 * @param minute * @return 是否有信息打出，如果有返回true；如果没有返回false */ public boolean excuteMonitor(Integer minute , String reg) { boolean isHavePrint = false; /* 载入并获取mq配置信息 */ ContextModel contextModel = monitorContext.getContextModel(); List<MQServerModel> serverList = contextModel.getMqServerModel(); /* 轮询每个server和其下的每个MQManager */ for (MQServerModel mqServerModel : serverList) { String ip = mqServerModel.getIp(); List<MQQueueManagerModel> qmList = mqServerModel.getQueueManagerModelList(); if(excuteMonitorQM(ip, qmList , minute , reg) == true) isHavePrint = true; } return isHavePrint; } @SuppressWarnings("deprecation") private boolean excuteMonitorQM(String ip, List<MQQueueManagerModel> qmList , Integer minute , String reg) { long currentDate = new Date().getTime(); boolean isPrint = false; for (MQQueueManagerModel mqQueueManagerModel : qmList) { QueueManagerMonitor qmm = new QueueManagerMonitor(ip , mqQueueManagerModel.getPort() , mqQueueManagerModel.getUsername() , mqQueueManagerModel.getPassword() , mqQueueManagerModel.getQueueManagerName()); MQQueueManager qm = null; try { qm = qmm.getQueueManager(); } catch (MQException e1) { continue; } Print.printQM(qm.name); try { List<String> qs = qmm.getQueueNames(qm); for (String qname : qs) { if(qname.indexOf("SYSTEM") == 0 || check(qname, reg) == false) continue; QueueMonitor qMonitor = new QueueMonitor(qname , qm); int depth = qMonitor.getQueueDepthForQName(); if(depth > 0) { MQQueue queue = qMonitor.getBrowseQueueForQName(); QueueMonitorTotleModel totle = qMonitor.getQueueMonitorTotleMondelForEarliestQueue(queue); totle.setMsgCount(depth); if(minute == null || minute <= 0) { Print.printQueueMonitorTotle(totle); continue; } long earliestDate = totle.getEarliestMsgDate().getTime(); long differenceDate = currentDate - earliestDate; differenceDate = TimeUtil.getMinuteForMillisecond(differenceDate); if(differenceDate >= minute) { Print.printQueueMonitorTotle(totle); isPrint = true; } } } } catch (MQException e) { // e.printStackTrace(); } catch (IOException e) { // e.printStackTrace(); } } return isPrint; } /** * 方法入口， * 参数说明： * 1、可传入两个参数，第一个参数必须填，用来匹配需要检查queue名称的正则表达式 * 2、只填一个参数，会将mq中所有q都检测一遍，并打印queue信息。 * 3、填写参数例如：args[1]=3, * 那么会取q中最旧的一条msg,比对msg时间和当前系统时间，如果超过3分钟，会视为异常queue。将queue的信息打印， * 并在轮询方法调用结束后抛出异常 * * @author 王成(chengwangi@isoftstone.com) * @date 2012-11-23 下午01:16:51 * @param args * @throws Exception */ public static void main(String[] args) throws Exception { // args = new String[1]; // args[0] = "(S\\d{5}_[0-9A-Z]{6}_HLC)|(HLC_[0-9A-Z]{6}_S\\d{5})"; String reg = args[0]; Integer minute = null; if(args != null && args.length == 2) minute = new Integer(args[1]); MQMonitor m = new MQMonitor(); boolean isPrint = m.excuteMonitor(minute , reg); if(isPrint == true && minute != null && minute > 0) throw new Exception(); } public static boolean check(String data , String reg) { //return data.matches("(S\\d{5}_[0-9A-Z]{6}_HLC)|(HLC_[0-9A-Z]{6}_S\\d{5})"); return data.matches("reg"); } }