SNMP

src/jnet/lib/Message.java

@@ -104,8 +104,11 @@ public class Message implements Serializable {
     // C->S: klient posila požadavek na smazaní udalostí
     public static final int DELETE_LOG = 113;
     
+    // C->S: klient si vyžádal SNMP informace o bojektu
+    public static final int SNMP_OBJECT_INFO = 114;
     
-    
+    // C->S: klient si vyžádal SNMP informace o interface objektu
+    public static final int SNMP_OBJECT_INTERFACE = 115;
     
     
     

src/jnet/lib/object/Event.java

@@ -16,6 +16,7 @@ public class Event implements Serializable{
     public static final int TYPE_SNMP = 2;
     public static final int TYPE_INFO = 3;
     public static final int TYPE_PING_OFF = 4;
+    public static final int TYPE_PING_ON = 5;
 
     public Event(int id, int object, long start, long end, String description, int type) {
         this.id = id;

src/jnet/lib/object/SnmpProfile.java

@@ -1,6 +1,7 @@
 package jnet.lib.object;
 
 import java.io.Serializable;
+import org.snmp4j.mp.SnmpConstants;
 
 
 public class SnmpProfile implements Serializable {
@@ -12,6 +13,11 @@ public class SnmpProfile implements Serializable {
     private String communityRead;
     private String communityWrite;
     
+    private static final int version1 = SnmpConstants.version1;
+    private static final int version2c = SnmpConstants.version2c;
+    private static final int version3 = SnmpConstants.version3;
+    
+
     public SnmpProfile(int id, String name, int version, String port, String communityRead, String communityWrite) {
         this.id = id;
         this.name = name;

src/jnet/lib/snmp/DeviceInfo.java

@@ -0,0 +1,74 @@
+package jnet.lib.snmp;
+
+import java.io.Serializable;
+
+
+public class DeviceInfo implements Serializable{
+    
+        private String sysName;
+        private String sysDescr;
+        private String sysUptime;
+        private String sysContact;
+        private String sysLocation;
+        private String sysObjectID;
+
+    public DeviceInfo(String sysName, String sysDescr, String sysUptime, String sysContact, String sysLocation, String sysObjectID) {
+        this.sysName = sysName;
+        this.sysDescr = sysDescr;
+        this.sysUptime = sysUptime;
+        this.sysContact = sysContact;
+        this.sysLocation = sysLocation;
+        this.sysObjectID = sysObjectID;
+    }
+
+    public String getSysName() {
+        return sysName;
+    }
+
+    public void setSysName(String sysName) {
+        this.sysName = sysName;
+    }
+
+    public String getSysDescr() {
+        return sysDescr;
+    }
+
+    public void setSysDescr(String sysDescr) {
+        this.sysDescr = sysDescr;
+    }
+
+    public String getSysUptime() {
+        return sysUptime;
+    }
+
+    public void setSysUptime(String sysUptime) {
+        this.sysUptime = sysUptime;
+    }
+
+    public String getSysContact() {
+        return sysContact;
+    }
+
+    public void setSysContact(String sysContact) {
+        this.sysContact = sysContact;
+    }
+
+    public String getSysLocation() {
+        return sysLocation;
+    }
+
+    public void setSysLocation(String sysLocation) {
+        this.sysLocation = sysLocation;
+    }
+
+    public String getSysObjectID() {
+        return sysObjectID;
+    }
+
+    public void setSysObjectID(String sysObjectID) {
+        this.sysObjectID = sysObjectID;
+    }
+        
+        
+
+}

src/jnet/lib/snmp/Interface.java

@@ -0,0 +1,104 @@
+package jnet.lib.snmp;
+
+import java.io.Serializable;
+
+public class Interface implements Serializable {
+
+    private int id;
+    private String description;
+    private String operStatus;
+    private String speed;
+    private String type;
+    private String macAddress;
+    private String adminStatus;
+    private String lastChangeTime;
+
+    public Interface(int id, String description, String operStatus, String speed, String type, String macAddress, String adminStatus, String lastChangeTime) {
+        this.id = id;
+        this.description = description;
+        this.operStatus = operStatus;
+        this.speed = speed;
+        this.type = type;
+        this.macAddress = macAddress;
+        this.adminStatus = adminStatus;
+        this.lastChangeTime = lastChangeTime;
+    }
+
+    @Override
+    public String toString() {
+        return "Interface ID: " + id + "\n"
+                + "Description: " + description + "\n"
+                + "Operational Status: " + operStatus + "\n"
+                + "Speed: " + speed + "\n"
+                + "Type: " + type + "\n"
+                + "MAC Address: " + macAddress + "\n"
+                + "Administrative Status: " + adminStatus + "\n"
+                + "Last Link Change: " + lastChangeTime + "\n";
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public String getOperStatus() {
+        return operStatus;
+    }
+
+    public void setOperStatus(String operStatus) {
+        this.operStatus = operStatus;
+    }
+
+    public String getSpeed() {
+        return speed;
+    }
+
+    public void setSpeed(String speed) {
+        this.speed = speed;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getMacAddress() {
+        return macAddress;
+    }
+
+    public void setMacAddress(String macAddress) {
+        this.macAddress = macAddress;
+    }
+
+    public String getAdminStatus() {
+        return adminStatus;
+    }
+
+    public void setAdminStatus(String adminStatus) {
+        this.adminStatus = adminStatus;
+    }
+
+    public String getLastChangeTime() {
+        return lastChangeTime;
+    }
+
+    public void setLastChangeTime(String lastChangeTime) {
+        this.lastChangeTime = lastChangeTime;
+    }
+    
+    
+}

src/jnet/lib/snmp/SNMPDeviceInfo.java

@@ -0,0 +1,154 @@
+package jnet.lib.snmp;
+
+import org.snmp4j.*;
+import org.snmp4j.event.ResponseEvent;
+import org.snmp4j.mp.SnmpConstants;
+import org.snmp4j.smi.*;
+import org.snmp4j.transport.DefaultUdpTransportMapping;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+public class SNMPDeviceInfo {
+
+    private Snmp snmp;
+    private String address;
+    private String community;
+    private int version;
+
+    // SNMP OID pro základní informace
+    private static final OID SYS_NAME_OID = new OID("1.3.6.1.2.1.1.5.0");
+    private static final OID SYS_DESCR_OID = new OID("1.3.6.1.2.1.1.1.0");
+    private static final OID SYS_UPTIME_OID = new OID("1.3.6.1.2.1.1.3.0");
+    private static final OID SYS_CONTACT_OID = new OID("1.3.6.1.2.1.1.4.0");
+    private static final OID SYS_LOCATION_OID = new OID("1.3.6.1.2.1.1.6.0");
+    private static final OID SYS_OBJECT_ID_OID = new OID("1.3.6.1.2.1.1.2.0");
+
+    // OID databáze vyrobcu
+    private static final Map<String, String> DEVICE_OID_MAP = new HashMap<>();
+
+    static {
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.9", "Cisco");
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.11", "Hewlett-Packard (HP)");
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.14988", "Mikrotik");
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.41112.1.3.1", "Ubiquiti Networks");
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.259.10.1.43.101", "EdgeCore");
+        DEVICE_OID_MAP.put("1.3.6.1.4.1.11863.5.1048577", "TP-Link");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.43", "Lexmark");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.311", "Microsoft");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.3224", "Fortinet");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.8072", "Net-SNMP");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.2021", "Linux Host");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.171", "D-Link");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.12148", "MikroTik");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.2636", "Juniper Networks");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.674", "Dell");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.2352", "Allied Telesis");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.807", "IBM");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.562", "Alcatel");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.14988", "Ubiquiti Networks");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.22610", "Ruckus Wireless");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.318", "APC (Schneider Electric)");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.2011", "Huawei");
+//        DEVICE_OID_MAP.put("1.3.6.1.4.1.4826", "Opengear");
+    }
+
+    public SNMPDeviceInfo(String ip, String port, String community, int version) throws IOException {
+        this.address = ip + "/" + port;  // Přidání SNMP portu
+        this.community = community;
+        this.version = version;
+        
+        TransportMapping<UdpAddress> transport = new DefaultUdpTransportMapping();
+        snmp = new Snmp(transport);
+        transport.listen();
+    }
+
+    /**
+     * Získání základních informací o zařízení.
+     */
+    public DeviceInfo getDeviceInfo() throws IOException {
+        DeviceInfo di = new DeviceInfo(
+                getAsString(SYS_NAME_OID),
+                getAsString(SYS_DESCR_OID),
+                getAsString(SYS_UPTIME_OID),
+                getAsString(SYS_CONTACT_OID),
+                getAsString(SYS_LOCATION_OID),
+                getDeviceVendor()
+        );
+
+        return di;
+    }
+
+    /**
+     * Získá sysObjectID a přeloží na výrobce
+     *
+     * @return Výrobce nebo "Neznámý" + OID
+     * @throws IOException
+     */
+    public String getDeviceVendor() throws IOException {
+        String sysObjectID = getAsString(SYS_OBJECT_ID_OID);
+
+        // Překlad OID na výrobce
+        for (String oidPrefix : DEVICE_OID_MAP.keySet()) {
+            if (sysObjectID.startsWith(oidPrefix)) {
+                return DEVICE_OID_MAP.get(oidPrefix);
+            }
+        }
+
+        return "Neznámý výrobce (" + sysObjectID + ")";
+    }
+
+    /**
+     * Získání hodnoty SNMP OID jako String.
+     */
+    private String getAsString(OID oid) throws IOException {
+        CommunityTarget target = createTarget();
+        PDU pdu = new PDU();
+        pdu.add(new VariableBinding(oid));
+        pdu.setType(PDU.GET);
+
+        ResponseEvent event = snmp.get(pdu, target);
+        if (event != null && event.getResponse() != null) {
+            return event.getResponse().get(0).getVariable().toString();
+        } else {
+            return "No response";
+        }
+    }
+
+    /**
+     * Převede SNMP sysUpTime (setiny sekundy) na čitelný formát D HH:MM:SS
+     *
+     * @param sysUpTime setiny sekundy (centiseconds)
+     * @return čitelný uptime
+     */
+    private static String formatUptime(String sysUpTime) {
+        System.out.println("jnet.lib.snmp.SNMPDeviceInfo.formatUptime() " +sysUpTime);
+        try {
+            long centiseconds = Long.parseLong(sysUpTime);
+            long totalSeconds = centiseconds / 100;
+            long days = totalSeconds / 86400;
+            long hours = (totalSeconds % 86400) / 3600;
+            long minutes = (totalSeconds % 3600) / 60;
+            long seconds = totalSeconds % 60;
+
+            return String.format("%d dní, %02d:%02d:%02d", days, hours, minutes, seconds);
+        } catch (NumberFormatException e) {
+            return "Neplatný uptime";
+        }
+    }
+
+    /**
+     * Vytvoření SNMP cíle (target).
+     */
+    private CommunityTarget createTarget() {
+        CommunityTarget target = new CommunityTarget();
+        target.setCommunity(new OctetString(this.community));
+        target.setAddress(new UdpAddress(this.address));
+        target.setVersion(this.version);
+        target.setRetries(2);
+        target.setTimeout(1500);
+        return target;
+    }
+
+}

