snmp4j介绍及api使用

妖狐艹你老母 2022-05-22 05:05 391阅读 0赞

# 一、SNMP简介 #

SNMP指的是简单网络管理协议。它属于TCP/IP五层协议中的应用层协议。它提供了一种简单和方便的模式来管理网络中的各个元素。这里的元素就是各个被管理的对象，可以是因特网中的某个硬件，比如网卡，也可以是某些硬件和软件的配置参数的集合。由于SNMP协议简单可靠 ，受到了众多厂商的欢迎，成为了目前最为广泛的网管协议。

SNMP协议主要由两大部分构成：SNMP管理站和SNMP代理。SNMP管理站是一个中心节点，负责收集维护各个SNMP元素的信息，并对这些信息进行处理，最后反馈给网络管理员；而SNMP代理是运行在各个被管理的网络节点之上，负责统计该节点的各项信息，并且负责与SNMP管理站交互，接收并执行管理站的命令，上传各种本地的网络信息。

SNMP管理站和SNMP代理之间是松散耦合。他们之间的通信是通过UDP协议完成的。一般情况下，SNMP管理站通过UDP协议向SNMP代理发送各种命令，当SNMP代理收到命令后，返回SNMP管理站需要的参数。但是当SNMP代理检测到网络元素异常的时候，也可以主动向SNMP管理站发送消息，通告当前异常状况。

SNMP协议于1988年发布。到目前一共经历了V1，V2，V3三个版本。其中V1已经被废弃，而V2c虽然没有能够成为正式标准，但是已经被很多厂家所接受，V3目前是因特网的正式标准。与V1相比，V2，V3更能适应大规模的网络管理，而且在安全方面有了较大的改进。

# 二一、[Win7开启SNMP服务][Win7_SNMP]  #

通过SNMP监控Windows主机需要在被监控的服务器上安装简单网络管理协议（SNMP）的Windows组件，以Windows 7系统为例：  
首先，在控制面板中找到“卸载程序”；

![18406763][]

在弹出的窗口中单击“打开或关闭Windows功能”；

![18406763][]

勾选弹出窗口中的“简单网络管理协议（SNMP）”项后单击“确定”并根据提示完成安装即可。

![SouthEast][]

完成SNMP服务的安装后，右键单击“计算机”选择“管理”

![SouthEast 1][]

在弹出的“计算机管理”窗口中左侧导航栏中找到“服务”，并在右侧找到“SNMP Service”项；

![SouthEast 2][]

鼠标双击“SNMP Service”选项，在弹出的窗口中切换到“安全”选项卡中，如上图添加“接受的社区名称”和接收那些主机发出的SNMP数据包。

![SouthEast 3][]

“接受的社区名称”是自己定义的任意字符都可以，接收那些主机发出的SNMP数据包定义成你的Nagios服务器即可。到这里被监控端的Windows主机的SNMP服务就配置完成了。

### 二二、Linux ###

###     ###

1、检查是否有SNMP服务，若没有，请先安装

service snmpd status  \#查看是否安装snmp

yum install -y net-snmp\* \#若没安装，则安装

2、先编辑Snmp的配置文件，设置安全的验证方式

vi /etc/snmp/snmpd.conf

3、设置完毕，开关SNMP

service snmpd start

service snmpd stop

4、设置SNMP开机自动启动

chkconfig snmpd on

chkconfig snmpd off

5、增强的SNMP安全性

/etc/sysconfig/iptables 中

iptables -A INPUT  -p udp -s 192.168.2.18 --dport 161 -j ACCEPT

service iptables save

以上做的目的，就是只让指定的监控服务器(IP)才能与您的SNMP服务建立连接。

# 三、snmp4j例子 #

