databasecachestatusmonitorimpl.java

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

package com.infobank.superchannel.admin.monitor.implementation;

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

import com.infobank.superchannel.admin.controller.DatabaseCacheController;
import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
import com.infobank.superchannel.daemon.databasecache.DatabaseCacheDaemon;
import com.infobank.superchannel.observer.implementation.CompoundDatabaseCacheStatusObserver;
import com.infobank.superchannel.observer.implementation.FilePersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.pojo.BlackListLog;
import com.infobank.superchannel.pojo.ControllerUserToken;
import com.infobank.superchannel.pojo.GenericLog;
import com.infobank.superchannel.pojo.TextMessageLog;
import com.infobank.superchannel.util.DaemonConfiguration;

/**
 * @author Xiaoguang Sun
 * @version 类说明: 数据库缓冲服务器的状态监控器实现
 */
public class DatabaseCacheStatusMonitorImpl
    implements DatabaseCacheStatusMonitor{
  // 数据库缓冲服务器状态复合观察者对象
  private CompoundDatabaseCacheStatusObserver observer=null;

  // 数据库缓冲服务器对象
  private DatabaseCacheDaemon daemon=null;

    // strong reference to rmi object
    DatabaseCacheStatusMonitor databaseCacheStatusMonitor=null;

  /**
   * 构造函数
   * @param deamon 数据库缓冲服务器对象
   */
  public DatabaseCacheStatusMonitorImpl(DatabaseCacheDaemon daemon){
    this.daemon=daemon;
    try{
      observer=new CompoundDatabaseCacheStatusObserver(new FilePersistenceDatabaseCacheStatusObserver(daemon));
      databaseCacheStatusMonitor=(DatabaseCacheStatusMonitor)UnicastRemoteObject.exportObject(this, 0);
      daemon.attachObserver(observer);
    }
    catch(RemoteException ex){
      System.err.println("fatal error: could not bind monitor to registry");
      throw new RuntimeException("fatal error: could not bind monitor to registry");
    }
  }
  
  /**
   * 构造函数
   * @param observer 观察者对象
   * @deprecated 仅供测试使用
   */
  public DatabaseCacheStatusMonitorImpl(MemoryPersistenceDatabaseCacheStatusObserver observer){
    this.observer=new CompoundDatabaseCacheStatusObserver(observer);
  }
  
  /**
   * 取得自上次调用此方法后所有黑名单更新日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后所有黑名单更新日志
   */
  public List<BlackListLog> getBlackListLog(ControllerUserToken token){
    return observer.getBlackListLog(token);
  }

  /**
   * 取得自上次调用此方法后被过滤掉的短信息内容日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后被过滤掉的短信息内容日志
   */
  public List<TextMessageLog> getBlockMessageLog(ControllerUserToken token){
    return observer.getBlockMessageLog(token);
  }

  /**
   * 取得待发消息队列尺寸
   * @param token 用户访问令牌
   * @return 待发消息队列尺寸
   */
  public int getMessageQueueSize(ControllerUserToken token){
    return observer.getMessageQueueSize(token);
  }

  /**
   * 取得自上次调用此方法后从数据库中取出的待发短信息日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后从数据库中取出的待发短信息日志
   */
  public List<TextMessageLog> getNewMessageLog(ControllerUserToken token){
    return observer.getNewMessageLog(token);
  }

  /**
   * 取得自上次调用此方法后新增短信息状态更新请求的日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后新增短信息状态更新请求的日志
   */
  public List<TextMessageLog> getNewMessageStatusLog(ControllerUserToken token){
    return observer.getNewMessageStatusLog(token);
  }

  /**
   * 取得累计发送失败短信息数目
   * @param token 用户访问令牌
   * @return 累计发送失败短信息数目
   */
  public int getNumberOfFailedMessages(ControllerUserToken token){
    return observer.getNumberOfFailedMessages(token);
  }

  /**
   * 取得累计发送成功短信息数目
   * @param token 用户访问令牌
   * @return 累计发送成功短信息数目
   */
  public int getNumberOfSuccessfulMessages(ControllerUserToken token){
    return observer.getNumberOfSuccessfulMessages(token);
  }

  /**
   * 取得状态更新回写队列尺寸
   * @param token 用户访问令牌
   * @return 状态更新回写队列尺寸
   */
  public int getStatusQueueSize(ControllerUserToken token){
    return observer.getStatusQueueSize(token);
  }

  /**
   * 取得自上次调用此方法后被过短信息状态被回写回数据库的日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后被过短信息状态被回写回数据库的日志
   */
  public List<TextMessageLog> getUpdateMessageLog(ControllerUserToken token){
    return observer.getUpdateMessageLog(token);
  }

  /**
   * 为当前用户访问令牌建立监控信息绑定
   * @param token 用户访问令牌
   * @return 操作是否成功
   */
  public boolean attach(ControllerUserToken token){
    return observer.attachObserver(token, new MemoryPersistenceDatabaseCacheStatusObserver());
  }

  /**
   * 为当前用户访问令牌解除监控信息绑定
   * @param token 用户访问令牌
   * @return 操作是否成功
   */
  public boolean detach(ControllerUserToken token){
    return observer.detachObserver(token);
  }

  /**
   * 获取自上次调用此方法后产生的所有通用日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后产生的所有通用日志
   */
  public List<GenericLog> getGenericLog(ControllerUserToken token){
    return observer.getGenericLog(token);
  }

  /**
   * 获取当前被监控组件的状态
   * @param token 用户访问令牌
   * @return 当前被监控组件的状态
   */
  public String getState(ControllerUserToken token){
    return daemon.getState();
  }

  public int getIncomingMessageQueueSize(ControllerUserToken token){
    return observer.getIncomingMessageQueueSize(token);
  }

  public List<TextMessageLog> getNewIncomingMessageLog(ControllerUserToken token){
    return observer.getNewIncomingMessageLog(token);
  }
}