2.1절. 준비사항

먼저 접근할수 있는 SNMP agent가 준비되어 있어야 한다. 자신의 호스트에 설치되어 있다면 테스트하기 편하겠지만 , 자신의 호스트에 설치되어 있지 않다고 하더라도 접근할수 있는 snmp agent가 설치된 호스트가 있으면 관계없다.

이책의 모든 내용은 기본적으로 ucd snmp 4.x를 기준으로 작성되어있다. ucd snmp의 설치와 운영방법에 대해서는 SNMP개요및 설치,운용기사를 참고하기 바란다.

여러분이 ucd snmp를 성공적으로 설치했다면, snmp개발 라이브러리와 헤더파일들이 설치될 것이다. snmp애플리케이션을 만들기 위해서는 이들 라이브러리와 헤더파일의 위치를 알고 있어야 한다. ucd snmp를 컴파일할때, --prefix 옵션을 사용하지 않았다면, 기본설치디렉토리인 /usr/loca/lib, /usr/local/include/ucd-snmp에 설치될것이다. 각자 확인해보기 바란다.

2.2절. 예제프로그램을 통한 이해

앞서 이 문서는 tutorial형식을 따른다고 했음으로, 우선 간단한 예제프로그램을 만들어보고, 예제프로그램을 설명하는 식으로 snmp플밍에 대해서 알아보도록 하겠다.

우리가 만들고자 하는 애플리케이션은 인자로 OID를 주면 agent로 연결해서 OID에 대한 값을 가져오는 프로그램으로 가장단순하지만 snmp플밍의 기본적인 골격을 가지고 있음으로 이 예제를 잘 이해하게 되면 다른 응용도 가능할것이다.

예제 : simple_snmp.cc

/* * 이 애플리케이션은 snmp1 snmp2를 기준으로 * 작성한다. * ucd-snmp 헤더파일들을 인클루드 시킨다. * 아규먼트로 MID이름 혹은 대응되는 OID이름을 입력받는다. */ #include <ucd-snmp/ucd-snmp-config.h> #include <ucd-snmp/ucd-snmp-includes.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> int main(int argc, char **argv) { struct snmp_session session, *ss; struct snmp_pdu *pdu; struct snmp_pdu *response; oid anOID[MAX_OID_LEN]; size_t anOID_len = MAX_OID_LEN; struct variable_list *vars; int status; if (argc < 2) { printf("Usage : simple_snmp OID\"); exit(0); } /* */ init_snmp("snmpapp"); /* * session을 초기화 한다. 우리는 만들어진 세션을 이용해서 * 필요한 작업을 하게 된다. * 세션을 만들기 위해서 SNMP기본정보인, * 호스트이름, 커뮤니케이션, 버젼정보들을 입력한다. */ snmp_sess_init(&session); session.peername = "localhost"; session.version = SNMP_VERSION_2c; session.community = "public"; session.community_len = strlen(session.community); /* * 위의 초기화 정보를 토대로 * 세션을 연다 */ SOCK_STARTUP; ss = snmp_open(&session); if (!ss) { snmp_perror("ack"); exit(0); } /* 요청을 위한 PDU를 만든다. * PDU에 대한 내용은 이미 앞전의 기사에서 * 설명했음으로 참고하기 바란다. */ pdu = snmp_pdu_create(SNMP_MSG_GET); read_objid(argv[1], anOID, &anOID_len); snmp_add_null_var(pdu, anOID, anOID_len); /* * 만들어진 요청을 보낸다. * 함수이름에서 알수 있듯이 동기요청이다. * 즉 응답이 올때까지 기다린다. * 물론 비동기 요청도 있다. * 해당 세션으로 pdu를 보내고 response로 응답을 * 받아온다. */ status = snmp_synch_response(ss, pdu, &response); /* * 리턴값이 넘어왔다면.. * 값을 검사한다. */ if (status == STAT_SUCCESS && response->errstat == SNMP_ERR_NOERROR) { int count = 1; /* * 읽어온 정보를 분석해서 출력한다. */ for (vars = response->variables; vars; vars = vars->next_variable) { char *sp = (char *)malloc(1 + vars->val_len); memcpy(sp, vars->val.string, vars->val_len); sp[vars->val_len] = ' '; /* * 따로 설명할건데, * 응답은 자신의 고유타입을 가지고 있다. * 즉 일반 스트링인지, 숫자인지, 시간관련된 * 값인지에 대한 정보를 가지고 있다. * 그럼으로 타입에 따라서 처리방법을 달리해야 한다. */ switch(vars->type) { case ASN_OCTET_STR: { printf("value #%d is a string: %s\", count++, sp); break; } case ASN_GAUGE: case ASN_COUNTER: case ASN_TIMETICKS: case ASN_INTEGER: { int a; memcpy((void *)&a, sp, 4); printf("value #%d is a INTEGER: %d\", count++, a); break; } case ASN_IPADDRESS: { int a; struct in_addr st_addr; memcpy((void *)&a, sp, 4); st_addr.s_addr = a; printf("value #%d is a IPADDR: %s\", count++, inet_ntoa(st_addr)); break; } } free(sp); } } else { if (status == STAT_SUCCESS) { fprintf(stderr, "Err : %s\", snmp_errstring(response->errstat)); } else { snmp_sess_perror("snmpget", ss); } } if (response) { snmp_free_pdu(response); } snmp_close(ss); }