准备工作：snmp4j的jar包可以在它的官方网站[http://www.snmp4j.org/][http_www.snmp4j.org]上下载

## 1、获取CPU利用率方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //获取cpu使用率  
2.  **public** **static** **void** collectCPU() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] oids = \{ "1.3.6.1.2.1.25.3.3.1.2"\};  
7.  **try** \{  
8.  transport = **new** DefaultUdpTransportMapping();  
9.  snmp = **new** Snmp(transport);//创建snmp  
10. snmp.listen();//监听消息  
11. target = **new** CommunityTarget();  
12. target.setCommunity(**new** OctetString("public"));  
13. target.setRetries(2);  
14. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
15. target.setTimeout(8000);  
16. target.setVersion(SnmpConstants.version2c);  
17. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
18. @Override  
19. **public** PDU createPDU(Target arg0) \{  
20. PDU request = **new** PDU();  
21. request.setType(PDU.GET);  
22. **return** request;  
23. \}  
24. \});  
25. OID\[\] columns = **new** OID\[oids.length\];  
26. **for** (**int** i = 0; i < oids.length; i++)  
27. columns\[i\] = **new** OID(oids\[i\]);  
28. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
29. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
30. System.out.println(" null");  
31. \}**else**\{  
32. **int** percentage = 0;  
33. **for**(TableEvent event : list)\{  
34. VariableBinding\[\] values = event.getColumns();  
35. **if**(values != **null**)   
36. percentage += Integer.parseInt(values\[0\].getVariable().toString());  
37. \}  
38. System.out.println("CPU利用率为："\+percentage/list.size()+"%");  
39. \}  
40. \} **catch**(Exception e)\{  
41. e.printStackTrace();  
42. \}**finally**\{  
43. **try** \{  
44. **if**(transport!=**null**)  
45. transport.close();  
46. **if**(snmp!=**null**)  
47. snmp.close();  
48. \} **catch** (IOException e) \{  
49. e.printStackTrace();  
50. \}  
51. \}  
52. \}

## 2、获取内存信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //获取内存相关信息  
2.  **public** **static** **void** collectMemory() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] oids = \{ "1.3.6.1.2.1.25.2.3.1.2",  //type 存储单元类型  
7.       "1.3.6.1.2.1.25.2.3.1.3",  //descr  
8.       "1.3.6.1.2.1.25.2.3.1.4",  //unit 存储单元大小  
9.       "1.3.6.1.2.1.25.2.3.1.5",  //size 总存储单元数  
10.      "1.3.6.1.2.1.25.2.3.1.6"\}; //used 使用存储单元数;  
11. String PHYSICAL\_MEMORY\_OID = "1.3.6.1.2.1.25.2.1.2";//物理存储  
12. String VIRTUAL\_MEMORY\_OID = "1.3.6.1.2.1.25.2.1.3"; //虚拟存储  
13. **try** \{  
14. transport = **new** DefaultUdpTransportMapping();  
15. snmp = **new** Snmp(transport);//创建snmp  
16. snmp.listen();//监听消息  
17. target = **new** CommunityTarget();  
18. target.setCommunity(**new** OctetString("public"));  
19. target.setRetries(2);  
20. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
21. target.setTimeout(8000);  
22. target.setVersion(SnmpConstants.version2c);  
23. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
24. @Override  
25. **public** PDU createPDU(Target arg0) \{  
26. PDU request = **new** PDU();  
27. request.setType(PDU.GET);  
28. **return** request;  
29. \}  
30. \});  
31. OID\[\] columns = **new** OID\[oids.length\];  
32. **for** (**int** i = 0; i < oids.length; i++)  
33. columns\[i\] = **new** OID(oids\[i\]);  
34. @SuppressWarnings("unchecked")  
35. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
36. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
37. System.out.println(" null");  
38. \}**else**\{  
39. **for**(TableEvent event : list)\{  
40. VariableBinding\[\] values = event.getColumns();  
41. **if**(values == **null**) **continue**;  
42. **int** unit = Integer.parseInt(values\[2\].getVariable().toString());//unit 存储单元大小  
43. **int** totalSize = Integer.parseInt(values\[3\].getVariable().toString());//size 总存储单元数  
44. **int** usedSize = Integer.parseInt(values\[4\].getVariable().toString());//used  使用存储单元数  
45. String oid = values\[0\].getVariable().toString();  
46. **if** (PHYSICAL\_MEMORY\_OID.equals(oid))\{  
47. System.out.println("PHYSICAL\_MEMORY----->物理内存大小："\+(**long**)totalSize \* unit/(1024\*1024\*1024)+"G   内存使用率为："\+(**long**)usedSize\*100/totalSize+"%");  
48. \}**else** **if** (VIRTUAL\_MEMORY\_OID.equals(oid)) \{  
49. System.out.println("VIRTUAL\_MEMORY----->虚拟内存大小："\+(**long**)totalSize \* unit/(1024\*1024\*1024)+"G   内存使用率为："\+(**long**)usedSize\*100/totalSize+"%");  
50. \}  
51. \}  
52. \}  
53. \} **catch**(Exception e)\{  
54. e.printStackTrace();  
55. \}**finally**\{  
56. **try** \{  
57. **if**(transport!=**null**)  
58. transport.close();  
59. **if**(snmp!=**null**)  
60. snmp.close();  
61. \} **catch** (IOException e) \{  
62. e.printStackTrace();  
63. \}  
64. \}  
65. \}

