공간사랑

• TCP/IP 데이터의 전달을 보장합니다.
• 언제 전달될지는 보장되지 않습니다. 
  
  

• recv() = 0 상대편의 접속 해제
• recv() > 0 recv()가 읽어 들인 바이트
• recv() = -1 에러 
  
  

• 바이트 패딩 오류(x86및 기타 다른 플렛폼)
• 바이트 오더 차이(x86및 기타 다른 플렛폼)
• 데이터 송/수신 구분 
  
  

       헤    더                         바    디
 데이터 구분+바디 사이즈+ SOH     가변적인 데이터 + EOT

    SENDER           RECEIVER

  1.  A03FH      ---> A03
  2.                    Header Area Parse
  3.               ---> FH

    SENDER           RECEIVER

  1.  A      --->
  2.  B      --->
  3.  C      --->
  4.  D      --->      ABCD

  ---------------------------------------------

    SENDER           RECEIVER

  1.  ABCD   --->      ABCD

 int setsockopt(int s , int level , int optname, const void * optval , socklen_t optlen);

int ClientMacAddress(char *ip, char *macaddress)
{
  struct sockaddr_in sin = { 0 };
  struct arpreq myarp = { { 0 } };
  int sockfd;
  unsigned char *ptr;

    sin.sin_family = AF_INET;
    if (inet_aton (ip, &sin.sin_addr) == 0) {
        printf ("'%s' address is not valid\n",ip );
        return -1;
    }

    memcpy (&myarp.arp_pa, &sin, sizeof myarp.arp_pa);
    strcpy (myarp.arp_dev, "eth0");

    if ((sockfd = socket (AF_INET, SOCK_DGRAM, 0)) == -1) {
        printf ("cannot open socket\n");
        return -2;
    }

    if (ioctl (sockfd, SIOCGARP, &myarp) == -1) {
        /* 로컬일 경우 에러가 발생할 가능성이 */
        printf(" no entry in arp_cache for '%s'\n",ip);
        return -3;
    }

    ptr = &myarp.arp_ha.sa_data [0];

    snprintf(macaddress, 50, "%2.2X:%2.2X:%2.2X:%2.2X:%2.2X:%2.2X",
            *ptr, *(ptr+1),*(ptr+2), *(ptr+3),*(ptr+4),*(ptr+5));

    return 0;

}

• DB 서버는 개별 서버들에서 직접 엑세스 하지 않고 DB서버에 별도의 데몬을 구동하여 이 데몬을 통하여 SELECT/INSERT/UPDATE를 수행하게 합니다. 또한 빈번한 자료나 신속성을 요하는 정보의 경우에는 새로운 이벤트 발생시 DB 쿼리를 통하지 않고 늘 메모리에 저장하고 있다가 응답을 하게 됩니다. 
  
  
  
• 뉴스 서버는 전송되는 데이터의 양이 많지만 정적인 자료가 주를 이루므로 실시간 브로드 케스팅을 하지 않고 클라이언트의 요구에 따라 반응하게 되어 있습니다. 예를 들면 사용자가 뉴스창을 띄었을때 그에 해당 하는 뉴스 제목만 20건 전송해주고 뉴스 내용을 클릭했을때 그 뉴스의 내용에 해당하는 자료를 전송해줍니다. 또한 스크롤바를 클릭하여 20건의 뉴스 제목이 넘어가면 새로운 20건을 전송요청하게 되는 형식입니다. 
  
  
  
• 챠트 서버는 정/동적인 데이터를 함께 다룹니다. 즉, 과거 자료를 비교하기 위해서는 정적인 데이터를 필요로 하지만 장중의 가격 정보를 원할경우에는 실시간 데이터를 요청하여 실시간 챠트를 생성하게 합니다. 
  
  
  
• 호가서버는 증권전산에서 10차 호가까지 공개가 되므로 데이터의 전송이 가장 빈번하면서도 많습니다. 무엇보다 신속성을 우선으로 하며 증권사에 따라 UDP 프로토콜을 이용하는 서버가 존재합니다. 대부분의 증권사 서버는 호가 서버로 구성이 되는것이 이러한 이유입니다. 
  
  
  
• 메모리풀서버는 최초 클라이언트 구성시 순식간에 많은 양의 데이터를 표현해야 하는 관계로 각 서버들에 일일이 요청을 해서 표시하기에는 구동시간이 너무 오래 걸리므로 최초 구동에 필요한 데이터 부분만 따로 가지고 있는 서버입니다. 
  
  

• Synchronous I/O Multiplexing
• File Descriptor Read/Writeable
• Timeout 
  
  
  

• accept()이후 신규 쓰레드/프로세서 생성
• select를 사용하지 않은 무한 루프속(전통적인 다중서버 구성)에 신규 접속에 대해 쓰레드/프로세서를 생성한이후 개별 접속의 송/수신에 따라 select()를 이용하는 방법
• 1,2번 두가지를 혼합하는 방법 
  
  
  

• select() 자체만 이용하면서 I/O NON-Blocking 방법을 이용한다.
• select()+thread or select()+fork등을 조합해서 사용한다. 
  
  
  

• http://wiki.kldp.org/wiki.php/LinuxdocSgml/Serial-Programming-HOWTO
• http://dns.easysw.com/~mike/serial
• http://www.masoner.net/articles/async.html 
  
  

RFC 1945 - Hypertext Transfer Protocol -- HTTP/1.0 

RFC 2068 - Hypertext Transfer Protocol -- HTTP/1.1 

