SNMP 使用SNMP4J V2進行TRAP

阿新 • • 發佈：2019-01-21

SNMP trap(SNMP 陷阱)：某種入口，到達該入口會使SNMP被管裝置主動通知SNMP管理器,而不是等待SNMP管理器的再次輪詢！

在網管系統中，被管理裝置中的代理可以在任何時候向網路管理工作站報告錯誤情況，例如預製定閾值越界程度等等。代理並不需要等到管理工作站為獲得這些錯誤情況而輪詢他的時候才會報告。這些錯誤情況就是眾所周知的SNMP自陷（trap）！

網管系統開放監聽埠，始終監聽被管裝置對於該埠的通訊資訊。被管裝置發生故障會主動向該埠傳送故障資訊，網管系統收到訊息進行告警！

首先要模擬工作站對埠進行監聽，請看如下程式：

Java程式碼

package t3;
import java.io.IOException;
import java.net.UnknownHostException;
import java.util.Vector;
import org.snmp4j.CommandResponder;
import org.snmp4j.CommandResponderEvent;
import org.snmp4j.MessageDispatcherImpl;
import org.snmp4j.Snmp;
import org.snmp4j.TransportMapping;
import

org.snmp4j.mp.MPv1;
import org.snmp4j.mp.MPv2c;
import org.snmp4j.mp.MPv3;
import org.snmp4j.security.SecurityModels;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.security.USM;
import org.snmp4j.smi.Address;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.TcpAddress;
import org.snmp4j.smi.UdpAddress;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultTcpTransportMapping;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;
/**
* 本類用於監聽代理程序的Trap資訊
*/
public class MultiThreadedTrapReceiver implements CommandResponder {
public static void main(String[] args) {
MultiThreadedTrapReceiver multithreadedtrapreceiver = new MultiThreadedTrapReceiver();
multithreadedtrapreceiver.run();
}
private MultiThreadedMessageDispatcher dispatcher;
private Snmp snmp = null;
private Address listenAddress;
private ThreadPool threadPool;
public MultiThreadedTrapReceiver() {
}
public void run() {
try {
init();
snmp.addCommandResponder(this);
System.out.println("--------------->開始監聽Trap資訊!<---------------");
} catch (Exception ex) {
ex.printStackTrace();
}
}
private void init() throws UnknownHostException, IOException {
threadPool = ThreadPool.create("Trap", 2);
dispatcher = new MultiThreadedMessageDispatcher(threadPool,new MessageDispatcherImpl());
listenAddress = GenericAddress.parse(System.getProperty("snmp4j.listenAddress", "udp:127.0.0.1/2008")); // 本地IP與監聽埠
TransportMapping transport;
// 對TCP與UDP協議進行處理
if (listenAddress instanceof UdpAddress) {
transport = new DefaultUdpTransportMapping((UdpAddress) listenAddress);
} else {
transport = new DefaultTcpTransportMapping((TcpAddress) listenAddress);
}
snmp = new Snmp(dispatcher, transport);
snmp.getMessageDispatcher().addMessageProcessingModel(new MPv1());
snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
snmp.getMessageDispatcher().addMessageProcessingModel(new MPv3());
USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(MPv3.createLocalEngineID()), 0);
SecurityModels.getInstance().addSecurityModel(usm);
snmp.listen();
}
/**
* 實現CommandResponder的processPdu方法, 用於處理傳入的請求、PDU等資訊
* 當接收到trap時，會自動進入這個方法
*/
@SuppressWarnings("unchecked")
public void processPdu(CommandResponderEvent respEvnt) {
// 解析Response
if (respEvnt != null && respEvnt.getPDU() != null) {
Vector<VariableBinding> recVBs = respEvnt.getPDU().getVariableBindings();
for (int i = 0; i < recVBs.size(); i++) {
VariableBinding recVB = recVBs.elementAt(i);
System.out.println(recVB.getOid() + " : " + recVB.getVariable());
}
}
}
}

我們採用的是實現 CommandResponder 介面，該介面有一個方法

Java程式碼

public void processPdu(CommandResponderEvent respEvnt)

在該埠接收到資訊時會主動呼叫該方法！

執行Main方法，控制檯提示

Java程式碼

-------------->開始監聽Trap資訊!<---------------

程式對本機埠 2008 開始監聽！

使用命令

Java程式碼

>netstate -an

發現本機UDP埠已經開始監聽！

我們再來實現Agent，被管裝置向網管系統TRAP資訊：

Java程式碼

package t3;
import java.io.IOException;
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.Address;
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;
/**
* 本類用於向管理程序傳送Trap資訊
*/
public class SnmpUtilSendTrap {
private Snmp snmp = null;
private Address targetAddress = null;
public static void main(String[] args) {
try {
SnmpUtilSendTrap util = new SnmpUtilSendTrap();
util.initComm();
util.sendPDU();
} catch (IOException e) {
e.printStackTrace();
}
}
public void initComm() throws IOException {
// 設定管理程序的IP和埠
targetAddress = GenericAddress.parse("udp:127.0.0.1/2008");
TransportMapping transport = new DefaultUdpTransportMapping();
snmp = new Snmp(transport);
transport.listen();
}
/**
* 向管理程序傳送Trap報文
*
* @throws IOException
*/
@SuppressWarnings("unchecked")
public void sendPDU() throws IOException {
// 設定 target
CommunityTarget target = new CommunityTarget();
target.setAddress(targetAddress);
// 通訊不成功時的重試次數
target.setRetries(2);
// 超時時間
target.setTimeout(1000 * 5);
// snmp版本
target.setVersion(SnmpConstants.version2c);
// 建立 PDU
PDU pdu = new PDU();
pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1.6.0"),new OctetString("aaaa")));
pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1.2.0"),new OctetString("bbbb")));
pdu.setType(PDU.TRAP);
// 向Agent傳送PDU，並接收Response
snmp.send(pdu, target);
System.out.println("------------> END<--------------");
}
}

