databasecachecontrollerclient.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.DatabaseCacheController;
import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
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.ControllerUserToken;
import com.infobank.superchannel.pojo.GenericLog;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.pojo.TextMessageLog;

public class DatabaseCacheControllerClient extends Thread{
  private static DatabaseCacheController dcc=null;
  private ControllerUserToken token=null;
  private DatabaseCacheStatusMonitor dcm=null;
  private BlackListLog blacklistLog=null;
  private List<TextMessageLog> blockedMessageLog=null;
  private List<TextMessageLog> newMessageLog=null;
  private List<TextMessageLog> updateMessageLog=null;
  private List<TextMessageLog> newMessageStatusLog=null;
  private List<TextMessageLog> newIncomingMessageLog=null;
  private List<GenericLog> genericLog=null;
  public int messageQueueSize=0;
  public int numberOfFailedMessages=0;
  public int numberOfSuccessfulMessages=0;
  public int incomingMessageQueueSize=0;
  public int statusQueueSize=0;

  public static void main(String[] args){
    String host=(args.length<1)?null:args[0];
    try{
      Registry registry=LocateRegistry.getRegistry(host);
      dcc=(DatabaseCacheController) registry.lookup("DatabaseCacheController");
      DatabaseCacheControllerClient instance=new DatabaseCacheControllerClient();
      instance.start();
    }
    catch(Exception e){
      System.err.println("Client Exception: "+e.toString());
      e.printStackTrace();
      System.exit(1);
    }
  }
  
  public void run(){
    /*
    try{
      token=dcc.logon("admin", "admin");
      dcm=dcc.getStatusMonitor(token);
      while(true){
        blacklistLog=dcm.getBlackListLog(token);

        blockedMessageLog=dcm.getBlockMessageLog(token);
        if(blockedMessageLog!=null){
          for(TextMessageLog log:blockedMessageLog){
            System.err.print(log.timestamp.toString()+" New message being blocked:"+log.message.getMessage());
            System.err.println(". Because "+log.message.getPhone()+" is the recipient");
          }
        }
        
        newMessageLog=dcm.getNewMessageLog(token);
        if(newMessageLog!=null){
          for(TextMessageLog log:newMessageLog){
            System.err.println(log.timestamp.toString()+" New message is coming:"+log.message.getMessage());
          }
        }

        newIncomingMessageLog=dcm.getNewIncomingMessageLog(token);
        if(newIncomingMessageLog!=null){
          for(TextMessageLog log:newIncomingMessageLog){
            System.err.println(log.timestamp.toString()+" New incoming message:"+log.message.getMessage());
          }
        }

        updateMessageLog=dcm.getUpdateMessageLog(token);
        if(updateMessageLog!=null){
          for(TextMessageLog log:updateMessageLog){
            System.err.println(log.timestamp.toString()+" Updating message:"+log.message.getMessage());
          }
        }

        newMessageStatusLog=dcm.getNewMessageStatusLog(token);
        if(newMessageStatusLog!=null){
          for(TextMessageLog log:newMessageStatusLog){
            System.err.println(log.timestamp.toString()+" New message status change:"+log.message.getMessage());
          }
        }
        
        genericLog=dcm.getGenericLog(token);
        if(genericLog!=null){
          for(GenericLog log:genericLog){
            System.err.println(log.timestamp.toString()+log.level.toString()+log.log);
          }
        }
        
        int val=dcm.getMessageQueueSize(token);
        if(messageQueueSize!=val){
          messageQueueSize=val;
          System.err.println("Size of message queue is "+messageQueueSize+" now");
        }

        val=dcm.getIncomingMessageQueueSize(token);
        if(incomingMessageQueueSize!=val){
          incomingMessageQueueSize=val;
          System.err.println("Size of incoming message queue is "+incomingMessageQueueSize+" now");
        }

        val=dcm.getNumberOfFailedMessages(token);
        if(numberOfFailedMessages!=val){
          numberOfFailedMessages=val;
          System.err.println("Number of failed messages is "+numberOfFailedMessages);
        }
        val=dcm.getNumberOfSuccessfulMessages(token);
        if(numberOfSuccessfulMessages!=val){
          numberOfSuccessfulMessages=val;
          System.err.println("Number of successful messages is "+numberOfSuccessfulMessages);
        }
        val=dcm.getStatusQueueSize(token);
        if(statusQueueSize!=val){
          statusQueueSize=val;
          System.err.println("Statues queue size is "+statusQueueSize+" now");
        }
        Thread.sleep(2000);
        
        //dcc.stop(token);
      }
    }
    catch(Exception ex){
    }
    finally{
      try{
        dcc.logout(token);
      }catch(RemoteException ex){
        
      }
    }
    */
  }
}