`
279135628
  • 浏览: 13110 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
文章分类
社区版块
存档分类
最新评论

有用snmpv3开发过网管系统

SecurityJavaEE 
阅读更多
以下是我用JAVA实现的利用snmpv3写的一段测试代码：
1：JAVA实现的SNMP代理部分 
package com.medou.agent;
import org.snmp4j.*;
import org.snmp4j.mp.*;
import org.snmp4j.security.AuthMD5;
import org.snmp4j.security.AuthSHA;
import org.snmp4j.security.PrivAES128;
import org.snmp4j.security.PrivAES192;
import org.snmp4j.security.PrivAES256;
import org.snmp4j.security.PrivDES;
import org.snmp4j.security.SecurityModels;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.security.USM;
import org.snmp4j.security.UsmUser;
import org.snmp4j.smi.*;
import org.snmp4j.transport.DefaultTcpTransportMapping;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;

public class SnmpProcessor implements CommandResponder {
	private MultiThreadedMessageDispatcher dispatcher;
	private Address listenAddress;
	private ThreadPool threadPool;
	private OID authProtocol;
	private OID privProtocol;
	private OctetString privPassphrase;
	private OctetString authPassphrase;
	private OctetString securityName = new OctetString();
	private int numDispatcherThreads = 2;
	private int version;
	private String host;
    
	public SnmpProcessor(String host, String user, 
			  String authProtocol, String authPasshrase, String privProtocol, 
	          String privPassphrase, int version) {
		  this.authPassphrase = new OctetString(authPasshrase);
		  this.securityName = new OctetString(user);
		  this.privPassphrase = new OctetString(privPassphrase);
		  this.version = version;
		  this.host = host;
		  if (authProtocol.equals("MD5")) {
			  this.authProtocol = AuthMD5.ID;
	      } else if (authProtocol.equals("SHA")) {
	    	  this.authProtocol = AuthSHA.ID;
	      }
	      if (privProtocol.equals("DES")) {
	    	  this.privProtocol = PrivDES.ID;
	      } else if ((privProtocol.equals("AES128"))
	              || (privProtocol.equals("AES"))) {
	    	  this.privProtocol = PrivAES128.ID;
	      } else if (privProtocol.equals("AES192")) {
	    	  this.privProtocol = PrivAES192.ID;
	      } else if (privProtocol.equals("AES256")) {
	    	  this.privProtocol = PrivAES256.ID;
	      }
	}
	
	public synchronized void run() {
		try {
            init();
        } catch (Exception ex) {
        	ex.printStackTrace();
        } 
	}

	public synchronized void init() throws Exception {
        try {
        	threadPool = ThreadPool.create("Trap", numDispatcherThreads);
            dispatcher = new MultiThreadedMessageDispatcher(threadPool, new MessageDispatcherImpl());
            listenAddress = GenericAddress.parse(host);
            TransportMapping transport;
            if (listenAddress instanceof UdpAddress) {
              transport = new DefaultUdpTransportMapping((UdpAddress)listenAddress);
            } else {
              transport = new DefaultTcpTransportMapping((TcpAddress)listenAddress);
            }
            dispatcher.addMessageProcessingModel(new MPv1());
            dispatcher.addMessageProcessingModel(new MPv2c());
            dispatcher.addMessageProcessingModel(new MPv3());
            SecurityProtocols.getInstance().addDefaultProtocols();
            Snmp snmp = new Snmp(dispatcher, transport);
            if (version == SnmpConstants.version3) {
        	    USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(MPv3.createLocalEngineID()), 0);
        	    SecurityModels.getInstance().addSecurityModel(usm);
        	    // Add the configured user to the USM
        	    addUsmUser(snmp);
            }
            snmp.addCommandResponder(this);
            transport.listen();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
	
	private void addUsmUser(Snmp snmp) {
	    snmp.getUSM().addUser(securityName, new UsmUser(securityName,
	                                                    authProtocol,
	                                                    authPassphrase,
	                                                    privProtocol,
	                                                    privPassphrase));
    }
	
	public String getResponse (String cmdType, String oid, String value) {
		return "lkj";
	}
	
@SuppressWarnings("unchecked")
public synchronized void processPdu(CommandResponderEvent aEvent) {
      PDU pdu = aEvent.getPDU();
      if (pdu == null) {
          return;
      } 
      String cmdType = "";
      OID oid = pdu.get(0).getOid();
      String oidStr = oid.toString();
      System.out.println(oidStr);
      String value = null==pdu.get(0).getVariable().toString()?"":pdu.get(0).getVariable().toString();
      System.out.println(value);
      switch (pdu.getType()) {
          case PDU.GET:
              cmdType = "0";
              break;
          case PDU.GETNEXT:
              cmdType = "1";
              break;
          case PDU.SET:
              cmdType = "3";
              break;
          default:
              break;
      }
      StatusInformation statusInformation = new StatusInformation();
      StateReference stateRef = aEvent.getStateReference();
      try {
          pdu.setType(PDU.RESPONSE);
          String response = getResponse(cmdType, oidStr, value);
          Variable rariable = null;
          rariable = new OctetString(response);
          pdu.set(0, new VariableBinding(oid, rariable));
          aEvent.getMessageDispatcher().returnResponsePdu(
              aEvent.getMessageProcessingModel(),
              aEvent.getSecurityModel(), aEvent.getSecurityName(),
              aEvent.getSecurityLevel(), pdu,
              aEvent.getMaxSizeResponsePDU(), stateRef,
              statusInformation);
      } catch (MessageException ex) {
    	  ex.printStackTrace();
      }
  }
	
	public static void main(String[] args) {
		SnmpProcessor a = new SnmpProcessor("udp:192.168.0.118/161", "lkj", "MD5", "mysnmplkj", "DES", "mysnmplkj", SnmpConstants.version3);
		a.run();
	}

}


2：以下是我写的网管与代理交互部分： 
package com.medou.agent;

import java.io.IOException;
import java.util.Vector;
import org.snmp4j.CommunityTarget;
import org.snmp4j.PDU;
import org.snmp4j.ScopedPDU;
import org.snmp4j.Snmp;
import org.snmp4j.Target;
import org.snmp4j.TransportMapping;
import org.snmp4j.UserTarget;
import org.snmp4j.event.ResponseEvent;
import org.snmp4j.mp.MPv3;
import org.snmp4j.mp.SnmpConstants;
import org.snmp4j.security.AuthMD5;
import org.snmp4j.security.AuthSHA;
import org.snmp4j.security.PrivAES128;
import org.snmp4j.security.PrivAES192;
import org.snmp4j.security.PrivAES256;
import org.snmp4j.security.PrivDES;
import org.snmp4j.security.SecurityLevel;
import org.snmp4j.security.SecurityModels;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.security.USM;
import org.snmp4j.security.UsmUser;
import org.snmp4j.smi.Address;
import org.snmp4j.smi.GenericAddress;
import org.snmp4j.smi.OID;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.TcpAddress;
import org.snmp4j.smi.VariableBinding;
import org.snmp4j.transport.DefaultTcpTransportMapping;
import org.snmp4j.transport.DefaultUdpTransportMapping;

/**
 * 本类用于向管理进程发送GET信息
 *
 * @author 
 *
 */
public class SnmpUtilSendGet {
    private Address targetAddress = null;
    private OID authProtocol;
    private OID privProtocol;
    private OctetString privPassphrase;
    private OctetString authPassphrase;
    private OctetString securityName = new OctetString();
    private int version;
    private String host;
    private Target target;
    private OctetString community = new OctetString("public");
    private TransportMapping transport;
    
    /**
     * 初始化Snmp信息
     * @param host
     * @param user
     * @param authProtocol
     * @param authPasshrase
     * @param privProtocol
     * @param privPassphrase
     * @param version
     */
    public SnmpUtilSendGet(String host, String user, 
  		  String authProtocol, String authPasshrase, String privProtocol, 
            String privPassphrase, int version) {
          this.authPassphrase = new OctetString(authPasshrase);
    	  this.securityName = new OctetString(user);
    	  this.privPassphrase = new OctetString(privPassphrase);
    	  this.version = version;
    	  this.host = host;
    	  if (authProtocol.equals("MD5")) {
    		  this.authProtocol = AuthMD5.ID;
          } else if (authProtocol.equals("SHA")) {
        	  this.authProtocol = AuthSHA.ID;
          }
          if (privProtocol.equals("DES")) {
        	  this.privProtocol = PrivDES.ID;
          } else if ((privProtocol.equals("AES128"))
                  || (privProtocol.equals("AES"))) {
        	  this.privProtocol = PrivAES128.ID;
          } else if (privProtocol.equals("AES192")) {
        	  this.privProtocol = PrivAES192.ID;
          } else if (privProtocol.equals("AES256")) {
        	  this.privProtocol = PrivAES256.ID;
          }
      }
    
    /**
     * 创建snmp
     * @throws IOException
     */
    public Snmp createSnmpSession() throws IOException {
        // 设置管理进程的IP和端口
        targetAddress = GenericAddress.parse(host);
        if (targetAddress instanceof TcpAddress) {
            transport = new DefaultTcpTransportMapping();
        } else {
            transport = new DefaultUdpTransportMapping();
        }
        Snmp snmp = new Snmp(transport);
        if (version == SnmpConstants.version3) {
    	    USM usm = new USM(SecurityProtocols.getInstance(), new OctetString(MPv3.createLocalEngineID()), 0);
    	    SecurityModels.getInstance().addSecurityModel(usm);
    	    // Add the configured user to the USM
    	    addUsmUser(snmp);
        }
        return snmp;
    }
    
    /**
     * 加入user信息（snmp3）
     * @param snmp
     */
    private void addUsmUser(Snmp snmp) {
	    snmp.getUSM().addUser(securityName, new UsmUser(securityName,
	                                                    authProtocol,
	                                                    authPassphrase,
	                                                    privProtocol,
	                                                    privPassphrase));
    }
    
    /**
     * 创建PUD
     * @param target
     * @return
     */
    public PDU createPDU(Target target) {
        PDU request;
        if (target.getVersion() == SnmpConstants.version3) {
            request = new ScopedPDU();
        } else {
            request = new PDU();
        }
        return request;
    }
    
    /**
     * 创建Target
     * @return
     */
    private Target createTarget() {
        if (version == SnmpConstants.version3) {
          UserTarget target = new UserTarget();
          if (authPassphrase != null) {
            if (privPassphrase != null) {
              target.setSecurityLevel(SecurityLevel.AUTH_PRIV);
            } else {
              target.setSecurityLevel(SecurityLevel.AUTH_NOPRIV);
            }
          } else {
            target.setSecurityLevel(SecurityLevel.NOAUTH_NOPRIV);
          }
          target.setSecurityName(securityName);
          return target;
       } else {
          CommunityTarget target = new CommunityTarget();
          target.setCommunity(community);
          return target;
       }
    }
    
    /**
     * 向管理进程发送Trap报文
     *
     * @throws IOException
     */
    @SuppressWarnings("unchecked")
    public void sendPDU() throws IOException {
        // 设置 target
    	Snmp snmp = createSnmpSession();
    	target = createTarget();
        target.setAddress(targetAddress);
        // 通信不成功时的重试次数
        target.setRetries(2);
        // 超时时间
        target.setTimeout(1500);
        // snmp版本
        target.setVersion(version);
        
        transport.listen();
        // 创建 PDU
        PDU pdu = createPDU(target);
//        pdu.add(new VariableBinding(new OID(".1.3.6.1.2.3377.10.1.1.1.2"),
//                new OctetString("JavaEE")));
        pdu.add(new VariableBinding(new OID(".1.3.4")));
        pdu.setType(PDU.GET);
        System.out.println(pdu);
        ResponseEvent respEvnt = snmp.send(pdu, target);
        System.out.println(respEvnt.getResponse());
        // 解析Response
        if (respEvnt != null && respEvnt.getResponse() != null) {
            Vector<VariableBinding> recVBs = respEvnt.getResponse()
            .getVariableBindings();
            for (int i = 0; i < recVBs.size(); i++) {
                VariableBinding recVB = recVBs.elementAt(i);
                System.out.println(recVB.getOid() + " : " + recVB.getVariable());
            }
        }
        snmp.close();
    }

    public static void main(String[] args) {
        try {
            SnmpUtilSendGet util = new SnmpUtilSendGet("udp:192.168.0.118/161", "lkj", "MD5", "mysnmplkj", "DES", "mysnmplkj", SnmpConstants.version3);
            util.createSnmpSession();
            util.sendPDU();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}



为什么我运行了代理后，执行交互部分的代码，代理不会跳入processPdu方法运行？ 我试过用SNMP2V的版本是可以的，有谁知道的请解答下   谢谢
分享到：
| 谁知道关于基于snmp的java编程的书籍，关于 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    snmp.rar_SNMP_agent++ sample_agent_pp.l_snmpv3_boot_counter_snmp

    "snmpv3"指的是SNMP的第三版本，相比之前的版本，SNMPv3增加了安全特性，如认证、加密和访问控制，提高了网络管理的安全性。SNMPv3是目前最常用的版本，因为它的安全性远超SNMPv1和v2c。 "boot_counter"可能是指...

    c++构建snmp网络管理协议

    C++构建SNMP网络管理协议API 本文档描述了使用C++语言构建的简单网络管理协议（SNMP）API的实现，名为SNMP++。SNMP++是一套专注于网络管理的开放技术，结合了SNMP协议原理和C++语言。该API提供了一系列可移植的C++...

    SNMP协议测试软件ManageEngine MibBrowser

    这个工具同样对网络管理和故障排查非常有用，因为它可以模拟不同的SNMP查询并评估设备的响应时间。 在测试和开发过程中，MibBrowser和SNMP Tester这样的工具可以帮助识别网络设备的问题，比如性能瓶颈、配置错误或...

    2013年1月自考计算机网络管理(02379)试题及填空选择题答案.pdf

    网络管理的安全性也是一个重要的考试内容，文件中提到了密钥管理，包括keyOld和keyNew，表明了在SNMP版本3中增强了安全特性，包括了用户认证和数据加密。MD5和SHA1是常见的哈希算法，用于确保数据的完整性和认证。在...

    snmp_SNMP_snmpbuilder_

    5. 安全性：对于SNMPv3的支持，Snmp++库包含了认证和加密的机制，可以设置不同的安全级别来保护网络管理通信的安全。 6. 异步操作：除了同步的SNMP操作，Snmp++还支持异步操作，这在处理大量并发请求时非常有用，...

    snmp4j 开发包

    SNMP4J 开发包是Java开发者用于构建SNMP（简单网络管理协议）应用程序的重要工具。这个包包含两个主要的组件：SNMP4J.jar和jpcap.jar，它们分别提供了对SNMP协议的支持和网络数据包捕获的能力。 SNMP（Simple ...

    SNMP开发说明

    SNMP（Simple Network Management Protocol，简单网络管理协议）是一种广泛应用于网络设备管理的协议，它允许网络管理员远程监控和管理网络设备，如路由器、交换机、服务器等。本压缩包包含了一系列资源，对于想要...

    snmpPPv3.2.25.zip_PPV225_SNMP

    SNMP（简单网络管理协议）是一种广泛用于网络设备管理的标准协议，它允许管理员远程监控和配置网络设备。本文将深入探讨SNMPv3，这是SNMP的第三个版本，相较于之前的版本，它提供了更高级别的安全性和隐私保护。在这...

    计算机网络课件第八章

    SNMP（简单网络管理协议）是标准的网络管理协议，管理信息库MIB存储了网络设备的状态信息，而SNMPv2和SNMPv3提供了更高级的安全性和功能。 8.8 在应用层，进程间通信通常通过系统调用接口实现，服务器有两种工作...

    net-snmp源码

    net-snmp库支持SNMPv1、SNMPv2c和SNMPv3，涵盖了从基本到安全的网络管理需求。 net-snmp源码的移植性体现在它可以在多种操作系统上运行，包括但不限于Linux、Windows、FreeBSD、Solaris等。移植的关键在于其跨平台...

    基于java的SNMP的MIB浏览器 JMIBBrowser.zip

    这种工具对网络管理员来说非常有用，因为它提供了对网络设备状态的直观视图，并且可以方便地进行远程管理。 **JMIBBrowser**是本文讨论的重点，这是一款用Java语言开发的SNMP MIB浏览器。Java作为一种跨平台的语言...

    SNMP proxy forwarder:高度可配置的SNMPv1 / v2c / v3应用程序级代理-开源

    SNMP（简单网络管理协议）是一种广泛用于网络设备管理的标准协议，它允许管理员远程监控和配置网络设备。在SNMP代理转发器（SNMP proxy forwarder）中，我们讨论的是一种高度可配置的工具，它能够作为一个应用程序级...

    SnmpSharpNet:用C＃（csharp）编写的简单网络管理协议（SNMP）.Net库。 实现协议版本1、2和3。http

    SnmpSharpNet是一个开源的C#库，专为.NET开发者设计，用于实现简单网络管理协议（SNMP）。...无论是在企业级的网络监控系统还是个人项目中，它都能作为一个可靠的SNMP客户端库，简化网络管理的工作。

    snmpppv3.2.9a.rar_SNMP_linux snmpnext

    SNMPv3相比前两版（v1和v2c）增加了安全特性，如用户身份验证、加密和访问控制，使得网络管理更加安全可靠。 描述中提到的"snmp++"是一个用C++编写的第三方SNMP开发库。C++是一种强大且灵活的编程语言，适合开发...

    SNMP的MIB浏览器 JMIBBrowser.7z

    6. **多协议支持**：除了SNMPv1、SNMPv2c，JMIBBrowser可能还支持更安全的SNMPv3，该版本提供了身份验证和加密，增强了网络管理的安全性。 7. **配置管理**：用户可以保存和加载SNMP代理的配置，方便在不同设备间...

    snmp4j-1.9.2a.rar_snmp4j

    通过研究和使用snmp4j-1.9.2a的源码，开发者不仅可以学习SNMP协议的实现细节，还可以深入了解Java网络编程、多线程、异步处理等方面的知识，这对于网络管理软件的开发是非常宝贵的。同时，源码也是进一步改进和扩展...

    snmp4j-1.9.3d.zip

    SNMP4J是Java开发SNMP（简单网络管理协议）应用程序的一个开源库，它提供了全面的SNMP协议实现，包括v1、v2c和v3版本。在本文中，我们将深入探讨SNMP4J的核心功能、使用场景、以及如何通过这个库来实现网络设备的...

    snmp.zip_SNMP_SNMP set_c++ getnext（）_c++ snmp::set_snmp++

    SNMP（Simple Network Management Protocol，简单网络管理协议）是一种广泛应用于网络设备管理的协议，它允许网络管理员远程监控和配置网络设备。C++是实现SNMP的一种编程语言，提供了多种库来支持SNMP操作，如SNMP+...

    snmp++3.4.6动态库（mingw编译，包含头文件）.zip

    SNMP++ 3.4.6 动态库是一个用于开发网络管理应用程序的C++库，它是基于标准的SNMP（简单网络管理协议）构建的。这个库特别针对mingw编译环境进行了优化，适用于使用Qt开发平台的开发者。本文将深入探讨SNMP++、...

    andy net-snmp-5.7.pre1.zip

    net-snmp是一个开源的网络管理系统，它提供了一套完整的工具集用于管理和监控网络设备。net-snmp项目始于1992年，至今已经发展成为一个功能强大、稳定且高度可配置的网络管理软件。在本文中，我们将深入探讨net-snmp...

Magicbox
Global site tag (gtag.js) - Google Analytics