## 3、获取磁盘信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //获取磁盘相关信息  
2.  **public** **static** **void** collectDisk() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String DISK\_OID = "1.3.6.1.2.1.25.2.1.4";  
7.  String\[\] oids = \{ "1.3.6.1.2.1.25.2.3.1.2",  //type 存储单元类型  
8.       "1.3.6.1.2.1.25.2.3.1.3",  //descr  
9.       "1.3.6.1.2.1.25.2.3.1.4",  //unit 存储单元大小  
10.      "1.3.6.1.2.1.25.2.3.1.5",  //size 总存储单元数  
11.      "1.3.6.1.2.1.25.2.3.1.6"\}; //used 使用存储单元数;  
12. **try** \{  
13. transport = **new** DefaultUdpTransportMapping();  
14. snmp = **new** Snmp(transport);//创建snmp  
15. snmp.listen();//监听消息  
16. target = **new** CommunityTarget();  
17. target.setCommunity(**new** OctetString("public"));  
18. target.setRetries(2);  
19. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
20. target.setTimeout(8000);  
21. target.setVersion(SnmpConstants.version2c);  
22. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
23. @Override  
24. **public** PDU createPDU(Target arg0) \{  
25. PDU request = **new** PDU();  
26. request.setType(PDU.GET);  
27. **return** request;  
28. \}  
29. \});  
30. OID\[\] columns = **new** OID\[oids.length\];  
31. **for** (**int** i = 0; i < oids.length; i++)  
32. columns\[i\] = **new** OID(oids\[i\]);  
33. @SuppressWarnings("unchecked")  
34. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
35. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
36. System.out.println(" null");  
37. \}**else**\{  
38. **for**(TableEvent event : list)\{  
39. VariableBinding\[\] values = event.getColumns();  
40. **if**(values == **null** ||!DISK\_OID.equals(values\[0\].getVariable().toString()))   
41. **continue**;  
42. **int** unit = Integer.parseInt(values\[2\].getVariable().toString());//unit 存储单元大小  
43. **int** totalSize = Integer.parseInt(values\[3\].getVariable().toString());//size 总存储单元数  
44. **int** usedSize = Integer.parseInt(values\[4\].getVariable().toString());//used  使用存储单元数  
45. System.out.println(getChinese(values\[1\].getVariable().toString())+"   磁盘大小："\+(**long**)totalSize\*unit/(1024\*1024\*1024)+"G   磁盘使用率为："\+(**long**)usedSize\*100/totalSize+"%");  
46. \}  
47. \}  
48. \} **catch**(Exception e)\{  
49. e.printStackTrace();  
50. \}**finally**\{  
51. **try** \{  
52. **if**(transport!=**null**)  
53. transport.close();  
54. **if**(snmp!=**null**)  
55. snmp.close();  
56. \} **catch** (IOException e) \{  
57. e.printStackTrace();  
58. \}  
59. \}  
60. \}