코드자체를 이해하는 데에는 별어려움이 없을것이다. 위의 snmp응용 애플리케이션을 제작하는 전형적인 모습을 보여준다.

1. 즉 가정 먼저 snmp agent(이하 에이전트)와 연결을 맺기 위한 세션초기화 작업 으로 여기에는 호스트이름과, 커뮤니티이름, 그리고 SNMP버젼정보가 들어가게 된다. SNMP버젼은 다음과 같이 준비되어 있다.

   표 1. SNMP 버젼 정의 상수

   SNMP_VERSION_1	snmp 버젼 1
   SNMP_VERSION_2c	snmp 버젼 2
   SNMP_VERSION_2u	정의만되어 있고 사용되어지지는 않는다.
   SNMP_VERSION_3	snmp 버젼 3

   세션을 맺고자 하는 에이전트의 snmp 버젼지원여부와 어느 버젼에서 지원하는 snmp정보를 가지고 올것인지를 확인해서 적당한 버젼으로 선택하면 된다. 보통 SNMP_VERSION_1 혹은 SNMP_VERSION_2c를 사용하면 문제없으며, SNMP_VERSION_2c를 사용하는게 가장무난하다. snmp3에서 포함하는 다른기능들(보안문제, 혹은 확장된 다른정보들)을 이용하지 않는다면 SNMP_VERSION_2c를 사용하도록 하자.

   snmp_sess_init()함수를 사용한다.

2. 위에서 만든 세션정보를 사용해서 세션을 연다(open).

   snmp_open()함수를 사용한다.

3. 여러분이 에이전트로 부터 정보를 요청하기 위해서는 PDU를 작성해야한다. PDU에는 요청하고자 하는 정보의 OID, 요청종류(GET, GET NEXT, SET등)를 명시해야만 한다.

   사용되는 함수는 snmp_pdu_create()와 read_objid()가 있다.

4. PDU를 작성했다면, 이제 에이전트측에 SNMP요청(패킷)을 보내야 할것이다. 요청을 위해서 snmp_synch_response()함수가 제공된다. 이것은 동기적인 요청을 위해서 사용한다. 비동기적으로 요청할수도 있는데, 이것은 따로 언급하도록 하겠다.

