messagelaunchercontrollerclient.java.svn-base

监控整个SP系统的SMS信息通道的发送情况并且生成日志。 支持权限判断。

package com.infobank.superchannel.test;

import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import java.util.LinkedList;
import java.util.List;

import com.infobank.superchannel.admin.controller.MessageLauncherController;
import com.infobank.superchannel.admin.monitor.ChannelStatusMonitor;
import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
import com.infobank.superchannel.admin.monitor.MessageLauncherStatusMonitor;
import com.infobank.superchannel.admin.monitor.implementation.DatabaseCacheStatusMonitorImpl;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.pojo.BlackList;
import com.infobank.superchannel.pojo.BlackListLog;
import com.infobank.superchannel.pojo.ChannelInfo;
import com.infobank.superchannel.pojo.ControllerUserToken;
import com.infobank.superchannel.pojo.GenericLog;
import com.infobank.superchannel.pojo.MessageBucketLog;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.pojo.TextMessageLog;

public class MessageLauncherControllerClient extends Thread{
  private static MessageLauncherController mlc;
  private static MessageLauncherStatusMonitor monitor;
  private static List<ChannelStatusMonitor> channelMonitors;
  
  private List<TextMessageLog> changeMessageStatusLog=null;
  
  private List<MessageBucketLog> newMassMessageBucketLog=null;
  
  private List<MessageBucketLog> newGeneralMessageBucketLog=null;
  
  private List<GenericLog> genericLog=null;

  private int massMessageQueueSize=0;
  
  private int generalMessageQueueSize=0;

  private ControllerUserToken token;
  public static void main(String[] args) {
    String host=(args.length<1)?null:args[0];
    try{
      Registry registry=LocateRegistry.getRegistry(host);
      mlc=(MessageLauncherController) registry.lookup("MessageLauncherController");
      new MessageLauncherControllerClient().start();
    }
    catch(Exception e){
      System.err.println("Client Exception: "+e.toString());
      e.printStackTrace();
    }
  }
  
  public void run(){
    /*
    try{
      token=mlc.logon("admin", "admin");
      monitor=mlc.getStatusMonitor(token);
      channelMonitors=mlc.getChannelMonitor(token);
      
      while(true){
        changeMessageStatusLog=monitor.getChangeMessageStatusLog(token);
        if(changeMessageStatusLog!=null){
          for(TextMessageLog log:changeMessageStatusLog){
            System.err.println(log.timestamp.toString()+" change message status:"+log.message.getMessage());
          }
        }
        
        newMassMessageBucketLog=monitor.getNewMassMessageBucketLog(token);
        if(newMassMessageBucketLog!=null){
          for(MessageBucketLog log:newMassMessageBucketLog){
            System.err.println(log.timestamp.toString()+" new mass message bucket with "+log.size+" messages :"+log.content);
          }
        }

        newGeneralMessageBucketLog=monitor.getNewGeneralMessageBucketLog(token);
        if(newGeneralMessageBucketLog!=null){
          for(MessageBucketLog log:newGeneralMessageBucketLog){
            System.err.println(log.timestamp.toString()+" new general message bucket with "+log.size+" messages :"+log.content);
          }
        }
        genericLog=monitor.getGenericLog(token);
        if(genericLog!=null){
          for(GenericLog log:genericLog){
            System.err.println(log.timestamp.toString()+log.level.toString()+log.log);
          }
        }
        
        int val=monitor.getMassMessageQueueSize(token);
        if(massMessageQueueSize!=val){
          massMessageQueueSize=val;
          System.err.println("Size of mass message queue is "+massMessageQueueSize + " now");
        }

        val=monitor.getGeneralMessageQueueSize(token);
        if(generalMessageQueueSize!=val){
          generalMessageQueueSize=val;
          System.err.println("Size of general message queue is "+generalMessageQueueSize + " now");
        }
        
        for(ChannelStatusMonitor csMonitor:channelMonitors){
          ChannelInfo ci=csMonitor.getChannelInfo(token);
          List<TextMessageLog> log=csMonitor.getDeliverMessageLog(token);
          System.err.println("Channel "+ci.name + ":"+ci.description);
          System.err.println("has sent "+csMonitor.getNumberOfSentMessages(token)+" messages");
          System.err.println("Successful/Failed:"+csMonitor.getNumberOfSuccessfulMessages(token)+"/"+csMonitor.getNumberOfFailedMessages(token));
          System.err.println("average time takes to send a message is "+csMonitor.getAverageTimeUsagePerMessage(token));
          for(TextMessageLog textMessageLog:log){
            System.err.println(textMessageLog.timestamp.toString()+" sending message:"+textMessageLog.message);
          }
        }

        Thread.sleep(2000);
      }
    }
    catch(Exception ex){
    }
    finally{
      try{
        mlc.logout(token);
      }
      catch(RemoteException ex){
        
      }
    }
    */
  }
}