Facebook Joinc 그룹
Joinc QA 사이트
Tweet
joinc는 Firefox와 chrome에서 테스트 했습니다. IE에서는 테이블이 깨지거나 이미지가 보이지 않을 수 있습니다. 특히 구글 Docs이미지의 경우 엑박처리될 수 있습니다.
Tweet
joinc는 Firefox와 chrome에서 테스트 했습니다. IE에서는 테이블이 깨지거나 이미지가 보이지 않을 수 있습니다. 특히 구글 Docs이미지의 경우 엑박처리될 수 있습니다.
1 멀티 스레드 기술에 대하여
스레드에 대한 자세한 내용은 Thread 미니 사이트에 자세히 기술 되어 있다. 여기에서는 소켓 프로그래밍을 중심으로 멀티 스레드 기술이 가지는 특징을 집중적으로 살펴보도록 하겠다.
운영체제는 프로그램의 실행 이미지인 프로세스를 최소 실행 단위로 작동한다. 다중 프로세스 운영체제는 이들 프로세스를 시 분할 방식으로 스위칭 하면서, 동시에 여러 개의 프로세스를 운용한다. (엄밀히 따지자면, 동시가 아닌 동시인 것 처럼 느껴지는 것이지만 이해하기 쉽게 동시라고 하겠다.)
이 프로세스는 여러 개의 문맥으로 이루어지는데, 어차피 다중 프로세스 운영체제가 프로세스를 스위칭 하는 거라면 문맥을 스위칭 할 수 있지 않을까 ? 간단히 말해서 코드단위로 스위칭 하는 것이다. 이렇게 스위칭 가능한 프로세스의 문맥을 스레드라고 한다. 프로세스는 최소한 하나 이상의 스레드로 구성되어 있다. 만약 두 개의 스레드로 구성된다면, 이를 멀티 스레드 프로그램이라고 한다.
2 멀티 스레드 기반 소켓 프로그래밍
앞서 멀티 프로세스 기반의 소켓 프로그램에서 여러 개의 프로세스를 동시에 운용함으로써, 다수의 클라이언트를 처리하는 방법을 알아보았다.
핵심은 서버 프로그램이 듣기 소켓과 연결 소켓이 분리되어 있는데, 듣기 소켓에 클라이언트 연결이 들어와서 연결 소켓이 만들어 지면, 연결 소켓을 상속 받는 새로운 자식 프로세스를 만들어서 클라이언트 요청을 처리하는데 있다.
멀티 스레드도 이와 동일한 방식으로 다수의 클라이언트를 처리할 수 있다. 프로세스 대신 스레드를 이용하면 된다. 즉 듣기 소켓을 통해서 새로운 클라이언트가 들어오면 fork 함수를 이용해서 자식 프로세스를 만드는 대신에, pthread_create함수를 이용해서 새로운 스레드를 만드는 것이다. 이 스레드는 문맥을 포함한 코드 조각으로 듣기 소켓의 소켓 지정 번호를 매개 변수로 받아들일 수 있다. 이 듣기 소켓을 이용해서 클라이언트를 처리하는 식이다.
멀티 스레드 방식의 서버는 대게 다음과 같은 흐름을 가진다.
2.1 멀티 스레드 기반 서버 프로그램 예제
에코 서비스를 멀티 스레드 기반으로 만들어 보았다.
001 #include <sys/socket.h> 002 #include <sys/stat.h> 003 #include <arpa/inet.h> 004 #include <stdio.h> 005 #include <string.h> 006 #include <pthread.h> 007 008 #define MAXLINE 1024 009 010 void *myFunc(void *arg); 011 012 int main(int argc, char **argv) 013 { 014 int listenfd, sockfd; 015 struct sockaddr_in sockaddr; 016 017 int socklen; 018 int th_id; 019 020 pthread_t thread_t; 021 022 if(argc != 2) 023 { 024 printf("Usage : %s [port]\n", argv[0]); 025 } 026 027 if((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) 028 { 029 perror("socket error"); 030 return 1; 031 } 032 033 memset((void *)&sockaddr,0x00,sizeof(sockaddr)); 034 sockaddr.sin_family = AF_INET; 035 sockaddr.sin_addr.s_addr = htonl(INADDR_ANY); 036 sockaddr.sin_port = htons(atoi(argv[1])); 037 038 if( bind(listenfd, (struct sockaddr *)&sockaddr, sizeof(sockaddr)) == -1) 039 { 040 perror("bind error"); 041 return 1; 042 } 043 044 if(listen(listenfd, 5) == -1) 045 { 046 perror("listen error"); 047 return 1; 048 } 049 050 while(1) 051 { 052 sockfd = accept(listenfd, (struct sockaddr *)&sockaddr, &socklen); 053 if(sockfd == -1) 054 { 055 perror("accept error"); 056 return 1; 057 } 058 th_id = pthread_create(&thread_t, NULL, myFunc, (void *)&sockfd); 059 if(th_id != 0) 060 { 061 perror("Thread Create Error"); 062 return 1; 063 } 064 pthread_detach(thread_t); 065 } 066 } 067 068 void *myFunc(void *arg) 069 { 070 int sockfd; 071 int readn, writen; 072 char buf[MAXLINE]; 073 sockfd = *((int *)arg); 074 075 while(1) 076 { 077 readn = read(sockfd, buf, MAXLINE); 078 if(readn <= 0) 079 { 080 perror("Read Error"); 081 return NULL; 082 } 083 writen = write(sockfd, buf, readn); 084 if(readn != writen) 085 { 086 printf("write error %d : %d\n", readn, writen); 087 return NULL; 088 } 089 } 090 } 091
1 - 57 socket -> bind -> listen -> accept의 일반적인 과정을 거친다.
58 - 63 accept 함수로 연결 소켓을 가져오면, 클라이언트와의 통신을 처리할 스레드 함수 myFunc를 호출한다. 연결 소켓을 스레드 함수의 매개 변수로 넘긴다.
64 워커 스레드를 기다릴 필요가 없으므로 detach 시켰다.
테스트는 echo 클라이언트 프로그램을 이용했다.58 - 63 accept 함수로 연결 소켓을 가져오면, 클라이언트와의 통신을 처리할 스레드 함수 myFunc를 호출한다. 연결 소켓을 스레드 함수의 매개 변수로 넘긴다.
64 워커 스레드를 기다릴 필요가 없으므로 detach 시켰다.
2.2 멀티 스레드 기반 소켓 프로그램의 장점과 단점
스레드는 코드 조각이므로 프로세스를 복사하는 멀티 프로세스 방식 보다 좀 더 작고 빠르게 작동하는 프로그램을 만들 수 있다. 반면 독립된 프로세스 단위로 구동되지 않기 때문에, 디버깅이 힘들다는 단점이 있다. 또한 하나의 스레드에 생긴 문제가 전체 프로세스에 문제를 줄 수 있다는 문제점도 있다.
만약 특별히 바쁜 서버가 아니라면, 멀티 스레드 보다는 멀티 프로세스 방식을 선택하는 게 낫다는게 내 의견이다.
|
|
category_network programing |