가장 일반적인 HTTP 프로토콜을 이용한 통신은 기본적인 TCP/IP통신에 HTTP 프로토콜을 이용하는것이 주를 이루므로

 [POST방식]
1. 접속
2. HTTP 헤더 전송[HTTP버전및 전송되는 데이터의 사이즈등등]
3. HTTP 바디(내용) 전송 [주로 질의 내용에 해당]
4. HTTP 헤더 수신[HTTP버전및 전송되는 데이터의 사이즈등등]
5. HTTP 바디(내용) 수신 [질의 결과에 해당]

[GET방식]
1. 접속
2. HTTP 헤더 전송[HTTP버전및 전송되는 데이터의 사이즈등등]
3.
4. HTTP 헤더 수신[HTTP버전및 전송되는 데이터의 사이즈등등]
5. HTTP 바디(내용) 수신 [질의 결과에 해당]

/*------ Base64 Encoding Table ------*/
static const char MimeBase64[] = {
    'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H',
    'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P',
    'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X',
    'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f',
    'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n',
    'o', 'p', 'q', 'r', 's', 't', 'u', 'v',
    'w', 'x', 'y', 'z', '0', '1', '2', '3',
    '4', '5', '6', '7', '8', '9', '+', '/'
};

/*------ Base64 Decoding Table ------*/
static int DecodeMimeBase64[256] = {
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* 00-0F */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* 10-1F */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,62,-1,-1,-1,63,  /* 20-2F */
    52,53,54,55,56,57,58,59,60,61,-1,-1,-1,-1,-1,-1,  /* 30-3F */
    -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9,10,11,12,13,14,  /* 40-4F */
    15,16,17,18,19,20,21,22,23,24,25,-1,-1,-1,-1,-1,  /* 50-5F */
    -1,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,  /* 60-6F */
    41,42,43,44,45,46,47,48,49,50,51,-1,-1,-1,-1,-1,  /* 70-7F */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* 80-8F */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* 90-9F */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* A0-AF */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* B0-BF */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* C0-CF */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* D0-DF */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,  /* E0-EF */
    -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1   /* F0-FF */
    };

int base64_decode(char *text, unsigned char *dst, int numBytes )
{
  const char* cp;
  int space_idx = 0, phase;
  int d, prev_d = 0;
  unsigned char c;

    space_idx = 0;
    phase = 0;

    for ( cp = text; *cp != '\0'; ++cp ) {
        d = DecodeMimeBase64[(int) *cp];
        if ( d != -1 ) {
            switch ( phase ) {
                case 0:
                    ++phase;
                    break;
                case 1:
                    c = ( ( prev_d << 2 ) | ( ( d & 0x30 ) >> 4 ) );
                    if ( space_idx < numBytes )
                        dst[space_idx++] = c;
                    ++phase;
                    break;
                case 2:
                    c = ( ( ( prev_d & 0xf ) << 4 ) | ( ( d & 0x3c ) >> 2 ) );
                    if ( space_idx < numBytes )
                        dst[space_idx++] = c;
                    ++phase;
                    break;
                case 3:
                    c = ( ( ( prev_d & 0x03 ) << 6 ) | d );
                    if ( space_idx < numBytes )
                        dst[space_idx++] = c;
                    phase = 0;
                    break;
            }
            prev_d = d;
        }
    }

    return space_idx;

}

int base64_encode(char *text, int numBytes, char **encodedText)
{
  unsigned char input[3]  = {0,0,0};
  unsigned char output[4] = {0,0,0,0};
  int   index, i, j, size;
  char *p, *plen;

  plen           = text + numBytes - 1;
  size           = (4 * (numBytes / 3)) + (numBytes % 3? 4 : 0) + 1;
  (*encodedText) = malloc(size);
  j              = 0;

    for  (i = 0, p = text;p <= plen; i++, p++) {
        index = i % 3;
        input[index] = *p;

        if (index == 2 || p == plen) {
            output[0] = ((input[0] & 0xFC) >> 2);
            output[1] = ((input[0] & 0x3) << 4) | ((input[1] & 0xF0) >> 4);
            output[2] = ((input[1] & 0xF) << 2) | ((input[2] & 0xC0) >> 6);
            output[3] = (input[2] & 0x3F);

            (*encodedText)[j++] = MimeBase64[output[0]];
            (*encodedText)[j++] = MimeBase64[output[1]];
            (*encodedText)[j++] = index == 0? '=' : MimeBase64[output[2]];
            (*encodedText)[j++] = index <  2? '=' : MimeBase64[output[3]];

            input[0] = input[1] = input[2] = 0;
        }
    }

    (*encodedText)[j] = '\0';

    return 0;
}

unsigned long int ChangeEndian(unsigned long int uiInput)
{
    return ( uiInput >> 24 ) | ( ( uiInput >> 8 ) & 0x0000FF00 ) \
       | ( ( uiInput <<  8 ) & 0x00FF0000 ) | ( uiInput << 24 );
}

#ifdef X86

typedef struct _HEADER_
{
  char phase[1];
  int  length;
  char end[1];
}__attribute__((packed)) _HEADER;

#elif AIX

#pragma options align=packed

typedef struct _HEADER_
{
  char phase[1];
  int  length;
  char end[1];
}_HEADER;

#pragma options align=reset

#elif HPUX

#pragma HP_ALIGN NOPADDING

typedef struct _HEADER_
{
  char phase[1];
  int  length;
  char end[1];
}_HEADER;

#pragma HP_ALIGN HPUX_NATURAL

#endif