src/jnet/lib/snmp/SNMPInterfaceScanner.java

@@ -0,0 +1,280 @@
+package jnet.lib.snmp;
+
+import java.io.IOException;
+import java.text.DecimalFormat;
+import java.util.ArrayList;
+import java.util.List;
+import org.snmp4j.CommunityTarget;
+import org.snmp4j.PDU;
+import org.snmp4j.Snmp;
+import org.snmp4j.TransportMapping;
+import org.snmp4j.event.ResponseEvent;
+import org.snmp4j.mp.SnmpConstants;
+import org.snmp4j.smi.OID;
+import org.snmp4j.smi.OctetString;
+import org.snmp4j.smi.UdpAddress;
+import org.snmp4j.smi.VariableBinding;
+import org.snmp4j.transport.DefaultUdpTransportMapping;
+
+public class SNMPInterfaceScanner {
+
+    private Snmp snmp;
+    private String address;
+    private String community;
+    private int version;
+
+    // OID pro rozhraní v IF-MIB
+    private static final String IF_INDEX_OID = "1.3.6.1.2.1.2.2.1.1";   // ifIndex
+    private static final String IF_DESCR_OID = "1.3.6.1.2.1.2.2.1.2";   // ifDescr
+    private static final String IF_SPEED_OID = "1.3.6.1.2.1.2.2.1.5";       // speed
+    private static final String IF_TYPE_OID = "1.3.6.1.2.1.2.2.1.3";    // ifType
+    private static final String IF_MAC_OID = "1.3.6.1.2.1.2.2.1.3";         // mac
+    private static final String IF_STATUS_OID = "1.3.6.1.2.1.2.2.1.8";  // ifOperStatus
+    private static final String IF_STATUS_ADM_OID = "1.3.6.1.2.1.2.2.1.7";  // adminStatus
+    private static final String IF_LAST_CHANGE_OID = "1.3.6.1.2.1.2.2.1.9"; // lastchange
+
+    public SNMPInterfaceScanner(String address, String port, String community, int version) throws IOException {
+        this.address = address + "/" + port;
+        this.community = community;
+        this.version = version;
+
+        TransportMapping<UdpAddress> transport = new DefaultUdpTransportMapping();
+        snmp = new Snmp(transport);
+        transport.listen();
+    }
+
+    /**
+     * Získání detailních informací o všech interfaces
+     *
+     * @throws IOException
+     */
+    public List<Interface> scanInterfaces() throws IOException {
+        List<Interface> list = new ArrayList<>();
+        
+        CommunityTarget target = createTarget();
+
+        OID oid = new OID(IF_INDEX_OID); // Start na ifIndex
+        boolean finished = false;
+
+        while (!finished) {
+            PDU pdu = new PDU();
+            pdu.add(new VariableBinding(oid));
+            pdu.setType(PDU.GETNEXT);
+
+            ResponseEvent response = snmp.send(pdu, target);
+            if (response == null || response.getResponse() == null) {
+                System.out.println("Žádná odpověď od SNMP agenta.");
+                break;
+            }
+
+            VariableBinding vb = response.getResponse().get(0);
+            OID nextOid = vb.getOid();
+
+            // Pokud jsme mimo tabulku, ukončit cyklus
+            if (!nextOid.startsWith(new OID(IF_INDEX_OID))) {
+                finished = true;
+                continue;
+            }
+
+            int ifIndex = vb.getVariable().toInt();
+            String ifDescr = getSnmpValue(IF_DESCR_OID + "." + ifIndex, target);
+            String ifType = getSnmpValue(IF_TYPE_OID + "." + ifIndex, target);
+            String ifStatus = getSnmpValue(IF_STATUS_OID + "." + ifIndex, target);
+            String ifSpeed = getSnmpValue(IF_SPEED_OID + "." + ifIndex, target);
+            String ifMac = getSnmpValue(IF_MAC_OID + "." + ifIndex, target);
+            String ifStatusAdm = getSnmpValue(IF_STATUS_ADM_OID + "." + ifIndex, target);
+            String ifLastChange = getSnmpValue(IF_LAST_CHANGE_OID + "." + ifIndex, target);
+            
+            list.add(new Interface(
+                    ifIndex, // index
+                    ifDescr, // description
+                    getInterfaceStatus(ifStatus), // operStatus
+                    formatIfSpeed(Long.parseLong(ifSpeed)), // speed
+                    getInterfaceType(ifType), // type
+                    ifMac, //mac
+                    convertIfAdminStatus(ifStatusAdm), //adminStatus
+                    ifLastChange // lastChange
+            ));
+
+            // Posuneme OID na další položku
+            oid = nextOid;
+        }
+        snmp.close();
+        return list;
+    }
+    
+    /**
+     * Pomocná metoda pro vytvoření SNMP cíle (target)
+     *
+     * @return
+     */
+    private CommunityTarget createTarget() {
+        CommunityTarget target = new CommunityTarget();
+        target.setCommunity(new OctetString(community));
+        target.setAddress(new UdpAddress(address));
+        target.setVersion(SnmpConstants.version2c);
+        target.setRetries(2);
+        target.setTimeout(1500);
+        return target;
+    }
+
+    private String getSnmpValue(String oid, CommunityTarget target) throws IOException {
+        PDU pdu = new PDU();
+        pdu.add(new VariableBinding(new OID(oid)));
+        pdu.setType(PDU.GET);
+
+        ResponseEvent response = snmp.send(pdu, target);
+        if (response != null && response.getResponse() != null) {
+            return response.getResponse().get(0).getVariable().toString();
+        }
+        return "Neznámé";
+    }
+
+    /**
+     * prevadi ciselne oznaceni typu rozhrani na nazev
+     * @param type
+     * @return 
+     */
+    private String getInterfaceType(String type) {
+        switch (type) {
+            case "1":
+                return "Jiné";
+            case "6":
+                return "Ethernet";
+            case "7":
+                return "ISO 8802-3";
+            case "9":
+                return "Token Ring";
+            case "15":
+                return "FDDI";
+            case "23":
+                return "PPP";
+            case "24":
+                return "Loopback";
+            case "28":
+                return "ATM";
+            case "32":
+                return "Frame Relay";
+            case "37":
+                return "IP-over-ATM";
+            case "53":
+                return "Fibre Channel";
+            case "62":
+                return "Fast Ethernet (100 Mbps)";
+            case "69":
+                return "Gigabit Ethernet (1 Gbps)";
+            case "71":
+                return "WiFi (802.11)";
+            case "94":
+                return "ATM Subinterface";
+            case "117":
+                return "Gigabit Ethernet (1 Gbps)";
+            case "131":
+                return "Tunnel";
+            case "135":
+                return "VLAN";
+            case "136":
+                return "LACP (Link Aggregation)";
+            case "161":
+                return "ISDN";
+            case "169":
+                return "DSL";
+            case "175":
+                return "DOCSIS (kabelový modem)";
+            case "181":
+                return "ATM (PON)";
+            case "182":
+                return "Ethernet (PON)";
+            case "209":
+                return "Bridge";
+            case "237":
+                return "LTE";
+            case "243":
+                return "5G";
+            default:
+                return "(" + type + ") Neznámé ";
+        }
+    }
+
+    /**
+     * prevadi ciselne oznaceni statusu rozhrani na nazev
+     *
+     * @param status
+     * @return
+     */
+    private String getInterfaceStatus(String status) {
+        switch (status) {
+            case "1":
+                return "Up";            // up(1)
+            case "2":
+                return "Down";          // down(2)
+            case "3":
+                return "Testing";              // testing(3)
+            case "4":
+                return "Unknown";            // unknown(4)
+            case "5":
+                return "Dormant";           // dormant(5)
+            case "6":
+                return "No present";         // notPresent(6)
+            case "7":
+                return "Lower Layer Down";  // lowerLayerDown(7)
+            default:
+                return "Neznámé (" + status + ")";
+        }
+    }
+
+/**
+     * Pomocná metoda pro rmátování času z Unixového formátu na čitelný
+     *
+     * @param unixTimestamp
+     * @return
+     */
+    private String formatTimestamp(String unixTimestamp) {
+        try {
+            long timestamp = Long.parseLong(unixTimestamp);
+            return new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new java.util.Date(timestamp * 1000));
+        } catch (NumberFormatException e) {
+            return "";
+        }
+    }
+    
+    /**
+     * funkce převede rychlost do citelnejsi podoby
+     * @param ifSpeed
+     * @return 
+     */
+    private static String formatIfSpeed(long ifSpeed) {
+        String[] UNITS = {"bps", "kbps", "Mbps", "Gbps", "Tbps"};
+        
+        if (ifSpeed <= 0) {
+            return "-";
+        }
+
+        int unitIndex = 0;
+        double speed = ifSpeed;
+
+        while (speed >= 1000 && unitIndex < UNITS.length - 1) {
+            speed /= 1000;
+            unitIndex++;
+        }
+
+        long roundedSpeed = Math.round(speed); // Zaokrouhlení na celé číslo
+        DecimalFormat df = new DecimalFormat("#,###"); // Oddělování tisíců
+
+        return df.format(roundedSpeed) + " " + UNITS[unitIndex];
+    }
+
+    /**
+     * prevede adm status na text
+     * @param status
+     * @return 
+     */
+    private static String convertIfAdminStatus(String status) {
+        return switch (status) {
+            case "1" -> "Up";
+            case "2" -> "Down";
+            case "3" -> "Testing";
+            default -> "Unknown";
+        };
+    }
+}

