만물의 근원은 불 - 헤라클레이토스(Herakleiros)

ACE_SOCK_Dgram
WikiCategory
�ڽŸ�� SSL CA �� ġ�ϱ�
luabind/Ʃ�丮��

ACEƩ�丮��002/��Ѽ��

1 시작하며
2 다시 메인 함수
3 Logging_Handler
4 마치며

[edit]

1 시작하며 #

이 튜토리얼에서는, 우리는 처음 튜토리얼에서 배웠던 작은 서버 하나와 몇가지 추가적인 것들을 빌드할 것이다. 이 글 마지막에는 더 괜찮은 서버 객체를 만들 것이다. 이것은 더 단순하고 이전에 만들었던 것보다 더 관리하기가 쉬운 것이다.

시작하기전에 우리 자신에게 튜토리얼 1에서 했던 질문을 다시 해보자 :

서버를 생성하는 데 필요한 것은 무엇인가?

클라이언트들로부터 접속을 받아들이는(accept) 어떤 것
설치된 접속들을 제어하는 어떤 것
이것들 모두를 제어하는 메인 프로그램 루프

이전에는, 위 질문들을 나타내는 솔루션을 각각 개별적으로 만들었다. 모든 작업이 끝난 후, 어플리케이션 관련 코드는 프로그램의 핸들러부분에만 제한되어있다는 것을 실감했을 것이다. 여기서, 이 접근을 파헤쳐보자.

[edit]

2 다시 메인 함수 #

튜토리얼 1과 같이, 이것 또한 정말로 작은 프로그램이다. 나는 새로운 아이디어를 도입해 붙일 것이지만 이것은 또한 acceptor를 단순화시키기 위해 치장하는 것이라 생각하면 된다.

Kirthika의 개요는 다음과 같다 :

이것은 ACE의 쉽게 구할 수 있는 컴퍼넌트와 클래스들을 사용함으로써 더욱 단순하게 만들어진 서버 예제이다. 여기, Logging_Acceptor는 ACE_SOCK_ACCEPTOR와 Logging_Handler와 결합된 ACE_Acceptor 클래스이다. 이것은 이제 reactor 인스턴스를 open시키고 건네받아진 클라이언트로부터의 접속을 accept할 것이다. 또한 ACE_SigAction와 ACE_SignalHandler를 사용해서 CTRL-C를 가로채기 위해서(이것은 SIGINT를 발생시킨다) 시그널을 구현할 것이다. 이 시그널은 reactor가 이벤트를 다루는 것을 멈추게 하는데 사용될 수 있다.

이제, reactor는 CTRL+C를 사용해서 shutdown될 때까지 무한 루프를 돌아도 된다. (CTRL+C는 reactor와 acceptor 양쪽다 파괴된 후에 발생한다)

Logging_Handler는 Event_Handler대신에 ACE_Svc_Handler에서 상속을 받는다. 왜냐하면 Svc_Handler는 SOCK_Stream을 내장하고 있고 reactor가 요구하는 모든 호출을 제공하기 때문이다. Svc_Handler는 이벤트에 반응할 수 있는 능력을 가지고 있고 숨겨져있는 데이타 스트림을 사용해서 해당 업무를 조종할 수 있도록 통신할 수 있다.

timer는 아무 것도 하지 않지만 간단하게 주기적인 처리가 필요할 때마다 사용되는 것을 보여주는 reactor에 의해 스케줄된다. ACE_TimeValue는 시간 주기를 설정하는 데 사용된다.

또한, 최적화는 사용한 객체를 파괴해주는 별도의 함수의 형태로 만들어져있다.

따라서 "더욱 간단한" 서버는 이제 구축되었다. 어떻게 작업을 간단하게 하는지를 성공적으로 보여주고, 다양한 ACE 컴퍼넌트를 판단에 맞게 사용하게 된 예라고 할 수 있다.

서버 메인 부분 프로그램(server.cpp)을 찾아보는 것으로 시작해보자:

// $Id: ACE_c6_a9_c5_e4_b8_ae_be_f3002_2f_b4_f5_bf_ed_b0_a3_b4_dc_c7_d1_bc_ad_b9_f6,v 1.1 2004/05/20 12:24:46 redpixel Exp redpixel $

/* 이전의 예처럼, Logging_Handler를 선언하는데 있어 몇가지 ACE
  객체들이 필요하다. */
#include "ace/Acceptor.h"
#include "ace/SOCK_Acceptor.h"
#include "ace/Reactor.h"
#include "handler.h"

/* 우리는 아직 전역 reactor 포인터를 사용하고 있다. 이것에 대한 좀더 톡쏘는
   방법은 차후의 서버 튜토리얼에서 보여주도록 하겠다.*/
ACE_Reactor *g_reactor;

/* 이것은 튜토리얼 1에서 힌트를 주었었다. 하드코딩된 acceptor를 우리가 만들었던
  것을 기억하는가? 이 템플릿 코드는 모든 일을 해주며 되려 더 많은 일을 한다.
  만약 여러분의 어플리케이션의 부분이라고 느껴지지않는 코드를 만들고 있다는 것을
  깨달았다면, ACE가 여러분을 위해 그런 일을 해줄 템플릿 또는 프레임워크 컴퍼넌트를
  가지고 있다는 것은 좋은 일일 것이다. */
