channelstatusmonitorserver.java

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

package com.infobank.superchannel.test;

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.monitor.ChannelStatusMonitor;
import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
import com.infobank.superchannel.admin.monitor.implementation.ChannelStatusMonitorImpl;
import com.infobank.superchannel.admin.monitor.implementation.DatabaseCacheStatusMonitorImpl;
import com.infobank.superchannel.observer.ChannelStatusObserver;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceChannelStatusObserver;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.pojo.BlackList;
import com.infobank.superchannel.pojo.ChannelInfo;
import com.infobank.superchannel.pojo.TextMessage;

public class ChannelStatusMonitorServer {
  /**
   * @param args
   */
  /*
  public static void main(String[] args) {
    try{
      ChannelInfo channelInfo=new ChannelInfo("CMC5555","China Mobile 5555 Channel");
      RemoteChannelStatusObserver observer=new RemoteChannelStatusObserver();
      observer.averageTimeUsagePerMessage(100);
      observer.numberOfSentMessages(10000);
      observer.channelInfo(channelInfo);
      for(int idx=0;idx<10;++idx){
        observer.deliverMessage(new TextMessage("Deliver Message "+idx));
        Thread.sleep(100);
      }

      ChannelStatusMonitorImpl csmon = new ChannelStatusMonitorImpl(observer);
      csmon.attach();

      ChannelStatusMonitor stub = (ChannelStatusMonitor) UnicastRemoteObject.exportObject(csmon, 0);

        // Bind the remote object's stub in the registry
        Registry registry = LocateRegistry.getRegistry();
        registry.rebind("ChannelStatusMonitor", stub);

        System.err.println("Server is ready");
        
        Thread.sleep(10000);
        
        System.err.println("Server is preparing to shutdown");
        
        while(!UnicastRemoteObject.unexportObject(csmon, false)){
          Thread.sleep(1000);
        }
    } catch (Exception e) {
        System.err.println("Server exception: " + e.toString());
        e.printStackTrace();
    }
  }*/

}