src/jnet/lib/snmp/SNMPTester.java

@@ -0,0 +1,57 @@
+package jnet.lib.snmp;
+
+
+import org.snmp4j.*;
+import org.snmp4j.event.ResponseEvent;
+import org.snmp4j.mp.SnmpConstants;
+import org.snmp4j.smi.*;
+import org.snmp4j.transport.*;
+
+public class SNMPTester {
+
+    private String address;
+    private String community;
+    private int version;
+
+    public SNMPTester(String address, String port, String community, int version) {
+        this.address = address+"/"+port;
+        this.community = community;
+        this.version = version;
+    }
+    
+    public boolean testSnmp() {
+        try {
+            // Nastavení SNMP agenta
+            TransportMapping transport = new DefaultUdpTransportMapping();
+            Snmp snmp = new Snmp(transport);
+            transport.listen();
+
+            // Cílový hostitel a community string
+            Target target = new CommunityTarget();
+            ((CommunityTarget) target).setCommunity(new OctetString(this.community));
+            target.setVersion(this.version);
+            target.setAddress(new UdpAddress(this.address));
+            target.setRetries(3); // Počet pokusů
+            target.setTimeout(5000); // Timeout v milisekundách
+
+            // Odeslání SNMP požadavku na systémovou OID (sysDescr)
+            PDU request = new PDU();
+            request.add(new VariableBinding(SnmpConstants.sysDescr)); // OID pro systémový popis
+            request.setType(PDU.GET);
+
+            // Odeslání požadavku
+            ResponseEvent response = snmp.get(request, target);
+            snmp.close(); // Ukončení SNMP komunikace
+
+            // Zpracování odpovědi
+            if (response != null && response.getResponse() != null) {
+                PDU pdu = response.getResponse();
+                return true; // Funkční SNMP
+            } else {
+                return false; // Nefunkční SNMP
+            }
+        } catch (Exception e) {
+            return false; // Chyba komunikace
+        }
+    }
+}