## 4、获取服务器进程信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //服务器进程集合信息  
2.  **public** **static** **void** collectProcess() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] oids =  
7.  \{ "1.3.6.1.2.1.25.4.2.1.1",  //index  
8.              "1.3.6.1.2.1.25.4.2.1.2",  //name  
9.              "1.3.6.1.2.1.25.4.2.1.4",  //run path  
10.      "1.3.6.1.2.1.25.4.2.1.6",  //type  
11.      "1.3.6.1.2.1.25.5.1.1.1",  //cpu  
12.      "1.3.6.1.2.1.25.5.1.1.2"\}; //memory    
13. **try** \{  
14. transport = **new** DefaultUdpTransportMapping();  
15. snmp = **new** Snmp(transport);  
16. snmp.listen();  
17. target = **new** CommunityTarget();  
18. target.setCommunity(**new** OctetString("public"));  
19. target.setRetries(2);  
20. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
21. target.setTimeout(8000);  
22. target.setVersion(SnmpConstants.version2c);  
23. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
24. @Override  
25. **public** PDU createPDU(Target arg0) \{  
26. PDU request = **new** PDU();  
27. request.setType(PDU.GET);  
28. **return** request;  
29. \}  
30. \});  
31. OID\[\] columns = **new** OID\[oids.length\];  
32. **for** (**int** i = 0; i < oids.length; i++)  
33. columns\[i\] = **new** OID(oids\[i\]);  
34. @SuppressWarnings("unchecked")  
35. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
36. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
37. System.out.println(" null");  
38. \}**else**\{  
39. **for**(TableEvent event : list)\{  
40. VariableBinding\[\] values = event.getColumns();  
41. **if**(values == **null**) **continue**;  
42. String name = values\[1\].getVariable().toString();//name  
43. String cpu = values\[4\].getVariable().toString();//cpu  
44. String memory = values\[5\].getVariable().toString();//memory  
45. String path = values\[2\].getVariable().toString();//path  
46. System.out.println("name--->"\+name+"  cpu--->"\+cpu+"  memory--->"\+memory+"  path--->"\+path);  
47. \}  
48. \}  
49. \} **catch**(Exception e)\{  
50. e.printStackTrace();  
51. \}**finally**\{  
52. **try** \{  
53. **if**(transport!=**null**)  
54. transport.close();  
55. **if**(snmp!=**null**)  
56. snmp.close();  
57. \} **catch** (IOException e) \{  
58. e.printStackTrace();  
59. \}  
60. \}  
61. \}

## 5、获取服务器系统服务方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //服务器系统服务集合  
2.  **public** **static** **void** collectService() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] oids =  
7.  \{ "1.3.6.1.4.1.77.1.2.3.1.1"\};  
8.  **try** \{  
9.  transport = **new** DefaultUdpTransportMapping();  
10. snmp = **new** Snmp(transport);  
11. snmp.listen();  
12. target = **new** CommunityTarget();  
13. target.setCommunity(**new** OctetString("public"));  
14. target.setRetries(2);  
15. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
16. target.setTimeout(8000);  
17. target.setVersion(SnmpConstants.version2c);  
18. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
19. @Override  
20. **public** PDU createPDU(Target arg0) \{  
21. PDU request = **new** PDU();  
22. request.setType(PDU.GET);  
23. **return** request;  
24. \}  
25. \});  
26. OID\[\] columns = **new** OID\[oids.length\];  
27. **for** (**int** i = 0; i < oids.length; i++)  
28. columns\[i\] = **new** OID(oids\[i\]);  
29. @SuppressWarnings("unchecked")  
30. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
31. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
32. System.out.println(" null");  
33. \}**else**\{  
34. **for**(TableEvent event : list)\{  
35. VariableBinding\[\] values = event.getColumns();  
36. **if**(values == **null**) **continue**;  
37. String name = values\[0\].getVariable().toString();//name  
38. System.out.println("名称--->"\+getChinese(name));//中文乱码，需要转为utf-8编码  
39. \}  
40. \}  
41. \} **catch**(Exception e)\{  
42. e.printStackTrace();  
43. \}**finally**\{  
44. **try** \{  
45. **if**(transport!=**null**)  
46. transport.close();  
47. **if**(snmp!=**null**)  
48. snmp.close();  
49. \} **catch** (IOException e) \{  
50. e.printStackTrace();  
51. \}  
52. \}  
53. \}

