flexible gameserver

Active Object Pattern on ACE

자바워크 — Wed, 18 Nov 2009 17:03:53 GMT

게임서버를 작성하다보면 로직스레드 혹은 패킷처리 스레드에서 처리할수 없는 작업들이 있습니다. DB작업이 좋은 예인데, 블럭이 걸리기 때문에 별도의 스레드에서 처리를 해주어야 합니다. 정리하자면 로직 스레드에서 DB스레드에 이 작업을 처리해 달라고 요청을 해야하는 상황인데, 이럴때 Active Object 패턴을 적용할 수 있습니다.

int ACE_TMAIN (int, ACE_TCHAR *[])
{
   DBWorkerThread workerThread;
   workerThread.activate();
   while(true)
   {
       SelectAccountJob job;
       workerThread.put(&job);
       ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) Put job \n")));
       ACE_OS::sleep (1);
   }
    return 0;
}

class DBWorkerThread : public ACE_Task_Base
{
public:
   int svc()
   {
       const int MAX_TIMEOUT = 5;
       while(true)
       {
           ACE_Time_Value tv ((long)MAX_TIMEOUT);
            ACE_Method_Request *request = queue_.dequeue(&tv);
           if (0 == request)
               continue;

           request->call();
       }
       return 0;
   }
    int put (ACE_Method_Request *req)
   {
       return queue_.enqueue(req);
   }
private:
   ACE_Activation_Queue queue_;
};

class SelectAccountJob : public ACE_Method_Request
{
public:
   virtual int call (void)
   {
       ACE_DEBUG((LM_INFO, ACE_TEXT ("(%t) Start SelectAccountJob\n")));
       ACE_OS::sleep (1);
       ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) End SelectAccountJob\n")));
       return 0;
   }
};

실행하면 아래와 같이 차례대로 실행이 되는 것을 볼수 있습니다.

왼쪽에 숫자가 ThreadID입니다. Put Job과 실제 실행이 각자 다른 스레드에서 실행되고 있습니다. ACE_Method_Request를 상속받아서 call 메서드만 구현해주면 DBWorkerThread에서 알아서 실행해줍니다.

하지만 실제로는 결과값도 받아와야 하는 경우가 많죠. 이럴때 ACE_Future를 사용할 수 있습니다.

int ACE_TMAIN (int, ACE_TCHAR *[])
{
    DBWorkerThread workerThread;
    workerThread.activate();
    while(true)
    {
        SelectAccountJob job;
        ACE_Future future = job.future();
        workerThread.put(&job);
        ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) Put job \n")));
        std::string result;
        future.get(result);
        ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) GetResult(%s)\n"), result.c_str()));
    }
    return 0;
}

class SelectAccountJob : public ACE_Method_Request
{
public:
    virtual int call (void)
    {
        ACE_DEBUG((LM_INFO, ACE_TEXT ("(%t) Start SelectAccountJob\n")));
        ACE_OS::sleep (1);
        result_.set("Success");
        ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) End SelectAccountJob\n")));
        return 0;
    }

    ACE_Future &future (void)
    {
        return result_;
    }

private:
    ACE_Future result_;
};

Job을 넣기전에 ACE_Future를 발급받습니다. ACE_Future는 결과값을 받을수 있는 proxy라고 할수 있습니다. future.get()하면 결과값을 받을 수 있는데, WorkerThread에서 결과값을 넣기 전이라면 받을수 있을때까지 블럭이 걸립니다. 내부적으로는 event wait를 합니다. WorkerThread에서 작업이 끝나면 signal을 주고 get을 했던 스레드는 블럭이 풀리면서 값을 받아오게 되는 구조입니다. 그전에 작업이 완료되어 있으면 블럭없이 바로 받아올수 있습니다.

WorkerThread에서 작업이 끝나면 callback을 불러주는 식으로 구현도 가능합니다.

int ACE_TMAIN (int, ACE_TCHAR *[])
{
    ...
    CompletionCallBack cb;
    while(true)
    {
        SelectAccountJob* job = new SelectAccountJob();
        ACE_Future future = job->future();
        job->attach(&cb);
        workerThread.put(job);
        ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) Put job \n")));
        ACE_OS::sleep (1);

    }
    getchar();
    return 0;
}