typedef ACE_Acceptor <Logging_Handler, ACE_SOCK_ACCEPTOR> Logging_Acceptor;

/* 새로 추가된 것들중 하나는 시그널 핸들러이다. 이것은 깔끔하게 서버가 종료할 수
  있도록 해준다. "finished" flag은 이전의 무한루프 대신에 사용된다. 그리고
  "handler"는 SIGINT(CTRL-C)에 응답하여 그 flag을 설정한다. {{{ACE_Reactor::notify()

의

실행은 handle_events()가 return하는 결과를 만들며, "finished"변수의 값이 바뀐 것을 알수 있게 된다. */

static sig_atomic_t finished = 0; extern "C" void handler (int) {

finished = 1; g_reactor->notify();

}

static const u_short PORT = ACE_DEFAULT_SERVER_PORT;

int main (int, char **) {

// 상속받은 이벤트 핸들러를 등록할 reactor를 생성한다. ACE_NEW_RETURN (g_reactor, ACE_Reactor, 1);

// 클라이언트 접속을 listen할 acceptor를 생성한다. Logging_Acceptor peer_acceptor;

/* 튜토리얼 1의 open()을 호출한 것과 비슷하는 점을 주목하라. 이전 것을

읽어보고 이 방법으로 하기로 했다.(-_-a 번역이...원문 : I read ahead when I created that one so that it would come out this way... */

if (peer_acceptor.open (ACE_INET_Addr (PORT), g_reactor) == -1)

ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1);

/* 여기에 어플리케이션에 시그널들에 응답하는 가장 쉬운 방법이 있다.

단순히 가로챌 시그널과 "C" 함수를 가지고 ACE_Sig_Action을 구축하면 된다. 예측했겠지만, reactor에 시그널 핸들러를 등록하는 방법도 또한 존재한다. 하지만 우리는 여기서는 쉬운 방법으로 가도록 한다. */

ACE_Sig_Action sa ((ACE_SignalHandler) handler, SIGINT);

ACE_DEBUG ((LM_DEBUG, "(%P|%t) starting up server logging daemon\n"));

// 시그널 핸들러가 SIGINT를 받을때까지 logging 서비스를 실행한다. while (!finished)

g_reactor->handle_events ();

// acceptor를 닫아 더이상 클라이언트를 받아들이지 않는다. peer_acceptor.close();

// reactor에 할당된 메모리를 해제한다. delete g_reactor;

ACE_DEBUG ((LM_DEBUG, "(%P|%t) shutting down server logging daemon\n")); return 0;

}

#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) template class ACE_Acceptor <Logging_Handler, ACE_SOCK_ACCEPTOR>; template class ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>; #elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) #pragma instantiate ACE_Acceptor <Logging_Handler, ACE_SOCK_ACCEPTOR> #pragma instantiate ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH> #endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ }}}

[edit]

3 Logging_Handler #

이제 새로운 Logging_Handler를 보도록 하자:

// $Id: ACE_c6_a9_c5_e4_b8_ae_be_f3002_2f_b4_f5_bf_ed_b0_a3_b4_dc_c7_d1_bc_ad_b9_f6,v 1.1 2004/05/20 12:24:46 redpixel Exp redpixel $

#ifndef LOGGING_HANDLER_H
#define LOGGING_HANDLER_H

#include "ace/INET_Addr.h"

#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */

#include "ace/SOCK_Stream.h"
#include "ace/Reactor.h"

/* acceptor를 생성하기위해 템플릿을 사용했기 때문에, reactor가 이것을
  사용하게 하는 방법이 있는지 여부를 모른다. 우리는 쉬운 방법을 택하도록
  한다. 전역 포인터 변수를 그냥 가져온다. (acceptor의 reactor로부터 다시
  얻어오는 방법이 있다. 나중에 알아보도록 한다.) */
extern ACE_Reactor *g_reactor;

/* 지금은 {{{ACE_Event_Handler}}}대신에 {{{ACE_Svc_Handler

에서 상속

받기로 한다. 이렇게 하는 큰 이유는 ACE_Svc_Handler가 SOCK_Stream을 포함하는 법을 알고 있고 reactor가 요구하는 모든 메소드 호출을 제공하기 때문이다. 두번째 템플릿 인자는 나중에 제작할 서버들에서 알려줄 약간 어려운 부분이다. 지금은 그대로 가져다 쓰도록 한다. */

