import org.snmp4j.CommunityTarget;
import org.snmp4j.PDU;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import org.snmp4j.mp.SnmpConstants;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OID;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.DefaultPDUFactory;
import org.snmp4j.util.TableEvent;
import org.snmp4j.util.TableUtils;
import java.io.IOException;
import java.util.List;
//注：双方都启动了snmp协议的情况下才起作用。snmp4j架包请自行到官网下载
/**
* @author : hzs
* @date : 15:12 2019/10/22
*/
public class snmp {
public static final int DEFAULT_VERSION = SnmpConstants.version2c;
public static final String DEFAULT_PROTOCOL = "udp";
public static final int DEFAULT_PORT = 161;
public static final int DEFAULT_RETRY = 3;
public static final int DEFAULT_TIMEOUT = 8000;
public static void main(String[] args) {
creatSnmp("主机的IP");
}
/**
* 创建snmp
* @description:
* @param ip
* @return: void
* @author: hzs
* @time: 2019/10/30 17:22
*/
public static void creatSnmp(String ip) {
TransportMapping transport = null;
Snmp snmp = null;
CommunityTarget target;
try {
transport = new DefaultUdpTransportMapping();
snmp = new Snmp(transport);//创建snmp
snmp.listen();//监听消息
target = new CommunityTarget();
target.setCommunity(new OctetString("public"));//社区名称
target.setRetries(DEFAULT_RETRY);//连接次数
target.setAddress(GenericAddress.parse(""+DEFAULT_PROTOCOL+":"+ip+"/"+DEFAULT_PORT+""));//监控的主机
target.setTimeout(DEFAULT_TIMEOUT);
target.setVersion(DEFAULT_VERSION);
String memory = collectMemory(snmp, target);
System.out.println("内存使用率为：" + memory);
String cpu = collectCPU(snmp, target);
System.out.println("CPU利用率为：" + cpu);
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (transport != null)
transport.close();
if (snmp != null)
snmp.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 获取内存相关信息
* @description:
* @param snmp
* @param target
* @return: java.lang.String
* @author: hzs
* @time: 2019/10/30 17:22
*/
public static String collectMemory(Snmp snmp, CommunityTarget target) {
String memory = null;
String[] oids = {"1.3.6.1.2.1.25.2.3.1.2", //type 存储单元类型
"1.3.6.1.2.1.25.2.3.1.3", //descr
"1.3.6.1.2.1.25.2.3.1.4", //unit 存储单元大小
"1.3.6.1.2.1.25.2.3.1.5", //size 总存储单元数
"1.3.6.1.2.1.25.2.3.1.6"}; //used 使用存储单元数;
String PHYSICAL_MEMORY_OID = "1.3.6.1.2.1.25.2.1.2";//物理存储
try {
TableUtils tableUtils = new TableUtils(snmp, new DefaultPDUFactory(PDU.GETBULK));
OID[] columns = new OID[oids.length];
for (int i = 0; i < oids.length; i++)
columns[i] = new OID(oids[i]);
List<TableEvent> list = tableUtils.getTable(target, columns, null, null);
for (TableEvent event : list) {
VariableBinding[] values = event.getColumns();
if (values == null) continue;
int unit = Integer.parseInt(values[2].getVariable().toString());//unit 存储单元大小
int totalSize = Integer.parseInt(values[3].getVariable().toString());//size 总存储单元数
int usedSize = Integer.parseInt(values[4].getVariable().toString());//used 使用存储单元数
String oid = values[0].getVariable().toString();
if (PHYSICAL_MEMORY_OID.equals(oid)) {
memory = (long) usedSize * 100 / totalSize + "%";
}
}
} catch (Exception e) {
e.printStackTrace();
}
return memory;
}
/**
* 获取cpu使用率
* @description:
* @param snmp
* @param target
* @return: java.lang.String
* @author: hzs
* @time: 2019/10/30 17:23
*/
public static String collectCPU(Snmp snmp, CommunityTarget target) {
String cpu = null;
String[] oids = {"1.3.6.1.2.1.25.3.3.1.2"};
try {
TableUtils tableUtils = new TableUtils(snmp, new DefaultPDUFactory(PDU.GETBULK));
OID[] columns = new OID[oids.length];
for (int i = 0; i < oids.length; i++)
columns[i] = new OID(oids[i]);
List<TableEvent> list = tableUtils.getTable(target, columns, null, null);
int percentage = 0;
for (TableEvent event : list) {
VariableBinding[] values = event.getColumns();
if (values != null)
percentage += Integer.parseInt(values[0].getVariable().toString());
}
cpu = percentage / list.size() + "%";
} catch (Exception e) {
e.printStackTrace();
}
return cpu;
}
}