## 6、获取接口信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //服务器接口集合  
2.  **public** **static** **void** collectInterface() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] IF\_OIDS =   
7.      \{ "1.3.6.1.2.1.2.2.1.1",  //Index   
8.       "1.3.6.1.2.1.2.2.1.2",  //descr  
9.       "1.3.6.1.2.1.2.2.1.3",  //type  
10.      "1.3.6.1.2.1.2.2.1.5",  //speed  
11.      "1.3.6.1.2.1.2.2.1.6",  //mac  
12.      "1.3.6.1.2.1.2.2.1.7",  //adminStatus  
13.      "1.3.6.1.2.1.2.2.1.8",  //operStatus     
14.         
15.      "1.3.6.1.2.1.2.2.1.10", //inOctets  
16.      "1.3.6.1.2.1.2.2.1.16", //outOctets  
17.      "1.3.6.1.2.1.2.2.1.14", //inError  
18.      "1.3.6.1.2.1.2.2.1.20", //outError  
19.      "1.3.6.1.2.1.2.2.1.13", //inDiscard  
20.      "1.3.6.1.2.1.2.2.1.19", //outDiscard  
21.      "1.3.6.1.2.1.2.2.1.11", //inUcastPkts  
22.      "1.3.6.1.2.1.2.2.1.17", //outUcastPkts  
23.      "1.3.6.1.2.1.2.2.1.12", //inNUcastPkts       
24.      "1.3.6.1.2.1.2.2.1.18"\};//outNUcastPkts  
25. String\[\] IP\_OIDS =     
26.     \{ "1.3.6.1.2.1.4.20.1.1", //ipAdEntAddr  
27.      "1.3.6.1.2.1.4.20.1.2", //ipAdEntIfIndex  
28.      "1.3.6.1.2.1.4.20.1.3"\};//ipAdEntNetMask   
29. **try** \{  
30. transport = **new** DefaultUdpTransportMapping();  
31. snmp = **new** Snmp(transport);  
32. snmp.listen();  
33. target = **new** CommunityTarget();  
34. target.setCommunity(**new** OctetString("public"));  
35. target.setRetries(2);  
36. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
37. target.setTimeout(8000);  
38. target.setVersion(SnmpConstants.version2c);  
39. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
40. @Override  
41. **public** PDU createPDU(Target arg0) \{  
42. PDU request = **new** PDU();  
43. request.setType(PDU.GET);  
44. **return** request;  
45. \}  
46. \});  
47. OID\[\] columns = **new** OID\[IF\_OIDS.length\];  
48. **for** (**int** i = 0; i < IF\_OIDS.length; i++)  
49. columns\[i\] = **new** OID(IF\_OIDS\[i\]);  
50. @SuppressWarnings("unchecked")  
51. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
52. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
53. System.out.println(" null");  
54. \}**else**\{  
55. **for**(TableEvent event : list)\{  
56. VariableBinding\[\] values = event.getColumns();  
57. **if**(values == **null**) **continue**;  
58. System.out.println("interface ---Index："\+values\[0\].getVariable().toString()+"  descr："\+getChinese(values\[1\].getVariable().toString())+"  type："\+values\[2\].getVariable().toString()+" speed："\+values\[3\].getVariable().toString()+" mac："\+getChinese(values\[4\].getVariable().toString())+" adminStatus："\+values\[5\].getVariable().toString()+"  operStatus："\+values\[6\].getVariable().toString());  
59. \}  
60. \}  
61. //获取ip  
62. OID\[\] ipcolumns = **new** OID\[IP\_OIDS.length\];  
63. **for** (**int** i = 0; i < IP\_OIDS.length; i++)  
64. ipcolumns\[i\] = **new** OID(IP\_OIDS\[i\]);  
65. @SuppressWarnings("unchecked")  
66. List<TableEvent> iplist = tableUtils.getTable(target, ipcolumns, **null**, **null**);  
67. **if**(iplist.size()==1 && iplist.get(0).getColumns()==**null**)\{  
68. System.out.println(" null");  
69. \}**else**\{  
70. **for**(TableEvent event : iplist)\{  
71. VariableBinding\[\] values = event.getColumns();  
72. **if**(values == **null**) **continue**;  
73. System.out.println(" IP--->ipAdEntAddr:"\+values\[0\].getVariable().toString()+"   ipAdEntIfIndex:"\+values\[1\].getVariable().toString()+"   ipAdEntNetMask:"\+values\[2\].getVariable().toString());  
74. \}  
75. \}  
76. \} **catch**(Exception e)\{  
77. e.printStackTrace();  
78. \}**finally**\{  
79. **try** \{  
80. **if**(transport!=**null**)  
81. transport.close();  
82. **if**(snmp!=**null**)  
83. snmp.close();  
84. \} **catch** (IOException e) \{  
85. e.printStackTrace();  
86. \}  
87. \}  
88. \}