class CompletionCallBack: public ACE_Future_Observer
{
public:
    virtual void update (const ACE_Future & future)
    {
        std::string result;
        future.get(result);
        ACE_DEBUG ((LM_INFO, ACE_TEXT("(%t) GetResult(%s)\n"), result.c_str()));
    }
};

class SelectAccountJob : public ACE_Method_Request
{
    ...
    void attach (CompletionCallBack *cb)
    {
        result_.attach (cb);
    }
private:
    ACE_Future result_;
};

WorkerThread에서 작업이 끝나면 CompletionCallBack::update를 호출해 줍니다. 보통 작업 결과를 확인하고 응답패킷을 보내주는 코드를 넣으면 되겠죠.

tag : ace, framework, active, object, pattern, ACE_Future, ACE_Method_Request

플랫폼 독립적인 코드 작성

자바워크 — Wed, 11 Nov 2009 12:52:58 GMT

윈도우용으로 작성한 코드를 리눅스용으로 포팅할 일이 생겼는데, 다행히 ACE 기반으로 작성된 코드라 쉽게 포팅 할 수 있었습니다. 포팅중에 정리해둔 것을 옮겨봅니다.

대소문자의 명확한 구분
파일을 지칭할때 윈도우와 달리 리눅스는 대소문자를 명확하게 구분합니다. 윈도우에서 그냥 넘어갔던 코드가 문제가 생길수 있습니다. 대부분 include에서 문제가 발생합니다.

"Stdafx.h" -> "stdafx.h"
ace/os_ns_string.h -> ace/OS_NS_string.h

ACE 타입의 사용
gcc에는 tchar.h 가 없기때문에 TCHAR를 모두 ACE_TCHAR로 변경했습니다.

TCHAR ->ACE_TCHAR
_T("text") - > ACE_TEXT("text")

또하나 유의할점은 TCHAR는 _UNICODE define 유무에 따라 char/wchar이 결정되지만 ACE_TCHAR는 ACE_USES_WCHAR define에 따라 결정됩니다.

_s 함수들
vc에서는 strcpy_s와 같이 _s가 붙은 함수의 사용을 권장하고 컴파일시에 경고메세지도 나옵니다. 하지만 gcc에는 없는 함수이기 때문에 그냥 strcpy함수 를 사용해야 합니다. 뒤에도 나오지만 ACE_OS::strcpy 함수를 쓰는게 가장 좋습니다. 설정에 따라 char/wchar로 switch되기 때문입니다. 그래도 C4996 warning은 피할수 없습니다. _CRT_SECURE_NO_DEPRECATE으로 끄는 수밖에 없습니다.

ACE 함수의 사용
ace/OS_NS_string.h, ace/OS_NS_stdlib.h, ace/OS_NS_stdio.h 에는 문자열과 io를 다루는 함수들이 있습니다. 그 함수들을 사용하면 ACE가 플랫폼과 char/wchar에 맞는 함수들을 호출해줍니다.

sprintf -> ACE_OS::sprintf
strcpy -> ACE_OS::strcpy
atoi -> ACE_OS::atoi
atof -> ACE_OS::atof
strcmp - >ACE_OS::strcmp
strtoul - > ACE_OS::strtoul
strlen - >ACE_OS::strlen
strcat -> ACE_OS::strcat
vsnprintf - >ACE_OS::vsnprintf
fopen - >ACE_OS::fopen
fread - > ACE_OS::fread

멤버함수 템플릿 특수화의 미묘한 차이
vc에서는 되는데, gcc에서는 inline으로 해결해야 하는 문제가 있더군요. 특정 상황에서 템플릿 멤버함수가 특수화가 되지 않는 현상이었습니다. 아마 부분 특수화 관련 이었던것 같은데, vc의 문제인지 gcc의 문제인지는 알수 없지만 반드시 체크해야 합니다.

GetTickCount() 함수
GetTickCount()는 리눅스에서는 gettimeofday()로 바꾸어주어야 합니다. 그냥 치환만 하면 되는건 아니고 받아오는 단위가 다르기 때문에 변환도 필요합니다. 아래와 같이 만들어서 사용했습니다.