使用的SNMP版本應該是 V2，V1的操作與V2 TRAP不同！

執行後控制檯列印執行結束！

網管系統模擬端列印收到的OID和OID對應的值資訊！

1
頂

1
踩

分享到：

2012-05-24 09:41
瀏覽 3344
評論(7)
分類:程式語言
相關推薦

評論

KuhYygy 寫道

請問下樓主，如果trap裡的包含中文的資訊，應該如何解碼，準確來講，應該如何選擇字元編碼？

String s = new String(((OctetString)recVB.getVariable()).getValue(), "UTF-8");

如上，我看有些寫UTF-8，有些寫GBK，請問這個應該怎麼選擇，或者有其它的方法解釋出trap裡的中文？謝謝~

如果是我們倆之間做通訊，咱倆之間肯定知道字串是什麼編碼格式的，為什麼會出現不知道編碼的情況？

6 樓 KuhYygy 2014-06-03

5 樓 lanqiu17 2014-02-21

cuisuqiang 寫道

lanqiu17 寫道

@SuppressWarnings("unchecked")
    public void processPdu(CommandResponderEvent respEvnt) {
        // 解析Response
        if (respEvnt != null && respEvnt.getPDU() != null) {
            Vector<VariableBinding> recVBs = respEvnt.getPDU().getVariableBindings();
            for (int i = 0; i < recVBs.size(); i++) {
                VariableBinding recVB = recVBs.elementAt(i);
                System.out.println(recVB.getOid() + " : " + recVB.getVariable());
            }
        }
    }

樓主，我覺得這裡應該交給執行緒去處理。它佔用的是接收trap執行緒池中的執行緒，會阻塞trap訊息的接收

SNMP4J用的是堵塞執行緒池處理，既然已經有執行緒池處理了，為什麼再做一層執行緒處理？除非是擔心收到的訊息很長時間處理不掉，那增大SNMP執行緒池就可以了

但當管理裝置過多，並且傳送trap訊息頻繁時，增大snmp執行緒池只是將問題延後了

lanqiu17 寫道

SNMP4J用的是堵塞執行緒池處理，既然已經有執行緒池處理了，為什麼再做一層執行緒處理？除非是擔心收到的訊息很長時間處理不掉，那增大SNMP執行緒池就可以了

3 樓 lanqiu17 2014-02-20

2 樓 lanqiu17 2014-02-20

哥們，你也是做網管軟體的啊，能交流下嗎

如果Trap時需要給客戶端返回一些資訊，可以參考如下程式碼：

Java程式碼

/**
* 實現CommandResponder的processPdu方法, 用於處理傳入的請求、PDU等資訊
* 當接收到trap時，會自動進入這個方法
*/
@SuppressWarnings("unchecked")
public void processPdu(CommandResponderEvent respEvnt) {
List<VariableBinding> list = new ArrayList<VariableBinding>();
// 解析Response
if (respEvnt != null && respEvnt.getPDU() != null) {
Vector<VariableBinding> recVBs = respEvnt.getPDU().getVariableBindings();
for (int i = 0; i < recVBs.size(); i++) {
VariableBinding recVB = recVBs.elementAt(i);
System.out.println(recVB.getOid() + " : " + recVB.getVariable());
Random random = new Random();
list.add(new VariableBinding(recVB.getOid(),new Integer32(random.nextInt(1999))));
}
org.snmp4j.mp.StatusInformation statusInformation = new org.snmp4j.mp.StatusInformation();
org.snmp4j.mp.StateReference ref = respEvnt.getStateReference();
try {
// 建立 PDU
PDU vPDU = respEvnt.getPDU();
vPDU.setType(PDU.RESPONSE);
Random random = new Random();
for(int i = 0;i< list.size() ;i++){
VariableBinding vb = list.get(i);
vb.setVariable(new Integer32(random.nextInt(9999)));
vPDU.set(i,vb);
}
respEvnt.getMessageDispatcher().returnResponsePdu(
respEvnt.getMessageProcessingModel(),
respEvnt.getSecurityModel(),
respEvnt.getSecurityName(),
respEvnt.getSecurityLevel(),
vPDU,
respEvnt.getMaxSizeResponsePDU(),
ref,
statusInformation);
} catch (Exception e) {
e.printStackTrace();
}
}
}

SNMP 使用SNMP4J V2進行TRAP

SNMP 使用SNMP4J V2進行TRAP

使用Java進行SNMP程式設計-SNMP4J-SNMPv1/v2-程式碼例項

SNMP4J實現SNMP TRAP

硬件層監控之Zabbix-snmp-trap企業級實戰

SNMP V2簡單設置

使用apksigner對apk進行v2簽名

SNMP：使用net-snmp捕捉trap

java-snmp4j之snmp

【Zabbix-SNMPtrap】列舉一個常見使用Zabbix的SNMP trap監控裝置的例子

如何給SNMP Trap通道加上同步機制

net-snmp擴充套件trap型別的私有mib

SNMP　trap訊息為何不能正確發往指定埠162．

snmp4j程式設計之三 trap監聽

【NetSNMP##】 C語言傳送SNMP Trap訊息

linux下snmp4j獲取net-snmp的基本資訊

SNMP Trap的功能介紹

java利用snmp4j包來讀取snmp協議資料（Manager端）

Snmp學習總結(二)——SNMP4J介紹

snmp trap入門

使用snmp4j實現Snmp功能（一）

SNMP 使用SNMP4J V2進行TRAP

相關推薦