## 7、获取端口信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //服务器端口集合  
2.  **public** **static** **void** collectPort() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] TCP\_CONN = \{ "1.3.6.1.2.1.6.13.1.1", //status  
7.          "1.3.6.1.2.1.6.13.1.3"\}; //port  
8.     
9.  String\[\] UDP\_CONN = \{ "1.3.6.1.2.1.7.5.1.2"\};  
10. **try** \{  
11. transport = **new** DefaultUdpTransportMapping();  
12. snmp = **new** Snmp(transport);  
13. snmp.listen();  
14. target = **new** CommunityTarget();  
15. target.setCommunity(**new** OctetString("public"));  
16. target.setRetries(2);  
17. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
18. target.setTimeout(8000);  
19. target.setVersion(SnmpConstants.version2c);  
20. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
21. @Override  
22. **public** PDU createPDU(Target arg0) \{  
23. PDU request = **new** PDU();  
24. request.setType(PDU.GET);  
25. **return** request;  
26. \}  
27. \});  
28. //获取TCP 端口  
29. OID\[\] columns = **new** OID\[TCP\_CONN.length\];  
30. **for** (**int** i = 0; i < TCP\_CONN.length; i++)  
31. columns\[i\] = **new** OID(TCP\_CONN\[i\]);  
32. @SuppressWarnings("unchecked")  
33. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
34. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
35. System.out.println(" null");  
36. \}**else**\{  
37. **for**(TableEvent event : list)\{  
38. VariableBinding\[\] values = event.getColumns();  
39. **if**(values == **null**) **continue**;  
40. **int** status = Integer.parseInt(values\[0\].getVariable().toString());  
41. System.out.println("status--->"\+status+"   TCP\_port--->"\+values\[1\].getVariable().toString());  
42. \}  
43. \}  
44. //获取udp 端口  
45. OID\[\] udpcolumns = **new** OID\[UDP\_CONN.length\];  
46. **for** (**int** i = 0; i < UDP\_CONN.length; i++)  
47. udpcolumns\[i\] = **new** OID(UDP\_CONN\[i\]);  
48. @SuppressWarnings("unchecked")  
49. List<TableEvent> udplist = tableUtils.getTable(target, udpcolumns, **null**, **null**);  
50. **if**(udplist.size()==1 && udplist.get(0).getColumns()==**null**)\{  
51. System.out.println(" null");  
52. \}**else**\{  
53. **for**(TableEvent event : udplist)\{  
54. VariableBinding\[\] values = event.getColumns();  
55. **if**(values == **null**) **continue**;  
56. String name = values\[0\].getVariable().toString();//name  
57. System.out.println("UDP\_port--->"\+name);  
58. \}  
59. \}  
60. \} **catch**(Exception e)\{  
61. e.printStackTrace();  
62. \}**finally**\{  
63. **try** \{  
64. **if**(transport!=**null**)  
65. transport.close();  
66. **if**(snmp!=**null**)  
67. snmp.close();  
68. \} **catch** (IOException e) \{  
69. e.printStackTrace();  
70. \}  
71. \}  
72. \}

