🏷️ 😂 💄 एसएनएमपी इतना सरल क्यों नहीं है? 🔊 ↖️ 💅🏼

बहुत समय पहले, हेब पर एक लेख प्रकाशित किया गया था जो एक जावा अनुप्रयोग से एसएनएमपी के साथ काम करने के लिए लोकप्रिय पुस्तकालय का उपयोग करने के बारे में बात करता है। सामान्य तौर पर, लेखक के उपक्रम का समर्थन करते हुए, मैं उन कठिनाइयों पर ध्यान देना चाहता हूं जो SNMP का उपयोग करके वास्तविक परियोजना में उत्पन्न हो सकती हैं।

प्रलेखन पढ़ें

के साथ शुरू करने के लिए, मैं इस तथ्य पर ध्यान देना चाहूंगा कि यह पूरी तरह से मेरे लिए स्पष्ट नहीं है कि, एसएनएमपी अनुरोधों की पूरी विविधता से, लेखक टीआरएपी पर क्यों बस गए? आइए देखें कि RFC 1157 इस बारे में क्या लिखता है:

एसएनएमपी में निहित रणनीति यह है कि किसी भी महत्वपूर्ण स्तर पर नेटवर्क राज्य की निगरानी मुख्य रूप से निगरानी केंद्र (नों) की ओर से उपयुक्त जानकारी के लिए मतदान द्वारा पूरी की जाती है। सीमित संख्या में अनचाहे संदेश (जाल) मतदान का समय और ध्यान केंद्रित करते हैं। अवांछित संदेशों की संख्या को सीमित करना सादगी के लक्ष्य के अनुरूप है और
नेटवर्क प्रबंधन फ़ंक्शन द्वारा उत्पन्न ट्रैफ़िक की मात्रा को कम करना।

जिन लोगों को अंग्रेजी भाषा में कठिनाई होती है, उनके लिए रूसी अनुवाद है :

एसएनएमपी रणनीति यह है कि किसी भी महत्वपूर्ण स्तर के विस्तार के साथ नेटवर्क की स्थिति की निगरानी मुख्य रूप से एक निगरानी केंद्र से मतदान के द्वारा की जाती है। अनचाहे संदेशों की एक सीमित संख्या (जाल - रुकावट) सिंक्रनाइज़ेशन प्रदान करती है और चुनावों को सक्रिय करती है। अवांछित संदेशों की संख्या को सीमित करना सादगी सुनिश्चित करने और नेटवर्क प्रबंधन प्रणाली द्वारा बनाए गए यातायात को कम करने के कार्यों के अनुरूप है।

इन उद्धरणों से, यह स्पष्ट है कि टीआरएपी और सूचना प्रकार के प्रश्न एसएनएमपी का सबसे अधिक इस्तेमाल किया जाने वाला हिस्सा नहीं हैं। शुरुआती के लिए एक लेख बहुत अधिक सामान्य जीईटी अनुरोधों का उपयोग करने के उदाहरणों के साथ वर्णन करना अधिक उपयुक्त होगा।

सामान्य तौर पर, मैं अत्यधिक अनुशंसा करता हूं कि आरंभ करने से पहले आप स्वयं को सभी एसएनएमपी-संबंधित आरएफसी से परिचित कराएं। एसएनएमपी के कुछ पहलू स्पष्ट नहीं हैं और यह मूल स्रोत से उनमें से एक विचार प्राप्त करने के लिए समझ में आता है। आप विकी के साथ सामग्री से परिचित होना शुरू कर सकते हैं।

पहला कदम

प्रलेखन के साथ अनिवार्य परिचित के अलावा, यह समझना महत्वपूर्ण है कि हम सभी ऐसा क्यों करते हैं। टेलिकॉम प्रैक्टिस में, निम्नलिखित कार्यों को अक्सर सामना करना पड़ता है:

एसएनएमपी (लेखा, निगरानी) के माध्यम से उपकरणों का सर्वेक्षण
SNMP उपकरण प्रबंधन (सक्रियण)

उपकरण के सर्वेक्षण से जुड़े कार्यों को GET के गठन के लिए कम कर दिया जाता है (और, जैसा कि GETNEXT बाद में दिखाएगा) अनुरोध। एसईटी-अनुरोध भेजने के लिए उपकरण प्रबंधन कम हो जाता है जो उपकरणों पर संबंधित चर की स्थिति को बदल देता है (उदाहरण के लिए, इस प्रकार, आप कुछ इंटरफ़ेस को अक्षम कर सकते हैं)।

एसएनएमपी निगरानी का कार्य सामान्य पृष्ठभूमि के विरुद्ध इस आवश्यकता से होता है कि जिस उपकरण का सर्वेक्षण किया जा रहा है वह कई या बहुत अधिक है। मान लीजिए कि यह ठीक यही समस्या है जिसे हमें हल करना है।

