snmpagent.java

关于 RFID 读写器的相关内容

		/**************************
		 * epcgReaderDeviceMemory *
		 **************************/
		
		EpcgScalar epcgRdrDevFreeMemory = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY, MOAccessImpl.ACCESS_READ_ONLY, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemory, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevFreeMemoryNotifEnable = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY_NOTIF_ENABLE, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemoryNotifEnable, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevFreeMemoryNotifLevel = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY_NOTIF_LEVEL, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemoryNotifLevel, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevFreeMemoryOnsetThreshold = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY_ONSET_THRESHOLD, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemoryOnsetThreshold, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevFreeMemoryAbateThreshold = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY_ABATE_THRESHOLD, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemoryAbateThreshold, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevFreeMemoryStatus = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_FREE_MEMORY_STATUS, MOAccessImpl.ACCESS_READ_ONLY, null, readerDevice);
		try {
			server.register(epcgRdrDevFreeMemoryStatus, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevMemStateSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_MEM_STATE_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
		try {
			server.register(epcgRdrDevMemStateSuppressInterval, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar epcgRdrDevMemStateSuppressions = new EpcgScalar(EpcgScalarType.EPCG_RDR_DEV_MEM_STATE_SUPPRESSIONS, MOAccessImpl.ACCESS_READ_ONLY, new Counter32(0), readerDevice);
		try {
			server.register(epcgRdrDevMemStateSuppressions, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		
		/******************
		 * epcgReadPoints *
		 ******************/
		
//		EpcgScalar epcgReadPointPriorOperStatus = new EpcgScalar(EpcgScalarType.EPCG_READ_POINT_PRIOR_OPER_STATUS, MOAccessImpl.ACCESS_FOR_NOTIFY, new Integer32(OperationalStatus.UNKNOWN.toInt()), readerDevice);
//		try {
//			server.register(epcgReadPointPriorOperStatus, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgReadPointOperStateSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_READ_POINT_OPER_STATE_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
//		try {
//			server.register(epcgReadPointOperStateSuppressInterval, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgReadPointOperStateSuppressions = new EpcgScalar(EpcgScalarType.EPCG_READ_POINT_OPER_STATE_SUPPRESSIONS, MOAccessImpl.ACCESS_READ_ONLY, new Counter32(0), readerDevice);
//		try {
//			server.register(epcgReadPointOperStateSuppressions, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
		
		/*************************
		 * epcgAntennaReadPoints *
		 *************************/
		
//		EpcgScalar epcgAntRdPntSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_ANT_RD_PNT_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
//		try {
//			server.register(epcgAntRdPntSuppressInterval, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
		
		/***************
		 * epcgIoPorts *
		 ***************/
		
//		EpcgScalar epcgIoPortOperStatusPrior = new EpcgScalar(EpcgScalarType.EPCG_IO_PORT_OPER_STATUS_PRIOR, MOAccessImpl.ACCESS_FOR_NOTIFY, new Integer32(OperationalStatus.UNKNOWN.toInt()), readerDevice);
//		try {
//			server.register(epcgIoPortOperStatusPrior, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgIoPortOperStateSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_IO_PORT_OPER_STATE_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
//		try {
//			server.register(epcgIoPortOperStateSuppressInterval, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgIoPortOperStateSuppressions = new EpcgScalar(EpcgScalarType.EPCG_IO_PORT_OPER_STATE_SUPPRESSIONS, MOAccessImpl.ACCESS_READ_ONLY, new Counter32(0), readerDevice);
//		try {
//			server.register(epcgIoPortOperStateSuppressions, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
		
		/***************
		 * epcgSources *
		 ***************/
		
//		EpcgScalar epcgSrcOperPriorStatus = new EpcgScalar(EpcgScalarType.EPCG_SRC_OPER_PRIOR_STATUS, MOAccessImpl.ACCESS_FOR_NOTIFY, new Integer32(OperationalStatus.UNKNOWN.toInt()), readerDevice);
//		try {
//			server.register(epcgSrcOperPriorStatus, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgSrcOperStateSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_SRC_OPER_STATE_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
//		try {
//			server.register(epcgSrcOperStateSuppressInterval, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgSrcOperStateSuppressions = new EpcgScalar(EpcgScalarType.EPCG_SRC_OPER_STATE_SUPPRESSIONS, MOAccessImpl.ACCESS_READ_ONLY, new Counter32(0), readerDevice);
//		try {
//			server.register(epcgSrcOperStateSuppressions, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
		
		/****************************
		 * epcgNotificationChannels *
		 ****************************/
		
//		EpcgScalar epcgNotifChanOperStatusPrior = new EpcgScalar(EpcgScalarType.EPCG_NOTIF_CHAN_OPER_STATUS_PRIOR, MOAccessImpl.ACCESS_FOR_NOTIFY, new Integer32(OperationalStatus.UNKNOWN.toInt()), readerDevice);
//		try {
//			server.register(epcgNotifChanOperStatusPrior, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgNotifChanOperStateSuppressInterval = new EpcgScalar(EpcgScalarType.EPCG_NOTIF_CHAN_OPER_STATE_SUPPRESS_INTERVAL, MOAccessImpl.ACCESS_READ_WRITE, new UnsignedInteger32(0), readerDevice);
//		try {
//			server.register(epcgNotifChanOperStateSuppressInterval, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
//		EpcgScalar epcgNotifChanOperStateSuppressions = new EpcgScalar(EpcgScalarType.EPCG_NOTIF_CHAN_OPER_STATE_SUPPRESSIONS, MOAccessImpl.ACCESS_READ_ONLY, new Counter32(0), readerDevice);
//		try {
//			server.register(epcgNotifChanOperStateSuppressions, null);
//		} catch (DuplicateRegistrationException dre) {
//			log.debug(dre.getMessage());
//		}
		
		/********
		 * IETF *
		 ********/
		
		EpcgScalar sysDescr = new EpcgScalar(EpcgScalarType.SYS_DESCR, MOAccessImpl.ACCESS_READ_ONLY, null, readerDevice);
		try {
			MOScalar moScalar = SnmpUtil.findMOScalar(new OID(new int[] { 1,3,6,1,2,1,1,1,0 }));
			server.unregister(moScalar, null);
			server.register(sysDescr, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar sysLocation = new EpcgScalar(EpcgScalarType.SYS_LOCATION, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			MOScalar moScalar = SnmpUtil.findMOScalar(new OID(new int[] { 1,3,6,1,2,1,1,6,0 }));
			server.unregister(moScalar, null);
			server.register(sysLocation, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar sysContact = new EpcgScalar(EpcgScalarType.SYS_CONTACT, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			MOScalar moScalar = SnmpUtil.findMOScalar(new OID(new int[] { 1,3,6,1,2,1,1,4,0 }));
			server.unregister(moScalar, null);
			server.register(sysContact, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar sysUpTime = new EpcgScalar(EpcgScalarType.SYS_UP_TIME, MOAccessImpl.ACCESS_READ_ONLY, null, readerDevice);
		try {
			MOScalar moScalar = SnmpUtil.findMOScalar(new OID(new int[] { 1,3,6,1,2,1,1,3,0 }));
			server.unregister(moScalar, null);
			server.register(sysUpTime, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
		EpcgScalar sysName = new EpcgScalar(EpcgScalarType.SYS_NAME, MOAccessImpl.ACCESS_READ_WRITE, null, readerDevice);
		try {
			MOScalar moScalar = SnmpUtil.findMOScalar(new OID(new int[] { 1,3,6,1,2,1,1,5,0 }));
			server.unregister(moScalar, null);
			server.register(sysName, null);
		} catch (DuplicateRegistrationException dre) {
			log.debug(dre.getMessage());
		}
		
	}
	
	/**
	 * Adds the given <code>AlarmChannel</code>s.
	 * 
	 * @param alarmChannels
	 *            The <code>AlarmChannel</code>s to add
	 */
	public void addAlarmChannels(AlarmChannel[] alarmChannels) {
		for (int i = 0; i < alarmChannels.length; i++) {
			AlarmChannel curChan = alarmChannels[i];
			Address curAddr = curChan.getAddress();
			
			if (snmpTargetMIB != null) {
				snmpTargetMIB.addTargetAddress(new OctetString(curChan
						.getName()), TransportDomains.transportDomainUdpIpv4,
						new OctetString(new UdpAddress(curAddr.getHost() + "/"
								+ curAddr.getPort()).getValue()), 200, 1,
						new OctetString("notify"), new OctetString("v2c"),
						StorageType.permanent);
			} else {
				log.error("Run the init() method first.");
				return;
			}
		}
	}
	
	/**
	 * Removes an <code>AlarmChannel</code>.
	 * 
	 * @param alarmChannel
	 *            The <code>AlarmChannel</code> to remove
	 */
	public void removeAlarmChannel(AlarmChannel alarmChannel) {
		if (snmpTargetMIB != null) {
			snmpTargetMIB.removeTargetAddress(new OctetString(alarmChannel.getName()));
		} else {
			log.error("Run the init() method first.");
		}
	}
	
	/**
	 * Checks whether this agent has been initialized already.
	 * 
	 * @return <code>true</code> if this agent has been initialized already,
	 *         <code>false</code> otherwise
	 */
	public boolean isInitialized() {
		return initialized;
	}
	
}