unsigned int GetTick()
{
#ifdef WIN32
    return GetTickCount();
#else
    timeval tick;
    gettimeofday (&tick, 0);
    return (tick.tv_sec*1000 + tick.tv_usec/1000);
#endif
}

InterlockedCompareExchange 함수
ACE에는 이 함수에 대응하는 함수가 없습니다. 이 외의 interlocked 계열 함수들은 모두 있습니다만 유독 이함수만 없습니다. 그냥 lock걸고 비교하는 방식으로 변경해야합니다.

tag : ace, linux, 플랫폼, 독립, windows, framework

독일남부여행 - Garmisch

자바워크 — Sun, 01 Nov 2009 17:00:51 GMT

이번 남부여행의 종착점 Garmisch-Partenkirchen(보통 "가르미슈"라고 하더군요) 입니다. 여기는 독일에서 가장 높은 산인 Zugspitze가 있습니다. 등산열차가 있어서 누구나 쉽게 올라갈 수 있습니다. 올라가서 보니 구름이 밑에 있더군요(+_+). 사진으로 주욱 보시겠습니다.

tag : Garmisch, Germany, Zugspitze, 독일, 등산열차

독일남부여행 - Füssen

자바워크 — Fri, 30 Oct 2009 08:42:09 GMT

다음 여행지는 퓌센(Füssen)입니다. 이전 여행지인 Lindau(Bodensee)에서 기차로 3시간 정도 걸립니다. 노인슈반스타인(Neuschwanstein)성과 호엔슈방가우 성으로 유명합니다. 노인슈반스타인성은 디즈니랜드 백조의 성 모델로도 알려져있습니다.

밤에 도착해서 찍었더니 괴기스럽게 나왔습니다. 밤에도 조명을 켜두더군요.

먼저 호엔슈방가우 성 입구. 여기는 그닥 볼게 많지 않아 패스.

Alpsee라는 호수입니다. 호엔슈방가우성 가는 길에 있습니다.

단풍과 함께 절경을 보여줍니다.

물 정말 맑네요.

푸르스름한 빛을 띄는 호수

아이랑 걸어가기에는 조금 먼 거리라서 노인슈반스타인 성까지는 마차를 타고 갔습니다. 요금은 두당 6유로.

노인슈반스타인 성에 왔습니다. 아쉽게도 성안은 촬영금지입니다. :(

성에서 찍은 마을

호엔슈방가우 성

사진이 가장 잘 나온다는 마리엔 다리에서 찍은 노인슈반스타인 성

노인슈반스타인 성은 외관, 내부 장식, 주변 자연경관 어느 하나 빠질게 없을 정도로 훌륭합니다. 독일 여행을 가신다면 강력추천하고 싶네요.

tag : Füssen, Neuschwanstein, 퓌센, germany, 독일

독일남부여행 - Bodensee

자바워크 — Thu, 29 Oct 2009 08:05:13 GMT

Bodensee는 독일 남부 Lindau와 오스트리아, 스위스에 걸쳐있는 독일에서 가장 큰 호수입니다. 프랑크푸르트에서 기차로 5~6시간 정도 걸리지만 기차 창문으로 보이는 풍경이 멋져서 감수할만 합니다. :)

초원이 펼쳐진 평원

풀뜯는 소

드디어 Bodensee에 도착했습니다.

유람선도 있고, 개인 보트도 많이 정박되어있습니다.

물이 참 깨끗합니다.

거의 끝이 보이지 않습니다. 하지만 바다가 아니라 호수.

유람선을 타고 바다 호수로 나왔습니다.

새우깡 빵조각을 향한 갈매기의 비행
근데 호수인데 왠 갈매기 =_=;

반대편으로 가니 날씨가 좀 밝아지네요.

하늘, 산, 물 빛의 조화

노을지는 Bodensee

tag : lindau, bodensee, germany, 독일

크라이텍 한국지사 프로그래머 구인

자바워크 — Mon, 19 Oct 2009 20:40:12 GMT

http://www.gamejob.co.kr/List_GI/GIB_Read.asp?GI_No=49427
http://www.gpgstudy.com/forum/viewtopic.php?topic=24568
자세한 내용은 링크를 참고하시고, 간단히 요약하면 네트워크 프로그래머와 3D/Tool 프로그래머를 구인중입니다. 분위기상 무언가 새로운 것을 시작하려는 듯 하니 많이 지원해주시면 좋겠네요.