कोड लिखना शुरू करते हैं। परीक्षण के उदाहरण में, हम SNMP के माध्यम से अपने स्वयं के मेजबान से संपर्क करेंगे और OID 1.3.6.1.2.1.1.3.0 द्वारा निर्दिष्ट चर के मान को पढ़ेंगे और मेजबान अपटाइम को शामिल करेंगे:

एकल GET अनुरोध

package com.acme.ae.tests.snmp; import java.io.IOException; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.Target; import org.snmp4j.TransportMapping; import org.snmp4j.event.ResponseEvent; 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; public class Test { private final static String SNMP_COMMUNITY = "public"; private final static int SNMP_RETRIES = 3; private final static long SNMP_TIMEOUT = 1000L; private Snmp snmp = null; private TransportMapping transport = null; private void test() throws IOException { Target t = getTarget("udp:127.0.0.1/161"); String r = send(t, "1.3.6.1.2.1.1.3.0"); System.out.println(r); } private String send(Target target, String oid) throws IOException { PDU pdu = new PDU(); pdu.add(new VariableBinding(new OID(oid))); pdu.setType(PDU.GET); ResponseEvent event = snmp.send(pdu, target, null); if (event != null) { return event.getResponse().get(0).toString(); } else { return "Timeout exceeded"; } } private Target getTarget(String address) { Address targetAddress = GenericAddress.parse(address); CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(SNMP_COMMUNITY)); target.setAddress(targetAddress); target.setRetries(SNMP_RETRIES); target.setTimeout(SNMP_TIMEOUT); target.setVersion(SnmpConstants.version1); return target; } private void start() throws IOException { transport = new DefaultUdpTransportMapping(); snmp = new Snmp(transport); transport.listen(); } private void stop() throws IOException { try { if (transport != null) { transport.close(); transport = null; } } finally { if (snmp != null) { snmp.close(); snmp = null; } } } public static void main(String[] args) { Test t = new Test(); try { try { t.start(); t.test(); } finally { t.stop(); } } catch (IOException e) { System.out.println(e.toString()); } } }

यह सुनिश्चित करने के बाद कि हमारे मेजबान पर SNMP सेवा काम कर रही है और निष्पादन के लिए कोड चला रही है, हमें वांछित अपटाइम वैल्यू मिलती है (जिस समय होस्ट ने अंतिम बूट के बाद से काम करना बंद कर दिया है):

 1.3.6.1.2.1.1.3.0 = 2:28:55.06

इस मान का उपयोग करके, आप निगरानी कर सकते हैं। यदि हम पाते हैं कि मान कम हो गया है, तो मेजबान अगले मतदान के क्षण से रिबूट करने में कामयाब रहा है। यदि होस्ट निर्दिष्ट टाइमआउट (कई स्वचालित प्रयासों के बाद) के भीतर जवाब नहीं देता है, तो इसका सबसे अधिक संभावना है कि मेजबान नीचे है। क्या सब कुछ सरल है?

गिना - रोया

वास्तव में नहीं। हमें याद है कि हमें कई अनुरोधों को पूरा करना है। आइए देखें कि हम प्रति सेकंड कितने प्रश्नों को निष्पादित कर सकते हैं? आइए कोड में एक छोटा सुधार करें:

  private void test() throws IOException { Target t = getTarget("udp:127.0.0.1/161"); Long timestamp = System.currentTimeMillis(); for (int i = 0; i < 1000; i++) { send(t, "1.3.6.1.2.1.1.3.0"); } System.out.println(1000000L /(System.currentTimeMillis() - timestamp)); }

और इसे चलाने के लिए निष्पादित करें:

प्रति सेकंड लगभग ढाई हजार अनुरोध! बुरा नहीं है?

चलो जल्दी नहीं है। हम लूपबैक इंटरफ़ेस के लिए अनुरोध भेजते हैं, और यह स्थानीय नेटवर्क की तुलना में कुछ तेज़ी से काम करता है। आइए देखें कि हमारे नेटवर्क पर दूसरे होस्ट को पूरा करने के लिए हमारे पास प्रति सेकंड कितने अनुरोध हैं:

दो सौ तक भी नहीं पहुंचे। सामान्यतया, यह पर्याप्त होगा। यह सब कार्य पर निर्भर करता है। लेकिन हमने माप लिया कि साक्षात्कार का मेजबान उपलब्ध है। यदि मेजबान जवाब नहीं देता है तो क्या होता है?

कई एक्सेस प्रयास होंगे (हमारे कोड में हमने 3 सेट किए हैं) टाइमआउट (1000 एमएस) द्वारा अलग किए गए हैं। इसका मतलब है कि एक सेकंड में हमारे पास एक भी अनुरोध पूरा करने का समय नहीं होगा। चूंकि गैर-प्रतिक्रिया देने वाला मेजबान इतना दुर्लभ नहीं है, इसलिए वास्तविक परियोजना में यह एक बड़ी समस्या हो सकती है।