class Logging_Handler : public ACE_Svc_Handler <ACE_SOCK_STREAM, ACE_NULL_SYNCH> { public:

/* Acceptor<> 템플릿은 새로운 클라이언트 접속이 발생할 때 open()을 실행한다. */ virtual int open (void *) {

ACE_INET_Addr addr;

/* 접속되어있는 클라이언트의 주소를 얻기위해 peer()함수(부모클래스에 선언되어있음)

를 호출한다. 접속이 끊어졌을 때는 이 부분은 실패하며, 앞으로의 실행을 중단한다. */

if (this->peer ().get_remote_addr (addr) == -1)

return -1;

/* Acceptor<>는 자신의 reactor에 자기자신을 스스로 등록하지 않는다. 그러므로 이것은 손수

작성해주어야 한다. 이것이 reactor를 전역 포인터로 선언해두어야하는 이유다. READ_MASK 를 다시 사용하는 것에 주목하자. (그러므로 클라이언트가 어떤 동작을 할때마다 handle_input()가 호출된다.) */

if (g_reactor->register_handler (this, ACE_Event_Handler::READ_MASK) == -1)

ACE_ERROR_RETURN ((LM_ERROR, "(%P|%t) can't register with reactor\n"), -1);

/* 여기에 또다른 새로운 팁이 있다. 우리는 타이머 이벤트를 스케줄한다.

2초가 지나면 만기에 따른 time-out처리를 하며 다시 매 3초후에 실행된다. 이 예제안에서는 이것을 어떻게 사용하는가를 보여주는 것외의 어플리케이션 기능상의 다른 뜻은 없다는 것을 알아두기 바란다. */

else if (g_reactor->schedule_timer (this,

0, ACE_Time_Value (2), ACE_Time_Value (3)) == -1)

ACE_ERROR_RETURN ((LM_ERROR, "can'(%P|%t) t register with reactor\n"), -1);

ACE_DEBUG ((LM_DEBUG, "(%P|%t) connected with %s\n", addr.get_host_name ()));

return 0;

}

/* 이것은 하나의 스타일이고 아마도 맛보기라고 할 수 있다. 소멸자에 여기에 있는

모든 것들을 넣는 것 대신에, 이 함수에 넣어두고 "delete"를 호출하는 모든 경우에 destroy()를 호출한다. */

virtual void destroy (void) {

/* reactor로 부터 자신을 제거한다. */ g_reactor->remove_handler (this, ACE_Event_Handler::READ_MASK | ACE_Event_Handler::DONT_CALL);

/* 우리가 open()에서 스케줄한 타이머를 취소한다. */ g_reactor->cancel_timer (this);

/* 클라이언트로의 연결을 끊는다. */ this->peer ().close ();

/* 자기자신의 메모리를 날린다. */ delete this;

}

/* 클라이언트가 서버와의 접속을 원하지 않는다면, 아마도 close()를 호출할 것이다.

실제로, 만약 open()메소드에서 -1이 반환되면 Acceptor<>는 뒷처리를 위해서 close()를 실행한다. */

virtual int close (u_long flags = 0) {

/* ACE_Svc_Handler 베이스 클래스는 <flags> 인자를 필요로한다. 어쨌거나 우리는 여기서

그것을 사용하진 않으므로 UNUSED로 설정한다. 소스아래의 handle_timeout()에서도 같은 걸 볼 수 있을 것이다. */

ACE_UNUSED_ARG (flags);

/* 제거한 후 사라진다. */ this->destroy (); return 0;

}

protected:

/* 튜토리얼 1과 같이 클라이언트로부터의 입력에 반응하는 함수이다. */ virtual int handle_input (ACE_HANDLE) {

char buf128; ACE_OS::memset (buf, 0, sizeof (buf));

switch (this->peer().recv (buf, sizeof(buf)))

{ case -1:

ACE_ERROR_RETURN ((LM_ERROR, "(%P|%t) %p bad read\n", "client logger"), -1);

case 0:

ACE_ERROR_RETURN ((LM_ERROR, "(%P|%t) closing log daemon (fd = %d)\n", this->get_handle ()), -1);

default:

ACE_DEBUG ((LM_DEBUG, "(%P|%t) from client: %s", buf));

}

return 0;

}

/* 타이머가 만기되면, handle_timeout()이 호출된다. "arg"는

schedule_timer()함수의 두번째 인자로부터 넘어오는 값이다. void * 로 선언되어있으므로 어떤 변수라도 캐스팅해서 넘길 수 있다. 여기서는 단순히 메세지만 출력하도록 한다. */

virtual int handle_timeout (const ACE_Time_Value &tv, const void *arg) {

ACE_UNUSED_ARG(tv); ACE_UNUSED_ARG(arg); ACE_DEBUG ((LM_DEBUG, "(%P|%t) handling timeout from this = %u\n", this)); return 0;

}

/* handle_input() (또는 handle_timer())가 -1을 반환했을 경우 자기자신을 제거한다. */ virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask) {

this->destroy (); return 0;

}

};

#endif /* LOGGING_HANDLER_H */ }}}

[edit]

4 마치며 #

자, 두번째 튜토리얼이 끝났다. 우리는 서버를 생성하는 더 쉬운 방법을 알아보았다. (특히 accepter부분) 동시에, 함수성과 활용성을 개선하도록 해보았다. 하루에 할수 있는 일치고는 나쁘지 않다. ^^;

ID
Password
Join

Contents

1 시작하며 #

2 다시 메인 함수 #

3 Logging_Handler #

4 마치며 #