isppmib.java

一个SNMP4J开发的agent端程序

package com.poson.nmi.agent ;

import org.snmp4j.agent.DuplicateRegistrationException;
import org.snmp4j.agent.MOGroup;
import org.snmp4j.agent.MOServer;
import org.snmp4j.agent.mo.MOAccessImpl;
import org.snmp4j.agent.mo.MOFactory;
import org.snmp4j.agent.mo.MOScalar;
import org.snmp4j.agent.mo.MOTable;
import org.snmp4j.agent.mo.ext.SimMOFactory;
import org.snmp4j.log.LogAdapter;
import org.snmp4j.log.LogFactory;
import org.snmp4j.smi.Integer32;
import org.snmp4j.smi.OID;
import org.snmp4j.smi.OctetString;

import com.poson.nmi.common.ISPPMOFactory;
import com.poson.nmi.mo.*;


public class ISPPMib implements MOGroup{
	
	private static final LogAdapter LOGGER = LogFactory.getLogger(ISPPMib.class);
	private static MOFactory moFactory = SimMOFactory.getInstance();

	private MOServer moServer;
	private OctetString myContext;
	 
	private int alPlatformPortRowNum = 0 ;
	private int alDatabasePortRowNum = 0; 
	private int alApplicationPortRowNum = 0; 
	/****************************************************/
	/**************** Scalars OID ***********************/
	/****************************************************/
	/*** 内存大小***/
	public static final OID oidMemorySize =	new OID("1.3.6.1.4.1.20942.1.1.2.1.2.1.0"); 
	public MOScalar msMemorySize;		//	 Scalars
	/*** 使用内存大小***/
	public static final OID oidMemoryUsedSize =	new OID("1.3.6.1.4.1.20942.1.1.2.1.2.2.0"); 
	public MOScalar msMemoryUsedSize;		//	 Scalars
	/*** 使用率***/
	public static final OID oidMemoryUtility =	new OID("1.3.6.1.4.1.20942.1.1.2.1.2.3.0"); 
	public MOScalar msMemoryUtility;		//	 Scalars
	
	/*** 接收到的工单数***/
	public static final OID oidSpiReceive =	new OID("1.3.6.1.4.1.20942.1.1.2.2.1.1.0");  //后面为啥非得要加零
	public MOScalar msSpiReceive;		//	 Scalars
	/*** 回单成功的工单数***/
	public static final OID oidSpiReturnSuccess = new OID("1.3.6.1.4.1.20942.1.1.2.2.1.2.0");
	public MOScalar msSpiReturnSuccess ;
	/*** 回单成功的工单数***/
	public static final OID oidSpiReturnFailure = new OID("1.3.6.1.4.1.20942.1.1.2.2.1.3.0");
	public MOScalar msSpiReturnFailure ;
	
	/*** 处理成功的业务工单数***/
	public static final OID oidWoSuccess = new OID("1.3.6.1.4.1.20942.1.1.2.2.2.1.0");
	public MOScalar msWoSuccess ;
	/*** 处理成功的业务工单数***/
	public static final OID oidWoFailure = new OID("1.3.6.1.4.1.20942.1.1.2.2.2.2.0");
	public MOScalar msWoFailure ;
	
	/*** 拆分成功的业务工单数***/
	public static final OID oidSplitWorkorderSuccess = new OID("1.3.6.1.4.1.20942.1.1.2.2.3.1.0");
	public MOScalar msSplitWorkorderSuccess ;
	/*** 拆分成功的业务工单数***/
	public static final OID oidSplitWorkorderFailure = new OID("1.3.6.1.4.1.20942.1.1.2.2.3.2.0");
	public MOScalar msSplitWorkorderFailure ;
	
	/***HLR虚指令数量***/
	public static final OID oidVcommandHLR = new OID("1.3.6.1.4.1.20942.1.1.2.2.4.1.0");
	public MOScalar msVcommandHLR ;
	/***SCP虚指令数量***/
	public static final OID oidVcommandSCP = new OID("1.3.6.1.4.1.20942.1.1.2.2.4.2.0");
	public MOScalar msVcommandSCP ;
	/***HSS虚指令数量***/
	public static final OID oidVcommandHSS = new OID("1.3.6.1.4.1.20942.1.1.2.2.4.3.0");
	public MOScalar msVcommandHSS ;
	
	/***发送虚指令数量***/
	public static final OID oidNpiSend = new OID("1.3.6.1.4.1.20942.1.1.2.2.5.1.0");
	public MOScalar msNpiSend ;
	/***成功施工虚指令数量***/
	public static final OID oidNpiReturnSuccess = new OID("1.3.6.1.4.1.20942.1.1.2.2.5.2.0");
	public MOScalar msNpiReturnSuccess ;
	/***施工失败虚指令数量***/
	public static final OID oidNpiReturnFailure = new OID("1.3.6.1.4.1.20942.1.1.2.2.5.3.0");
	public MOScalar msNpiReturnFailure ; 
	
	
	
	/****************************************************/
	/************Platform Table  OID *****************/
	/****************************************************/
	public OID[] oidALPlatformPortIndex ;
	public OID[] oidALPlatformPortName ;
	public OID[] oidALPlatformPortAvStatus ;
	
	public MOScalar[] msALPlatformPortIndex ;
	public MOScalar[] msALPlatformPortName ;
	public MOScalar[] msALPlatformPortAvStatus ;
	/****************************************************/
	/************datebase Table  OID *****************/
	/****************************************************/
	public OID[] oidALDatabasePortIndex ;
	public OID[] oidALDatabasePortName ;
	public OID[] oidALDatabasePortAvStatus ;
	