रिकॉर्ड पर जाएं

इससे क्या हो सकता है? यदि हम किसी भी तुल्यकालिक प्रोटोकॉल (उदाहरण के लिए टेलनेट) के साथ काम कर रहे थे, तो हमारे पास ज्यादा विकल्प नहीं होंगे। उत्पादकता बढ़ाने के लिए, हमें एक साथ कई थ्रेड निष्पादित करने होंगे। लेकिन SNMP प्रकृति में अतुल्यकालिक है! इसे तुल्यकालिक फ्रेम में मजबूर करने की आवश्यकता नहीं है।

अतुल्यकालिक विकल्प पर कैसे जाएं? हमारे मामले में, यह बहुत आसान है:

अतुल्यकालिक अनुरोध

 package com.acme.ae.tests.snmp; import java.io.IOException; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.Target; import org.snmp4j.TransportMapping; import org.snmp4j.event.ResponseEvent; import org.snmp4j.event.ResponseListener; 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; public class Test implements ResponseListener { private final static String SNMP_COMMUNITY = "public"; private final static int SNMP_RETRIES = 3; private final static long SNMP_TIMEOUT = 1000L; private Snmp snmp = null; private TransportMapping transport = null; public void onResponse(ResponseEvent event) { PDU response = event.getResponse(); if (response != null) { System.out.println(response.get(0).toString()); return; } } private void test() throws IOException { Target t = getTarget("udp:192.168.131.253/161"); Long timestamp = System.currentTimeMillis(); for (int i = 0; i < 1000; i++) { send(t, "1.3.6.1.2.1.1.3.0"); } System.out.println(1000000L /(System.currentTimeMillis() - timestamp)); } private void send(Target target, String oid) throws IOException { PDU pdu = new PDU(); pdu.add(new VariableBinding(new OID(oid))); pdu.setType(PDU.GET); snmp.send(pdu, target, null, this); } private Target getTarget(String address) { Address targetAddress = GenericAddress.parse(address); CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(SNMP_COMMUNITY)); target.setAddress(targetAddress); target.setRetries(SNMP_RETRIES); target.setTimeout(SNMP_TIMEOUT); target.setVersion(SnmpConstants.version1); return target; } private void start() throws IOException { transport = new DefaultUdpTransportMapping(); snmp = new Snmp(transport); transport.listen(); } private void stop() throws IOException { try { if (transport != null) { transport.close(); transport = null; } } finally { if (snmp != null) { snmp.close(); snmp = null; } } } public static void main(String[] args) { Test t = new Test(); try { try { t.start(); t.test(); } finally { t.stop(); } } catch (IOException e) { System.out.println(e.toString()); } } }

अनुरोध एक अथाह बैरल में गिरने की तरह हैं! बेशक, उत्तर देरी से आएंगे, लेकिन वे भी बहुत जल्दी आएंगे। लेकिन हम कैसे जानते हैं कि मेजबान ने कोई जवाब नहीं दिया।

बहुत सरलता से, निर्दिष्ट संख्या और प्रयासों के बाद, SNMP4J एक घटना लौटाएगा, जिसमें प्रतिक्रिया शून्य होगी:

निश्चित संस्करण

 package com.acme.ae.tests.snmp; import java.io.IOException; import java.util.HashSet; import java.util.Set; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.Target; import org.snmp4j.TransportMapping; import org.snmp4j.event.ResponseEvent; import org.snmp4j.event.ResponseListener; import org.snmp4j.mp.SnmpConstants; import org.snmp4j.smi.Address; import org.snmp4j.smi.GenericAddress; import org.snmp4j.smi.Integer32; import org.snmp4j.smi.OID; import org.snmp4j.smi.OctetString; import org.snmp4j.smi.VariableBinding; import org.snmp4j.transport.DefaultUdpTransportMapping; public class Test implements ResponseListener { private final static String SNMP_COMMUNITY = "public"; private final static int SNMP_RETRIES = 3; private final static long SNMP_TIMEOUT = 1000L; private Snmp snmp = null; private TransportMapping transport = null; private Set<Integer32> requests = new HashSet<Integer32>(); private Long firstTimestamp = null; private long lastTimestamp; public void onResponse(ResponseEvent event) { Integer32 requestId = event.getRequest().getRequestID(); PDU response = event.getResponse(); if (response != null) { lastTimestamp = System.currentTimeMillis(); if (firstTimestamp == null) { firstTimestamp = lastTimestamp; } return; } else { synchronized (requests) { if (requests.contains(requestId)) { System.out.println("Timeout exceeded"); } } } synchronized (requests) { requests.remove(requestId); } } private void test() throws IOException { Target t = getTarget("udp:192.168.131.253/161"); Long timestamp = System.currentTimeMillis(); for (int i = 0; i < 1000; i++) { send(t, "1.3.6.1.2.1.1.3.0"); } System.out.println(1000000L /(System.currentTimeMillis() - timestamp)); while (!requests.isEmpty()) { try { Thread.sleep(1000L); } catch (InterruptedException e) { e.printStackTrace(); } } if (firstTimestamp != null) { System.out.println(1000000L /(lastTimestamp - firstTimestamp)); } } private void send(Target target, String oid) throws IOException { PDU pdu = new PDU(); pdu.add(new VariableBinding(new OID(oid))); pdu.setType(PDU.GET); snmp.send(pdu, target, null, this); synchronized (requests) { requests.add(pdu.getRequestID()); } } private Target getTarget(String address) { Address targetAddress = GenericAddress.parse(address); CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(SNMP_COMMUNITY)); target.setAddress(targetAddress); target.setRetries(SNMP_RETRIES); target.setTimeout(SNMP_TIMEOUT); target.setVersion(SnmpConstants.version1); return target; } private void start() throws IOException { transport = new DefaultUdpTransportMapping(); snmp = new Snmp(transport); transport.listen(); } private void stop() throws IOException { try { if (transport != null) { transport.close(); transport = null; } } finally { if (snmp != null) { snmp.close(); snmp = null; } } } public static void main(String[] args) { Test t = new Test(); try { try { t.start(); t.test(); } finally { t.stop(); } } catch (IOException e) { System.out.println(e.toString()); } } }

हम निष्पादन के परिणाम का विश्लेषण करते हैं:

 9174 283

हम प्रति सेकंड 9174 अनुरोधों को उत्पन्न करने का प्रबंधन करते हैं, और परागित डिवाइस 283 अनुरोधों प्रति सेकंड की गति से अनुरोध को संसाधित करने का प्रबंधन करता है। इसमें अधिकांश अनुरोधों का जवाब देने का समय नहीं है (तदनुसार, "टाइमआउट पार हो गया" संदेश लॉग में रहते हैं)। बेशक, यह एक समस्या नहीं होगी जब हम अनुरोधों के बीच उचित अंतराल के साथ बड़ी संख्या में उपकरणों को मतदान करना शुरू करते हैं।

हम और आगे बढ़ें

हमने सीखा कि SNMP से स्केलर वैरिएबल कैसे प्राप्त करें। लेकिन, उनके अलावा, एसएनएमपी में टेबल भी हैं (उदाहरण के लिए, डिवाइस पर इंटरफ़ेस टेबल)। उनकी व्यवस्था कैसे की जाती है? आइए देखें MIB- ब्राउज़र:

OID mgmt.interfaces (1.3.6.1.2.1.2.2) में हम स्केलर वैरिएबल ifNumber (1.3.6.1.2.2.2.2.1) को तालिका में इंटरफेस की संख्या के साथ-साथ कॉलम का एक सेट देखते हैं। प्रत्येक कॉलम का अपना OID होता है। उदाहरण के लिए, किसी इंटरफ़ेस के संख्यात्मक सूचकांक वाले कॉलम में OID = 1.3.6.1.2.2.2.2.1.1 OID होता है।

इस चर का मूल्य प्राप्त करने के लिए, OID के लिए एक इंटरफ़ेस इंडेक्स जोड़ना आवश्यक है (उदाहरण के लिए, इंडेक्स 123 OID = 1.3.6.1.2.2.2.2.1.1.123 इंडेक्स वाले इंटरफ़ेस के लिए)। लेकिन हम इंटरफेस के इंडेक्स कैसे प्राप्त करते हैं? वे जरूरी नहीं कि क्रम में जाएं! उदाहरण के लिए, मेरी मशीन पर, इंटरफ़ेस तालिका इस तरह दिखती है:

इस उद्देश्य के लिए, GETNEXT अनुरोध का आविष्कार किया गया था। इस अनुरोध के लिए OID उपसर्ग पास करते हुए, हम इस चर उपसर्ग के बाद OID और अगले (lexicographic क्रम में) का मूल्य प्राप्त करते हैं। इसका मतलब यह है कि तालिका स्तंभों के ओआईडी के उपसर्गों को पास करते हुए, हमें ओआईडी और इसकी पहली पंक्ति के मान मिलते हैं। अगली पंक्ति प्राप्त करने के लिए, आपको एक अन्य अनुरोध करने की आवश्यकता है, इसमें पिछले अनुरोध द्वारा प्राप्त ओआईडी को पारित करना होगा। और इसी तरह जब तक हम पूरी मेज पर नहीं दिखते।