5. 응답이 왔다면 응답데이타를 분석해야 할것이다. 응답데이타는 snmp_pdu 구조체형태로 넘어오게 된다. 응답데이타를 분석할때 중요한 것은 바로 데이타의 타입정보이다. snmp정보를 보면 어떤것은 일반 문자열인 반면 어떤것은 숫자, 혹은 시간등의 정보를 가진다. 이의 구분을 위해서 snmp_pdu구조체에는 해당 데이타의 타입정보를 가지는 변수가 지정되어 있다. 주로 사용되어지는 데이타타입에는 다음과 같은것들이 있다.

   표 2. SNMP 데이타 타입

   ASN_OCTET_STR	일반 문자열
   ASN_GAUGE	unsigned 32bit int
   ASN_INTEGER	signed 32bit int
   ASN_IPADDRESS	32bit 인터넷주소
   ASN_COUNTER	unsigned 32bit int
   ASN_TIMETICKS	unsigned 32bit int
   ASN_OID	OID 문자열

 
[root@localhost test]# ./snmp3 system.sysUpTime.0
value #1 is a INTEGER: 32172
			

이제 위의 예제프로그램을 컴파일하고 본격적인 테스트 해보도록 하자. 컴파일은 다음과 같이 하면된다.

[root@localhost test]# gcc -o simple_snmp simple_snmp.c -I/usr/local/include/ucd-snmp -lsnmp -lcrypto

다음은 테스트 결과이다. 중간중간에 결과에 대한 설명을 달아놓았으니 참고하기 바란다.

# 인터페이스 주소가져오기 [root@localhost test]# ./simple_snmp ip.ipAddrTable.ipAddrEntry.ipAdEntAddr.192.168.100.130 value #1 is a IPADDR: 192.168.100.130 # 2번 인터페이스(eth0)에 대한 MTU사이즈 가져오기 # .2 대신에 .1을 사용할경우 1번 인터페이스(loopback)에 대한 MTU사이즈를 # 얻어올수 있다. [root@localhost test]# ./simple_snmp interfaces.ifTable.ifEntry.ifMtu.2 value #1 is a INTEGER: 1500 # 2번 인터페이스를 통해 바깥으로 전송된 패킷의 갯수 [root@localhost test]# ./simple_snmp interfaces.ifTable.ifEntry.ifOutOctets.2 value #1 is a INTEGER: 1192344 # 시스템부팅후 경과시간 [root@localhost test]# ./simple_snmp system.sysUpTime.0 value #1 is a INTEGER: 166258 # 2번 인터페이스의 속도 # 10Mbps 랜임을 알수 있다. [root@localhost test]# ./simple_snmp interfaces.ifTable.ifEntry.ifSpeed.2 value #1 is a INTEGER: 10000000

테스트를 위해서 어떤 MIB(OID)가 필요한지 잘 모르겠다면, ucd-snmp에서 제공하는 메니저 프로그램중 snmpwalk를 이용해서 정보를 요청해서 이걸 파일등으로 저장한후 참고하면 된다.

[root@localhost test]# snmpwalk localhost public > snmp_info.dump

snmpwalk 는 GET NEXT를 이용하며 위의 경우 MIB이름을 지정하지 않았음으로 root노드를 지정했다고 간주하고 모든 MIB데이타를 긁어온다. 만약 system하위에 있는 데이타들을 요청한다면 public 다음에 system을 지정해 주면 될것이다.

만약 외부로 나가는 패킷의 양(트래픽)을 검사하길 원한다면 일정시간간격으로 "interfaces.ifTable.ifEntry.ifOutOctets.2" 정보를 요청해서 통계를 내면 된다. 이런식으로 해서 최소한의 네트워크 관리를 위한 정보수집이 가능해 진다.

2.3절. 다른 예제 : 비동기 데이타 요청

우리는 2.2절에서 snmp응용 애플리케이션을 만들기 위한 기본적인 내용들에 대해서 알아보았다. 위에서 만들어진 예제프로그램은 동기형식을 가진다. 즉 요청을 보내고 응답이 있을때까지 해당영역에서 블럭킹되는데, 이러한 모델은 단지 몇개의 에이전트로 부터 데이타를 받을 경우 문제가 없지만, 여러개의 에이전트로부터 데이타를 받을 경우 문제의 소지가 있다. NMS의 특성상 다수의 에이전트를 하나의 메니저에서 관리해야하는 경우가 많음으로 동기모델로 메니저프로그램을 만드는것은 아무래도 문제가 있어보인다.