	public MOScalar[] msALDatabasePortIndex ;
	public MOScalar[] msALDatabasePortName ;
	public MOScalar[] msALDatabasePortAvStatus ;
	/****************************************************/
	/************Application Table  OID *****************/
	/****************************************************/
	public static OID[] oidALApplicationPortIndex ;
	public static OID[] oidALApplicationPortName ;
	public static OID[] oidALApplicationPortAvStatus ;
	
	public MOScalar[] msALApplicationPortIndex ;
	public MOScalar[] msALApplicationPortName ;
	public MOScalar[] msALApplicationPortAvStatus ;
	
	/****************************************************/
	/****************CPU  Table  OID ********************/
	/****************************************************/
	public MOScalar[] alCPUPortIndex ;
	public MOScalar[] alCPUPortName ;
	public MOScalar[] alCPUPortAvStatus ;
	
	public OID[] oidALCPUPortIndex ;
	public OID[] oidALCPUPortName ;
	public OID[] oidALCPUAvStatus ;
	
	public ISPPMib(){
		
		// scarlar varable
		msMemorySize			=	new MemoryMOScalar(oidMemorySize,MOAccessImpl.ACCESS_READ_ONLY,MemoryMOScalar.TOTAL_SIZE) ;
		msMemoryUsedSize		=	new MemoryMOScalar(oidMemoryUsedSize,MOAccessImpl.ACCESS_READ_ONLY,MemoryMOScalar.USED_SIZE) ;
		msMemoryUtility			= 	new MemoryMOScalar(oidMemoryUtility,MOAccessImpl.ACCESS_READ_ONLY,MemoryMOScalar.USAGE) ;
		
		msSpiReceive 			=	new PFDbMOScalar(oidSpiReceive, MOAccessImpl.ACCESS_READ_ONLY);
		msSpiReturnSuccess 		= 	new PFDbMOScalar(oidSpiReturnSuccess, MOAccessImpl.ACCESS_READ_ONLY);
		msSpiReturnFailure 		= 	new PFDbMOScalar(oidSpiReturnFailure, MOAccessImpl.ACCESS_READ_ONLY);
		msWoSuccess				= 	new PFDbMOScalar(oidWoSuccess, MOAccessImpl.ACCESS_READ_ONLY);
		msWoFailure				= 	new PFDbMOScalar(oidWoFailure, MOAccessImpl.ACCESS_READ_ONLY);
		msSplitWorkorderSuccess = 	new PFDbMOScalar(oidSplitWorkorderSuccess, MOAccessImpl.ACCESS_READ_ONLY);
		msSplitWorkorderFailure = 	new PFDbMOScalar(oidSplitWorkorderFailure, MOAccessImpl.ACCESS_READ_ONLY);
		msVcommandHLR			=	new PFDbMOScalar(oidVcommandHLR, MOAccessImpl.ACCESS_READ_ONLY);
		msVcommandSCP			=	new PFDbMOScalar(oidVcommandSCP, MOAccessImpl.ACCESS_READ_ONLY);
		msVcommandHSS			=	new PFDbMOScalar(oidVcommandHSS, MOAccessImpl.ACCESS_READ_ONLY);
		msNpiSend				= 	new PFDbMOScalar(oidNpiSend, MOAccessImpl.ACCESS_READ_ONLY);
		msNpiReturnSuccess		= 	new PFDbMOScalar(oidNpiReturnSuccess, MOAccessImpl.ACCESS_READ_ONLY);
		msNpiReturnFailure		= 	new PFDbMOScalar(oidNpiReturnFailure, MOAccessImpl.ACCESS_READ_ONLY);
		
		// ALPlatformPort
		alPlatformPortRowNum = ISPPMOFactory.getInstance().getALRowNumber("alPlatformPortEntry") ;
		oidALPlatformPortIndex 	= new OID[alPlatformPortRowNum];
		oidALPlatformPortName 	= new OID[alPlatformPortRowNum];
		oidALPlatformPortAvStatus = new OID[alPlatformPortRowNum];
		
		msALPlatformPortIndex 	= new ALDbMOScalar[alPlatformPortRowNum];
		msALPlatformPortName 	= new ALDbMOScalar[alPlatformPortRowNum];
		msALPlatformPortAvStatus = new ALDbMOScalar[alPlatformPortRowNum];
		
		for(int i=0 ; i< alPlatformPortRowNum ; i++ )
		{
			oidALPlatformPortIndex[i] 	= new OID("1.3.6.1.4.1.20942.1.1.1.2.1.1.1.1."+i+".0") ;
			oidALPlatformPortName[i] 	= new OID("1.3.6.1.4.1.20942.1.1.1.2.1.1.1.2."+i+".0") ;
			oidALPlatformPortAvStatus[i] = new OID("1.3.6.1.4.1.20942.1.1.1.2.1.1.1.3."+i+".0") ;
			
			msALPlatformPortIndex[i] 	= new ALDbMOScalar(oidALPlatformPortIndex[i],MOAccessImpl.ACCESS_READ_ONLY) ;
			msALPlatformPortName[i] 	= new ALDbMOScalar(oidALPlatformPortName[i],MOAccessImpl.ACCESS_READ_ONLY) ;
			msALPlatformPortAvStatus[i] 	= new ALDbMOScalar(oidALPlatformPortAvStatus[i],MOAccessImpl.ACCESS_READ_ONLY) ;
		}
		
		//	ALPlatformPort
		alDatabasePortRowNum = ISPPMOFactory.getInstance().getALRowNumber("alDatabasePortEntry") ;
		oidALDatabasePortIndex 	= new OID[alDatabasePortRowNum];
		oidALDatabasePortName 	= new OID[alDatabasePortRowNum];