बेशक, उपरोक्त सभी को ध्यान में रखते हुए, हमें प्रश्नों की संख्या कम से कम करनी चाहिए (यह भी आवश्यक है कि एक क्वेरी के भीतर, RFC के अनुसार, लगातार डेटा प्रदान किया जाता है, अगर हम लगातार दो प्रश्नों के साथ इंडेक्स और इंटरफ़ेस का नाम क्वेरी करते हैं, तो वे अनुरूप नहीं हो सकते हैं) एक दूसरे को)। एसएनएमपी के 1 संस्करण के ढांचे में, हमें एक क्वेरी के साथ तालिका की पूरी पंक्ति को पढ़ना चाहिए।

यह ध्यान दिया जाना चाहिए कि यह काफी सुविधाजनक है कि स्केलर चर के ओआईडी भी उपसर्ग हैं। उदाहरण के लिए, sysUpTime OID चर के लिए, यह वास्तव में 1.3.6.1.2.1.1.3 है। हम इसे GETNEXT के अनुरोध पर पास कर सकते हैं और संबंधित मूल्य के साथ OID = 1.3.6.1.2.1.1.3.0 प्राप्त कर सकते हैं। यह स्केलर मानों को एक साथ क्वेरी में तालिका स्तंभ मानों के साथ क्वेरी करना संभव बनाता है।

तालिका की पहली पंक्ति देखें

 package com.acme.ae.tests.snmp; import java.io.IOException; import java.util.HashSet; import java.util.Set; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.Target; import org.snmp4j.TransportMapping; import org.snmp4j.event.ResponseEvent; import org.snmp4j.event.ResponseListener; import org.snmp4j.mp.SnmpConstants; import org.snmp4j.smi.Address; import org.snmp4j.smi.GenericAddress; import org.snmp4j.smi.Integer32; import org.snmp4j.smi.OID; import org.snmp4j.smi.OctetString; import org.snmp4j.smi.VariableBinding; import org.snmp4j.transport.DefaultUdpTransportMapping; public class Test implements ResponseListener { private final static String SNMP_COMMUNITY = "public"; private final static int SNMP_RETRIES = 3; private final static long SNMP_TIMEOUT = 1000L; private Snmp snmp = null; private TransportMapping transport = null; private Set<Integer32> requests = new HashSet<Integer32>(); public void onResponse(ResponseEvent event) { Integer32 requestId = event.getRequest().getRequestID(); PDU response = event.getResponse(); if (response != null) { System.out.println(response.toString()); return; } else { synchronized (requests) { if (requests.contains(requestId)) { System.out.println("Timeout exceeded"); } } } synchronized (requests) { requests.remove(requestId); } } private void test() throws IOException { Target t = getTarget("udp:127.0.0.1/161"); send(t, new String[] {"1.3.6.1.2.1.1.3", "1.3.6.1.2.1.2.2.1.1", "1.3.6.1.2.1.2.2.1.2"}); } private void send(Target target, String[] oids) throws IOException { PDU pdu = new PDU(); for (String oid: oids) { pdu.add(new VariableBinding(new OID(oid))); } pdu.setType(PDU.GETNEXT); ResponseEvent event = snmp.send(pdu, target, null); synchronized (requests) { requests.add(pdu.getRequestID()); } onResponse(event); } private Target getTarget(String address) { Address targetAddress = GenericAddress.parse(address); CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(SNMP_COMMUNITY)); target.setAddress(targetAddress); target.setRetries(SNMP_RETRIES); target.setTimeout(SNMP_TIMEOUT); target.setVersion(SnmpConstants.version1); return target; } private void start() throws IOException { transport = new DefaultUdpTransportMapping(); snmp = new Snmp(transport); transport.listen(); } private void stop() throws IOException { try { if (transport != null) { transport.close(); transport = null; } } finally { if (snmp != null) { snmp.close(); snmp = null; } } } public static void main(String[] args) { Test t = new Test(); try { try { t.start(); t.test(); } finally { t.stop(); } } catch (IOException e) { System.out.println(e.toString()); } } }

इस कोड को चलाने से, हमें निम्नलिखित प्रतिक्रिया मिलती है:

 RESPONSE[requestID=1170688508, errorStatus=Success(0), errorIndex=0, VBS[1.3.6.1.2.1.1.3.0 = 4:50:53.72; 1.3.6.1.2.1.2.2.1.1.1 = 1; 1.3.6.1.2.1.2.2.1.2.1 = 4d:53:20:54:43:50:20:4c:6f:6f:70:62:61:63:6b:20:69:6e:74:65:72:66:61:63:65:00]]

हमें पहला मूल्य प्राप्त हुआ, पहला इंटरफ़ेस का सूचकांक और उसका नाम, हेक्साडेसिमल प्रतिनिधित्व में ओकटेट्स की एक स्ट्रिंग द्वारा एन्कोड किया गया। निम्नलिखित पंक्तियों को प्राप्त करने के लिए, हमें अनुक्रमिक अनुरोधों को निष्पादित करना चाहिए, पहले प्राप्त ओआईडी को पारित करना।