## 8、获取安装的软件信息方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  //服务器安装软件集合  
2.  **public** **static** **void** collectSoft() \{  
3.  TransportMapping transport = **null** ;  
4.  Snmp snmp = **null** ;  
5.  CommunityTarget target;  
6.  String\[\] oids =  
7.  \{   "1.3.6.1.2.1.25.6.3.1.2",  //software  
8.                      "1.3.6.1.2.1.25.6.3.1.4",  //type  
9.      "1.3.6.1.2.1.25.6.3.1.5"\}; //install date  
10. **try** \{  
11. transport = **new** DefaultUdpTransportMapping();  
12. snmp = **new** Snmp(transport);  
13. snmp.listen();  
14. target = **new** CommunityTarget();  
15. target.setCommunity(**new** OctetString("public"));  
16. target.setRetries(2);  
17. target.setAddress(GenericAddress.parse("udp:127.0.0.1/161"));  
18. target.setTimeout(8000);  
19. target.setVersion(SnmpConstants.version2c);  
20. TableUtils tableUtils = **new** TableUtils(snmp, **new** PDUFactory() \{  
21. @Override  
22. **public** PDU createPDU(Target arg0) \{  
23. PDU request = **new** PDU();  
24. request.setType(PDU.GET);  
25. **return** request;  
26. \}  
27. \});  
28. OID\[\] columns = **new** OID\[oids.length\];  
29. **for** (**int** i = 0; i < oids.length; i++)  
30. columns\[i\] = **new** OID(oids\[i\]);  
31. @SuppressWarnings("unchecked")  
32. List<TableEvent> list = tableUtils.getTable(target, columns, **null**, **null**);  
33. **if**(list.size()==1 && list.get(0).getColumns()==**null**)\{  
34. System.out.println(" null");  
35. \}**else**\{  
36. **for**(TableEvent event : list)\{  
37. VariableBinding\[\] values = event.getColumns();  
38. **if**(values == **null**) **continue**;  
39. String software = values\[0\].getVariable().toString();//software  
40. String type = values\[1\].getVariable().toString();//type  
41. String date = values\[2\].getVariable().toString();//date  
42. System.out.println("软件名称--->"\+getChinese(software)+"  type--->"\+type+"  安装时间--->"\+hexToDateTime(date.replace("'", "")));  
43. \}  
44. \}  
45. \} **catch**(Exception e)\{  
46. e.printStackTrace();  
47. \}**finally**\{  
48. **try** \{  
49. **if**(transport!=**null**)  
50. transport.close();  
51. **if**(snmp!=**null**)  
52. snmp.close();  
53. \} **catch** (IOException e) \{  
54. e.printStackTrace();  
55. \}  
56. \}  
57. \}

## 9、其他方法 ##

\[java\]  [view plain][]   [copy][view plain]