src/jnet/lib/snmp/SNMPTrafficMonitor.java

@@ -0,0 +1,154 @@
+package jnet.lib.snmp;
+
+import java.io.IOException;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import org.snmp4j.CommunityTarget;
+import org.snmp4j.PDU;
+import org.snmp4j.Snmp;
+import org.snmp4j.TransportMapping;
+import org.snmp4j.event.ResponseEvent;
+import org.snmp4j.smi.OID;
+import org.snmp4j.smi.OctetString;
+import org.snmp4j.smi.UdpAddress;
+import org.snmp4j.smi.Variable;
+import org.snmp4j.smi.VariableBinding;
+import org.snmp4j.transport.DefaultUdpTransportMapping;
+
+
+public class SNMPTrafficMonitor {
+    
+    private Snmp snmp;
+    private String address;
+    private String community;
+    private int version;
+    private ScheduledExecutorService scheduler;
+    
+    private long previousInOctets = 0;
+    private long previousOutOctets = 0;
+    private long previousTimestamp = System.currentTimeMillis();
+    
+    public SNMPTrafficMonitor(String ip, String port, String community, int version) throws IOException {
+        this.address = ip + "/" + port; 
+        this.community = community;
+        this.version = version;
+        
+        TransportMapping<UdpAddress> transport = new DefaultUdpTransportMapping();
+        snmp = new Snmp(transport);
+        transport.listen();
+    }
+    
+    /**
+     * Vytvoření SNMP cíle (target).
+     */
+    private CommunityTarget createTarget() {
+        CommunityTarget target = new CommunityTarget();
+        target.setCommunity(new OctetString(this.community));
+        target.setAddress(new UdpAddress(this.address));
+        target.setVersion(this.version);
+        target.setRetries(2);
+        target.setTimeout(1500);
+        return target;
+    }
+    
+    public void getTraffic(int interfaceIndex) throws Exception {
+        // OID pro přijaté a odeslané bajty specifického rozhraní
+        OID oidInOctets = new OID("1.3.6.1.2.1.2.2.1.10." + interfaceIndex);  // ifInOctets pro daný interface
+        OID oidOutOctets = new OID("1.3.6.1.2.1.2.2.1.16." + interfaceIndex); // ifOutOctets pro daný interface
+
+        // Vytvoření SNMP požadavku pro získání hodnot
+        PDU pdu = new PDU();
+        pdu.add(new VariableBinding(oidInOctets));  // Přidaní OID pro příchozí traffic
+        pdu.add(new VariableBinding(oidOutOctets)); // Přidaní OID pro odchozí traffic
+        pdu.setType(PDU.GET);
+
+        // Definování cíle SNMP zařízení
+        CommunityTarget target = createTarget();
+
+        // Odeslání požadavku a zpracování odpovědi
+        ResponseEvent response = snmp.get(pdu, target);
+
+        if (response != null && response.getResponse() != null) {
+            PDU responsePDU = response.getResponse();
+            Variable inOctets = responsePDU.getVariableBindings().get(0).getVariable();
+            Variable outOctets = responsePDU.getVariableBindings().get(1).getVariable();
+
+            long currentInOctets = inOctets.toLong();
+            long currentOutOctets = outOctets.toLong();
+            long currentTimestamp = System.currentTimeMillis();
+
+            // Vypočítání traffiku za sekundu
+            long deltaInOctets = currentInOctets - previousInOctets;
+            long deltaOutOctets = currentOutOctets - previousOutOctets;
+            long deltaTime = currentTimestamp - previousTimestamp;
+
+            // Vypočítání traffiku za sekundu
+            double inTrafficPerSecond = (deltaInOctets * 1000.0) / deltaTime;  // Počet bajtů za sekundu
+            double outTrafficPerSecond = (deltaOutOctets * 1000.0) / deltaTime;
+
+            System.out.println("Traffic na rozhrani " + interfaceIndex + ":");
+            System.out.println("Prijaty traffic (In Octets): " + formatBytes(currentInOctets) + " | Za sekundu: " + formatBytesPerSecond(inTrafficPerSecond));
+            System.out.println("Odeslany traffic (Out Octets): " + formatBytes(currentOutOctets) + " | Za sekundu: " + formatBytesPerSecond(outTrafficPerSecond));
+
+            // Uložení aktuálních hodnot pro další výpočet
+            previousInOctets = currentInOctets;
+            previousOutOctets = currentOutOctets;
+            previousTimestamp = currentTimestamp;
+        } else {
+            System.out.println("Chyba při získávání dat z cílového zařízení.");
+        }
+    }
+    
+    public void startMonitoring(int interfaceIndex) {
+        // Vytvoření plánovače pro spuštění každých 5 sekund
+        scheduler = Executors.newScheduledThreadPool(1);
+        scheduler.scheduleAtFixedRate(() -> {
+            try {
+                getTraffic(interfaceIndex);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }, 0, 3, TimeUnit.SECONDS); // Start okamžitě a potom každých 5 sekund
+    }
+
+    public void stopMonitoring() {
+        if (scheduler != null) {
+            scheduler.shutdown();  // Umožní ukončení plánování
+        }
+    }
+    
+    // Metoda pro přepočet traffiku za sekundu na čitelnou podobu
+    private String formatBytesPerSecond(double bytesPerSecond) {
+        if (bytesPerSecond < 1024) {
+            return String.format("%.2f B/s", bytesPerSecond);
+        } else if (bytesPerSecond < 1048576) {  // 1024 * 1024
+            return String.format("%.2f KB/s", bytesPerSecond / 1024.0);
+        } else if (bytesPerSecond < 1073741824) {  // 1024 * 1024 * 1024
+            return String.format("%.2f MB/s", bytesPerSecond / 1048576.0);
+        } else {
+            return String.format("%.2f GB/s", bytesPerSecond / 1073741824.0);
+        }
+    }
+
+    public void stop() throws Exception {
+        if (snmp != null) {
+            snmp.close();
+        }
+    }
+
+    
+    // Metoda pro přepočet bajtů na čitelnou podobu
+    private String formatBytes(long bytes) {
+        if (bytes < 1024) {
+            return bytes + " B";
+        } else if (bytes < 1048576) {  // 1024 * 1024
+            return String.format("%.2f KB", bytes / 1024.0);
+        } else if (bytes < 1073741824) {  // 1024 * 1024 * 1024
+            return String.format("%.2f MB", bytes / 1048576.0);
+        } else {
+            return String.format("%.2f GB", bytes / 1073741824.0);
+        }
+    }
+
+}