अतुल्यकालिक प्रसंस्करण की संभावना का समर्थन करने की आवश्यकता को देखते हुए, यह एक गैर-तुच्छ (लेकिन पूरी तरह से हल करने योग्य) कार्य बन सकता है। सौभाग्य से, एसएनएमपी थोक अनुरोधों के दूसरे संस्करण में सारणीबद्ध डेटा की प्राप्ति को स्वचालित करते हुए और भेजे गए अनुरोधों की संख्या को कम करते हुए जोड़ा गया था। कोड में आवश्यक परिवर्तन करें:

बल्क अनुरोध

 package com.acme.ae.tests.snmp; import java.io.IOException; import java.util.HashSet; import java.util.Set; import org.snmp4j.CommunityTarget; import org.snmp4j.PDU; import org.snmp4j.Snmp; import org.snmp4j.Target; import org.snmp4j.TransportMapping; import org.snmp4j.event.ResponseEvent; import org.snmp4j.event.ResponseListener; import org.snmp4j.mp.SnmpConstants; import org.snmp4j.smi.Address; import org.snmp4j.smi.GenericAddress; import org.snmp4j.smi.Integer32; import org.snmp4j.smi.OID; import org.snmp4j.smi.OctetString; import org.snmp4j.smi.VariableBinding; import org.snmp4j.transport.DefaultUdpTransportMapping; public class Test implements ResponseListener { private final static String SNMP_COMMUNITY = "public"; private final static int SNMP_RETRIES = 3; private final static long SNMP_TIMEOUT = 1000L; private final static int BULK_SIZE = 50; private Snmp snmp = null; private TransportMapping transport = null; private Set<Integer32> requests = new HashSet<Integer32>(); public void onResponse(ResponseEvent event) { Integer32 requestId = event.getRequest().getRequestID(); PDU response = event.getResponse(); if (response != null) { System.out.println(response.toString()); return; } else { synchronized (requests) { if (requests.contains(requestId)) { System.out.println("Timeout exceeded"); } } } synchronized (requests) { requests.remove(requestId); } } private void test() throws IOException { Target t = getTarget("udp:127.0.0.1/161"); send(t, new String[] {"1.3.6.1.2.1.1.3", "1.3.6.1.2.1.2.2.1.1", "1.3.6.1.2.1.2.2.1.2"}); } private void send(Target target, String[] oids) throws IOException { PDU pdu = new PDU(); for (String oid: oids) { pdu.add(new VariableBinding(new OID(oid))); } pdu.setType(PDU.GETBULK); pdu.setMaxRepetitions(BULK_SIZE); pdu.setNonRepeaters(1); ResponseEvent event = snmp.send(pdu, target, null); synchronized (requests) { requests.add(pdu.getRequestID()); } onResponse(event); } private Target getTarget(String address) { Address targetAddress = GenericAddress.parse(address); CommunityTarget target = new CommunityTarget(); target.setCommunity(new OctetString(SNMP_COMMUNITY)); target.setAddress(targetAddress); target.setRetries(SNMP_RETRIES); target.setTimeout(SNMP_TIMEOUT); target.setVersion(SnmpConstants.version2c); return target; } private void start() throws IOException { transport = new DefaultUdpTransportMapping(); snmp = new Snmp(transport); transport.listen(); } private void stop() throws IOException { try { if (transport != null) { transport.close(); transport = null; } } finally { if (snmp != null) { snmp.close(); snmp = null; } } } public static void main(String[] args) { Test t = new Test(); try { try { t.start(); t.test(); } finally { t.stop(); } } catch (IOException e) { System.out.println(e.toString()); } } }

इस क्वेरी को निष्पादित करने के बाद, हमें एक क्वेरी के साथ तालिका की सभी पंक्तियाँ मिलती हैं:

बहुत सारा डेटा

 RESPONSE[requestID=1801703572, errorStatus=Success(0), errorIndex=0, VBS[1.3.6.1.2.1.1.3.0 = 4:58:44.56; 1.3.6.1.2.1.2.2.1.1.1 = 1; 1.3.6.1.2.1.2.2.1.2.1 = 4d:53:20:54:43:50:20:4c:6f:6f:70:62:61:63:6b:20:69:6e:74:65:72:66:61:63:65:00; 1.3.6.1.2.1.2.2.1.1.2 = 2; 1.3.6.1.2.1.2.2.1.2.2 = 56:4d:77:61:72:65:20:56:69:72:74:75:61:6c:20:45:74:68:65:72:6e:65:74:20:41:64:61:70:74:65:72:20:66:6f:72:20:56:4d:6e:65:74:38:00; 1.3.6.1.2.1.2.2.1.1.3 = 3; 1.3.6.1.2.1.2.2.1.2.3 = 56:4d:77:61:72:65:20:56:69:72:74:75:61:6c:20:45:74:68:65:72:6e:65:74:20:41:64:61:70:74:65:72:20:66:6f:72:20:56:4d:6e:65:74:31:00; 1.3.6.1.2.1.2.2.1.1.65541 = 65541; 1.3.6.1.2.1.2.2.1.2.65541 = 52:65:61:6c:74:65:6b:20:52:54:4c:38:31:36:38:2f:38:31:31:31:20:50:43:49:2d:45:20:47:69:67:61:62:69:74:20:45:74:68:65:72:6e:65:74:20:4e:49:43:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.1.65542 = 65542; 1.3.6.1.2.1.2.2.1.2.65542 = 4e:6f:72:74:65:6c:20:49:50:53:45:43:53:48:4d:20:41:64:61:70:74:65:72:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.1.65543 = 65543; 1.3.6.1.2.1.2.2.1.2.65543 = 4e:6f:72:74:65:6c:20:56:50:4e:20:41:64:61:70:74:65:72:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.2.1 = 4d:53:20:54:43:50:20:4c:6f:6f:70:62:61:63:6b:20:69:6e:74:65:72:66:61:63:65:00; 1.3.6.1.2.1.2.2.1.3.1 = 24; 1.3.6.1.2.1.2.2.1.2.2 = 56:4d:77:61:72:65:20:56:69:72:74:75:61:6c:20:45:74:68:65:72:6e:65:74:20:41:64:61:70:74:65:72:20:66:6f:72:20:56:4d:6e:65:74:38:00; 1.3.6.1.2.1.2.2.1.3.2 = 6; 1.3.6.1.2.1.2.2.1.2.3 = 56:4d:77:61:72:65:20:56:69:72:74:75:61:6c:20:45:74:68:65:72:6e:65:74:20:41:64:61:70:74:65:72:20:66:6f:72:20:56:4d:6e:65:74:31:00; 1.3.6.1.2.1.2.2.1.3.3 = 6; 1.3.6.1.2.1.2.2.1.2.65541 = 52:65:61:6c:74:65:6b:20:52:54:4c:38:31:36:38:2f:38:31:31:31:20:50:43:49:2d:45:20:47:69:67:61:62:69:74:20:45:74:68:65:72:6e:65:74:20:4e:49:43:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.3.65541 = 6; 1.3.6.1.2.1.2.2.1.2.65542 = 4e:6f:72:74:65:6c:20:49:50:53:45:43:53:48:4d:20:41:64:61:70:74:65:72:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.3.65542 = 6; 1.3.6.1.2.1.2.2.1.2.65543 = 4e:6f:72:74:65:6c:20:56:50:4e:20:41:64:61:70:74:65:72:20:2d:20:44:65:74:65:72:6d:69:6e:69:73:74:69:63:20:4e:65:74:77:6f:72:6b:20:45:6e:68:61:6e:63:65:72:20:4d:69:6e:69:70:6f:72:74:00; 1.3.6.1.2.1.2.2.1.3.65543 = 6; 1.3.6.1.2.1.2.2.1.3.1 = 24; 1.3.6.1.2.1.2.2.1.4.1 = 1520; 1.3.6.1.2.1.2.2.1.3.2 = 6; 1.3.6.1.2.1.2.2.1.4.2 = 1500; 1.3.6.1.2.1.2.2.1.3.3 = 6; 1.3.6.1.2.1.2.2.1.4.3 = 1500; 1.3.6.1.2.1.2.2.1.3.65541 = 6; 1.3.6.1.2.1.2.2.1.4.65541 = 1500; 1.3.6.1.2.1.2.2.1.3.65542 = 6; 1.3.6.1.2.1.2.2.1.4.65542 = 1402; 1.3.6.1.2.1.2.2.1.3.65543 = 6; 1.3.6.1.2.1.2.2.1.4.65543 = 1376; 1.3.6.1.2.1.2.2.1.4.1 = 1520; 1.3.6.1.2.1.2.2.1.5.1 = 10000000; 1.3.6.1.2.1.2.2.1.4.2 = 1500; 1.3.6.1.2.1.2.2.1.5.2 = 100000000; 1.3.6.1.2.1.2.2.1.4.3 = 1500; 1.3.6.1.2.1.2.2.1.5.3 = 100000000; 1.3.6.1.2.1.2.2.1.4.65541 = 1500; 1.3.6.1.2.1.2.2.1.5.65541 = 100000000; 1.3.6.1.2.1.2.2.1.4.65542 = 1402; 1.3.6.1.2.1.2.2.1.5.65542 = 10000000; 1.3.6.1.2.1.2.2.1.4.65543 = 1376; 1.3.6.1.2.1.2.2.1.5.65543 = 10000000; 1.3.6.1.2.1.2.2.1.5.1 = 10000000; 1.3.6.1.2.1.2.2.1.6.1 = ; 1.3.6.1.2.1.2.2.1.5.2 = 100000000; 1.3.6.1.2.1.2.2.1.6.2 = 00:50:56:c0:00:08; 1.3.6.1.2.1.2.2.1.5.3 = 100000000; 1.3.6.1.2.1.2.2.1.6.3 = 00:50:56:c0:00:01; 1.3.6.1.2.1.2.2.1.5.65541 = 100000000; 1.3.6.1.2.1.2.2.1.6.65541 = 00:18:f3:08:06:13; 1.3.6.1.2.1.2.2.1.5.65542 = 10000000; 1.3.6.1.2.1.2.2.1.6.65542 = 44:45:53:54:42:00; 1.3.6.1.2.1.2.2.1.5.65543 = 10000000; 1.3.6.1.2.1.2.2.1.6.65543 = 00:ff:97:65:06:be; 1.3.6.1.2.1.2.2.1.6.1 = ; 1.3.6.1.2.1.2.2.1.7.1 = 1; 1.3.6.1.2.1.2.2.1.6.2 = 00:50:56:c0:00:08; 1.3.6.1.2.1.2.2.1.7.2 = 1; 1.3.6.1.2.1.2.2.1.6.3 = 00:50:56:c0:00:01; 1.3.6.1.2.1.2.2.1.7.3 = 1; 1.3.6.1.2.1.2.2.1.6.65541 = 00:18:f3:08:06:13; 1.3.6.1.2.1.2.2.1.7.65541 = 1; 1.3.6.1.2.1.2.2.1.6.65542 = 44:45:53:54:42:00; 1.3.6.1.2.1.2.2.1.7.65542 = 1; 1.3.6.1.2.1.2.2.1.6.65543 = 00:ff:97:65:06:be; 1.3.6.1.2.1.2.2.1.7.65543 = 1; 1.3.6.1.2.1.2.2.1.7.1 = 1; 1.3.6.1.2.1.2.2.1.8.1 = 1; 1.3.6.1.2.1.2.2.1.7.2 = 1; 1.3.6.1.2.1.2.2.1.8.2 = 1; 1.3.6.1.2.1.2.2.1.7.3 = 1; 1.3.6.1.2.1.2.2.1.8.3 = 1; 1.3.6.1.2.1.2.2.1.7.65541 = 1; 1.3.6.1.2.1.2.2.1.8.65541 = 1; 1.3.6.1.2.1.2.2.1.7.65542 = 1; 1.3.6.1.2.1.2.2.1.8.65542 = 1; 1.3.6.1.2.1.2.2.1.7.65543 = 1; 1.3.6.1.2.1.2.2.1.8.65543 = 2; 1.3.6.1.2.1.2.2.1.8.1 = 1; 1.3.6.1.2.1.2.2.1.9.1 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.8.2 = 1; 1.3.6.1.2.1.2.2.1.9.2 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.8.3 = 1; 1.3.6.1.2.1.2.2.1.9.3 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.8.65541 = 1; 1.3.6.1.2.1.2.2.1.9.65541 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.8.65542 = 1; 1.3.6.1.2.1.2.2.1.9.65542 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.8.65543 = 2; 1.3.6.1.2.1.2.2.1.9.65543 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.9.1 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.10.1 = 3542209; 1.3.6.1.2.1.2.2.1.9.2 = 0:00:00.00; 1.3.6.1.2.1.2.2.1.10.2 = 40700]]