이러한 문제의 해결을 위해서 ucd-snmp는 비동기모델로 메니저를 작성할수 있도록 방법을 제공하고 있다. 언뜻 생각해도 udp를 사용하는 snmp에는 비동기모델의 어플리케이션이 더 어울릴거라고 생각할수 있다.

다음은 예제이다. 특별히 어려워보이는 건 없을것이다. 내용에 대한 설명은 주석으로 대신한다.

asynch_snmp.c

#include <ucd-snmp/ucd-snmp-config.h> #include <ucd-snmp/ucd-snmp-includes.h> #include <stdio.h> /* * 에이전트 호스트 정보 * 호스트 이름과 커뮤니티 이름을 정의한다. */ struct host { const char *name; const char *community; } hosts[] = { {"localhost", "public"}, {NULL} }; /* * 가져오고자 하는 oid를 정의 한다. * 여기에서는 시스템 uptime과, * eth0의 스피드(10Mbps) * 외부로 나간 패킷의 갯수를 얻어오기 위한 oid를 정의 했다. */ struct oid { const char *name; oid Oid[MAX_OID_LEN]; int OidLen; } oids[] = { {"system.sysUpTime.0"}, {"interfaces.ifTable.ifEntry.ifSpeed.2"}, {"interfaces.ifTable.ifEntry.ifOutOctets.2"}, {NULL} }; /* * snmp 초기화 * snmp를 초기화 하고 * oid이름을 읽어들인다. * 만약 oid이름에 문제가 있다면 오류를 발생시킬 것이다. */ void initialize(void) { struct oid *op = oids; init_snmp("asynchapp"); while(op->name) { op->OidLen = sizeof(op->Oid)/sizeof(op->Oid[0]); if (!read_objid(op->name, op->Oid, &op->OidLen)) { snmp_perror("read_objid"); exit(1); } op++; } } /* * 에이전트로 부터 넘어온 값을 출력한다. */ int print_result(int status, struct snmp_session *sp, struct snmp_pdu *pdu) { char buf[1024]; struct variable_list *vp; int ix; struct timeval now; struct timezone tz; struct tm *tm; /* * 최근의 프로그램들은 * time함수 gettimeofday를 선호한다. */ gettimeofday(&now, &tz); tm = localtime(&now.tv_sec); fprintf(stdout, "%.2d:%.2d:%.2d.%.6d ", tm->tm_hour, tm->tm_min, tm->tm_sec, now.tv_usec); switch(status) { /* * 에이전트로부터 넘어온 값을 출력한다. */ case STAT_SUCCESS: vp = pdu->variables; if (pdu->errstat == SNMP_ERR_NOERROR) { while(vp) { snprint_variable(buf, sizeof(buf), vp->name, vp->name_length, vp); fprintf(stdout, "%s: %s\", sp->peername, buf); vp = vp->next_variable; } } else { printf("error\"); } return 1; /* * 네트워크혹은 다른 문제로 에이전트로 부터 응답이 * 발생하지 않았을경우 */ case STAT_TIMEOUT: fprintf(stdout, "%s: Timeout\", sp->peername); return 0; case STAT_ERROR: snmp_perror(sp->peername); return 0; } return 0; } /* * snmp oid 세션을 만든다. 크기는 에이전트의 갯수만큼이다. */ struct session { struct snmp_session *sess; struct oid *current_oid; } sessions[sizeof(hosts)/sizeof(hosts[0])]; int active_hosts; /* * 에이전트로부터의 비동기 응답을 받았을경우 * 이를 처리한다. * 결과가 넘어온다면 print_result함수를 호출해서 * 결과를 출력한다. * 이 함수는 callback형식으로 호출되는데, * 즉 임의의 에이전트로부터 데이타입력이 있을경우 호출되는 형식이다. */ int asynch_response(int operation, struct snmp_session *sp, int reqid, struct snmp_pdu *pdu, void *magic) { struct session *host = (struct session *)magic; struct snmp_pdu *req; /* * 만약 operation이 데이타 받음이라면 * print_result를 호출해서 데이타를 출력한다. */ if (operation == RECEIVED_MESSAGE) { if (print_result(STAT_SUCCESS, host->sess, pdu)) { host->current_oid++; if (host->current_oid->name) { req = snmp_pdu_create(SNMP_MSG_GET); snmp_add_null_var(req, host->current_oid->Oid, host->current_oid->OidLen); if (snmp_send(host->sess, req)) { return 1; } else { snmp_perror("snmp_send"); snmp_free_pdu(req); } } } } else { print_result(STAT_TIMEOUT, host->sess, pdu); } active_hosts--; return 1; } /* * snmp session을 만들고 * 비동기로 결과를 받기 위해서 callback 함수를 등록시킨다. */ void asynchronous(void) { struct session *hs; struct host *hp; for (hs = sessions, hp = hosts; hp->name; hs++, hp++) { /* * 여기는 동기형식과 마찬가지로 단지 snmp세션을 * 만들기 위한 정보를 입력한다. */ struct snmp_pdu *req; struct snmp_session sess; snmp_sess_init(&sess); sess.version = SNMP_VERSION_2c; sess.peername = strdup(hp->name); sess.community = strdup(hp->community); sess.community_len = strlen(sess.community); // 바로 여기 callback 함수를 등록한다. sess.callback = asynch_response; sess.callback_magic = hs; if (!(hs->sess = snmp_open(&sess))) { snmp_perror("snmp_open"); continue; } hs->current_oid = oids; req = snmp_pdu_create(SNMP_MSG_GET); snmp_add_null_var(req, hs->current_oid->Oid, hs->current_oid->OidLen); /* * 비동기이기 때문에 snmp데이타를 보내고.. * 응답을 기다리기 위해서 블럭되지 않도록 한다. */ if (snmp_send(hs->sess, req)) { active_hosts++; } else { snmp_perror("snmp_send"); snmp_free_pdu(req); } } /* * 비동기 데이타 입력을 확인하기 위해서 * select를 이용한다. * 호스트의 갯수만틈을 select를 통해 기다린다. */ while(active_hosts) { int fds = 0, block = 1; fd_set fdset; struct timeval timeout; FD_ZERO(&fdset); snmp_select_info(&fds, &fdset, &timeout, &block); fds = select(fds, &fdset, NULL, NULL, block ? NULL : &timeout); if (fds) { snmp_read(&fdset); } else { snmp_timeout(); } } for (hp = hosts, hs = sessions; hp->name; hs++, hp++) { if(hs->sess) snmp_close(hs->sess); } } int main() { initialize(); asynchronous(); }

여러개의 에이전트를 등록시켜서 테스트할수 있었으면 했으나 사용할 에이전트가 한정된 관계로 하나의 에이전트만을 등록시켜서 테스트했다. 다음은 테스트 결과이다.

만약 에이전트가 실행중이지 않다면 타임아웃 에러가 발생할 것이다.

[root@localhost c_source]# ./snmp_as 23:54:48.463404 localhost: Timeout

에이전트가 실행중이라면 값을 가져오게 될것이다.

[root@localhost c_source]# ./snmp_as 23:55:55.536827 localhost: system.sysUpTime.0 = Timeticks: (6401) 0:01:04.01 23:55:55.539176 localhost: interfaces.ifTable.ifEntry.ifSpeed.2 = Gauge32: 10000000 23:55:55.540540 localhost: interfaces.ifTable.ifEntry.ifOutOctets.2 = Counter32: 4236