1.  /\*\* 
2.   \* 获取磁盘的中文名字 
3.   \* 解决snmp4j中文乱码问题 
4.   \*/  
5.  **public** **static** String getChinese(String octetString)\{  
6.  **if**(octetString == **null** || "".equals(octetString)   
7.         || "null".equalsIgnoreCase(octetString)) **return** "";  
8.  **try**\{  
9.  String\[\] temps = octetString.split(":");  
10. **if**(temps.length < COLON\_SIZE)  
11. **return** octetString;  
12. **byte**\[\] bs = **new** **byte**\[temps.length\];  
13. **for**(**int** i=0;i<temps.length;i++)  
14. bs\[i\] = (**byte**)Integer.parseInt(temps\[i\],16);  
15.     **return** **new** String(bs,"GB2312");  
16. \}**catch**(Exception e)\{  
17. **return** **null**;  
18. \}  
19. \}  
20. /\*\* 
21.  \* 将16进制的时间转换成标准的时间格式 
22.  \*/  
23. **private** **static** String hexToDateTime(String hexString) \{  
24. **if**(hexString == **null** || "".equals(hexString))  
25. **return** "";  
26. String dateTime = "";  
27. **try** \{  
28. **byte**\[\] values = OctetString.fromHexString(hexString).getValue();  
29. **int** year, month, day, hour, minute;  
30.    
31. year = values\[0\] \* 256 + 256 + values\[1\];  
32. month = values\[2\];  
33. day = values\[3\];  
34. hour = values\[4\];  
35. minute = values\[5\];  
36.    
37. **char** format\_str\[\] = **new** **char**\[22\];  
38. **int** index = 3;  
39. **int** temp = year;  
40. **for** (; index >= 0; index--) \{  
41. format\_str\[index\] = (**char**) (48 + (temp - temp / 10 \* 10));  
42. temp /= 10;  
43. \}  
44. format\_str\[4\] = '-';  
45. index = 6;  
46. temp = month;  
47. **for** (; index >= 5; index--) \{  
48. format\_str\[index\] = (**char**) (48 + (temp - temp / 10 \* 10));  
49. temp /= 10;  
50. \}  
51. format\_str\[7\] = '-';  
52. index = 9;  
53. temp = day;  
54. **for** (; index >= 8; index--) \{  
55. format\_str\[index\] = (**char**) (48 + (temp - temp / 10 \* 10));  
56. temp /= 10;  
57. \}  
58. format\_str\[10\] = ' ';  
59. index = 12;  
60. temp = hour;  
61. **for** (; index >= 11; index--) \{  
62. format\_str\[index\] = (**char**) (48 + (temp - temp / 10 \* 10));  
63. temp /= 10;  
64. \}  
65. format\_str\[13\] = ':';  
66. index = 15;  
67. temp = minute;  
68. **for** (; index >= 14; index--) \{  
69. format\_str\[index\] = (**char**) (48 + (temp - temp / 10 \* 10));  
70. temp /= 10;  
71. \}  
72. dateTime = **new** String(format\_str,0,format\_str.length).substring(0, 16);  
73. \} **catch** (Exception e) \{  
74. //LogFactory.getLog(getClass()).error(e);  
75. \}  
76. **return** dateTime;  
77. \}

转载自[/images/20220522/c7ae92f9989646c68738be2f007bc8f0.png][18406763]

[Win7_SNMP]: http://blog.chinaunix.net/uid-21857285-id-3340206.html
[18406763]: /images/20220522/c7ae92f9989646c68738be2f007bc8f0.png
[SouthEast]: /images/20220522/3a50ccc4b46845f39c1b23fdc9eaaa2d.png
[SouthEast 1]: /images/20220522/2891342dd95742e584d74044b0b6848a.png
[SouthEast 2]: /images/20220522/a56caaba7a3f4669bc81626b19253514.png
[SouthEast 3]: /images/20220522/d42ed3475d4f4ca5a6fe522e12423a64.png
[http_www.snmp4j.org]: http://www.snmp4j.org/
[view plain]: /images/20220522/c7ae92f9989646c68738be2f007bc8f0.png#