몇달전에 저도 한번 방문했었는데, 사무실은 역삼역 근처에 있고 새빌딩을 넉넉하게 쓰고 계시더군요. 분위기도 자유롭고 따뜻하게 대해주셔서 참 감사했었습니다.

채용정보 보니 이력서는 영문으로 제출해야 하는군요. 제가 일전에 올린 포스트도 참고가 될것 같습니다.
http://javawork.egloos.com/2199134

채용과 큰 관련은 없지만 아래 링크에 가보시면 크라이텍에 얼마나 다양한 국가의 사람들이 일하고 있는지 보실수 있습니다. 물론 저도 포함. :)
http://www.crytek.com/culture/team/

오픈소스 마인드 맵 프로그램 XMind

자바워크 — Tue, 13 Oct 2009 21:10:58 GMT

http://www.xmind.net/
XMind는 오픈소스로 제공되는 마인드맵 프로그램입니다. jre를 설치하는 걸 보면 자바로 만든 것 같습니다. 무료/유료 버전이 있습니다만 무료로 제공되는 버젼도 훌륭합니다.

XMind로 간단하게 마인드맵을 하나 그려보겠습니다.

초기화면 입니다. 제목부분을 더블클릭해서 입력할 수 있습니다.

서브토픽을 하나 만들었습니다. 메인토픽이 선택된 상태에서 탭키를 누르면 서브토픽이 생성됩니다.

서브토픽을 하나 더 생성했습니다. 이전 서브토픽 포커스에서 엔터키를 입력하면 됩니다.

진행 상황도 표시할 수 있습니다.

이런식으로 응용이 가능합니다.

제 경우는 어떤 일을 먼저 해야 하는지 판단이 잘 안될때, 갑자기 떠오른 아이디어를 정리하고 싶을때, 할일을 정리할때 마인드맵을 사용합니다. 전체적인 그림이 한눈에 들어오고 현재 진행상황도 쉽게 파악이 가능합니다.

tag : xmind, mindmap, 마인드맵

ACE_Message_Block의 chained block 기능

자바워크 — Thu, 01 Oct 2009 22:38:27 GMT

ACE_Message_Block은 고정 크기 및 가변 크기 버퍼를 효과적으로 관리하기 위한 클래스 입니다. 데이터 복사, read ptr, write ptr 관리, 레퍼런스 카운팅 등 여러가지 편리한 기능들을 제공합니다. 그중의 하나인 chained block 기능을 소개합니다.

코드로 먼저 보여드리죠.

ACE_Message_Block* head = new ACE_Message_Block(size);
ACE_Message_Block* next = new ACE_Message_Block(size);
head->cont(next);

head와 next block은 연결된 상태입니다. 마치 링크드 리스트 처럼 말이죠.

next block 뒤로도 계속 연결할 수 있습니다.

이렇게 연결된 block을 구하는 코드는 아래와 같습니다.

ACE_Message_Block* node = head->cont();

이런 chained block 기능으로 composite 패턴을 구현합니다.

composite 패턴 : 개별객체와 복합객체를 같은 방식으로 다룰수 있는 인터페이스를 제공

서버에서 받은 패킷이 그것을 처리하는 로직으로 도달하기까지 거치는 여러 클래스, 함수들이 ACE_Message_Block을 손쉽게 다룰수 있게 됩니다. head block만 넘기면 되기 때문이죠. 중간에 어떤 데이터를 추가하려고 해도 버퍼를 복사할 필요없이 뒤에 연결하기만 하면 됩니다. cont() 함수로 iterating도 간단하게 할 수 있고 연결된 block들의 총길이와 개개의 block들의 길이 등을 계산하는 함수들도 별도로 제공됩니다. head block만 release하면 연결된 block들도 함께 release 됩니다. 따라서 패킷을 모두 처리한후에 head block만 release하면 되죠.

Chained block의 끝에 새로운 block을 추가하려면 tail block을 알아야 하는데, head block에서 한번에 tail block을 알아내는 인터페이스는 제공하지 않습니다. 아래와 같이 구현하면 됩니다.