बेशक, यदि तालिका में 50 से अधिक अनुरोधित लाइनें शामिल हैं, फिर से (एसएनएमपी के 1 संस्करण के लिए), तो अगली पंक्तियों को प्राप्त करने के लिए क्वेरीज़ बनाना आवश्यक होगा, उनमें अंतिम पंक्ति के लिए प्राप्त ओआईडी पास होगा।

मैं क्या बात नहीं करता था?

इस लेख में मैंने बहुत बात नहीं की। मैंने SET प्रश्नों के साथ कुछ (सभी नहीं) चर के मूल्यों को बदलने के बारे में बात नहीं की। मैंने इस बारे में बात नहीं की कि TRAP क्या हैं और उनकी आवश्यकता क्यों है। मैंने एक शब्द भी नहीं कहा कि एसएनएमपी एजेंटों को कैसे विकसित किया जाए। और मैंने एसएनएमपी के तीसरे संस्करण के बारे में एक भी शब्द का उल्लेख नहीं किया है और इसके लिए शुरू किए गए परिवर्तन।

लेकिन यहां तक कि मैंने जो कहा वह यह समझने के लिए पर्याप्त है कि एसएनएमपी आसान नहीं है।

मुद्दे के लिए एक गंभीर दृष्टिकोण के साथ।