1. 程式人生 > >使用snmp4j實現Snmp功能(二)

使用snmp4j實現Snmp功能(二)

前一篇文章講了如何用snmp4j實現set和get的功能,今天講如何接收trap。

snmp4j提供了一個抽象類CommandResponder類用於接收trap,這個類裡面有一個必須實現的方法processPdu(),當接收到trap,會自動進入這個方法,因此我們可以將對trap的處理寫在這裡。

下面修改上篇文章例子中的initComm()方法:

private TransportMapping transport = null;

publicvoid initComm() throws IOException {

// Agent方的IP和埠

targetAddress = GenericAddress.parse

("udp:192.168.1.1/161");

// 置接收trapIP和埠

transport = new DefaultUdpTransportMapping(new UdpAddress(

"192.168.1.2/162"));

snmp = new Snmp(transport);

CommandResponder trapRec = new CommandResponder() {

publicsynchronizedvoid processPdu(CommandResponderEvent e) {

// 接收trap

PDU command = e.getPDU();

if (command !=

null) {

System.out.println(command.toString());

}

}

};

snmp.addCommandResponder(trapRec);

transport.listen();

}

其中targetAddress指Agent端也就是trap傳送,transport指trap接收方,這裡就是本機,假設IP是192.168.1.2,但注意不能寫成127.0.0.1。

因為我們無法得知trap什麼時候會發送,所以需要有一個執行緒等待trap的到來,在這個例子中我們使用wait()來等待trap的到來,具體應用中就要根據實際情況來做了。

publicsynchronized

void listen() {

System.out.println("Waiting for traps..");

try {

this.wait();//Wait for traps to come in

} catch (InterruptedException ex) {

System.out.println("Interrupted while waiting for traps: " + ex);

System.exit(-1);

}

}

publicstaticvoid main(String[] args) {

try {

SnmpUtil util = new SnmpUtil();

util.initComm();

util.listen();

} catch (IOException e) {

e.printStackTrace();

}

}

將上面的程式碼新增到原來的例子中,就可以接收trap了。

但是還有一個問題,如何讓192.168.1.1傳送trap呢?這個也可以使用snmp4j來做。其實發送trap和傳送set、get PDU是類似的,同樣是傳送PDU,只不過型別不一樣。我們把前面的例子複製到192.168.1.1,在裡面新增一段程式碼:

publicvoid setTrap() throws IOException {

// 構造Trap PDU

PDU pdu = new PDU();

pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.1"),

new OctetString("SnmpTrap")));

pdu.setType(PDU.TRAP);

sendPDU(pdu);

System.out.println("Trap sent successfully.");

}

這裡PDU的OID和Value可以自己構造,無需使用特定的值。

然後修改地址
targetAddress = GenericAddress.parse("udp:192.168.1.2/162");
transport = new DefaultUdpTransportMapping(new UdpAddress("192.168.1.1/161"));

另外需要修改target的version,即改為target.setVersion(SnmpConstants.version2c)為什麼要這樣改我也沒搞清楚,總之verion1收不到。

接下來修改main()函式,呼叫setTrap()。

然後回到本機執行剛才的例子,當控制檯顯示“Waiting for traps..”時,執行Agent端的例子。此時如果192.168.1.2打出我們剛剛設定的PDU的資訊,就說明Trap的收發成功了。