ACE_Message_Block *FindTail(ACE_Message_Block *block)
{
    ACE_Message_Block *tail = block;
    while (NULL != tail->cont())
        tail = tail->cont();
    return tail;
}

처리중에 연결된 block중 하나에 다른 스레드에서 접근하면 문제가 생길수 있기 때문에 thread-safe는 별도로 보장을 해주어야 합니다.

tag : ace, framework, ACE_Message_block, Composite패턴

lock-free 회의론

자바워크 — Thu, 01 Oct 2009 20:54:06 GMT

저도 이전에 lock-free에 대해 관심이 많이 생겨서 이것 저것 많이 알아보고 구현도 해본적이 있습니다만 현재는 회의적인 입장입니다. 이유는 2가지 입니다.

사용하는데 제약이 너무 많음
들인 노력에 비해 향상되는 성능이 크지 않음

제약이 너무 많음
lock-free 알고리즘의 하나인 SpinBuffer의 경우 두가지 제약이 있습니다. 하나는 소비자 스레드와 생산자 스레드가 각각 하나씩이어야 한다는 것이고 다른 하나는 두 스레드가 블럭되지 않고 SpinBuffer의 생산, 소비 함수를 주기적으로 호출을 해야 한다는 점입니다. 이 두 조건을 모두 만족하는 상황에서만 SpinBuffer를 사용해야 합니다. 그외에 대부분의 lock-free 알고리즘은 이러한 자기만의 제약사항이 있습니다. 거기에 공통적인 문제점인 ABA 문제도 있죠. 이런 문제점을 잘 이해하고 사용하지 않으면 큰 낭패를 볼 수 있습니다.

노력대 성능비
이렇게 제약사항을 모두 충족시키며 적용을 했음에도 불구하고 lock-free 알고리즘을 적용하여 향상되는 성능은 미미한 편이었습니다. 그보다는 busy wait나 context switching을 줄임으로서 얻는 성능의 향상이 더 컸습니다.

Proactor 패턴
Half-Sync/Half-Async 패턴
바람직한 Producer-Consumer 모델

lock-free 알고리즘을 이해하고 구현하는데 시간을 들이는 것보다는 기존의 concurrent 패턴을 잘 이해하고, 그안에서 성능을 향상시키는게 가격대 성능비(?)로 낫다고 판단했습니다. 그래서 요즘은 concurrent 패턴들을 조금 더이상적으로 구현하는데 신경을 쓰고 있습니다. 성급하게 응용을 하기 보다는 원저자의 의도에 가깝게 FM대로 구현을 하는 것이지요.

동네 산책길

자바워크 — Sun, 20 Sep 2009 21:40:55 GMT

집에서 바로 나서면 있는 골목길입니다. 오르막이라 처음부터 체력이 좀 소진 됩니다. =_=;

동네 놀이터 입니다. 그네, 미끄럼틀, 씨름장(?) 정도만 있는 작은 곳 입니다.

그 중 하나인 그네 입니다. 넘어졌을때 다치지 말라고 작은 나무조각들이 깔려있습니다.

동네 지붕이 예쁜집.

이제부터 본격 산책길 입니다. 오른쪽에 큰 밭이 있는데, 보리도, 밀도 아닌 뭔지 모를 작물이 잘 자라고 있습니다.

빨간 사과가 한창인 사과나무. 아무도 관리 안하는 것 같은데 열매를 주렁주렁 달고 있네요.

사과가 썩어나는 현장. 아무도 안주워 가더군요.

전나무처럼 생겼는데, 잎새가 축축 늘어집니다.

잠시 돌아본 동네 전경

9월의 독일 하늘.

어딘가로 들어가는 입구를 발견

들어가보니..

공원이군요

지대가 높아서 프랑크푸르트 시내가 보입니다.

토요일 정오인데도 한산하네요.

공원내 포도밭도 있습니다.

연날리는 할아버지

계단

광합성 중인 시민들

포도밭 옆으로 어디론가 가는 길이 있습니다.

사과농장입니다.

들어가보니 사과축제 같은 것을 하고 있네요. 그래서 개방되어 있었던 모양입니다.

사과 덩굴(?)

분위기 있는 나무 사이길

동네 지붕 예쁜집 #2