12-02 select 함수의이해와 서버의 구현 (2)
- 멀티 플렉싱 서버의 구현
- 지금 까지 익혀온 select 함수의 사용법을 바탕으로 멀티 플렉싱 서버를 구현할 차례이다.
- 다음예제는 멀티플렉싱 기반의 에코 서버이다.
- echo_selectserv.c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/select.h>
#define BUF_SIZE 100
void error_handling(const char *buf);
int main(int argc, char *argv[])
{
int serv_sock, clnt_sock;
struct sockaddr_in serv_adr, clnt_adr;
struct timeval timeout;
fd_set reads, cpy_reads;
socklen_t adr_sz;
int fd_max, str_len, fd_num , i;
char buf[BUF_SIZE];
if(argc != 2)
{
printf("USage : %s <port>\n", argv[0]);
exit(1);
}
serv_sock = socket(PF_INET, SOCK_STREAM, 0);
memset(&serv_adr, 0, sizeof(serv_adr));
serv_adr.sin_family = AF_INET;
serv_adr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_adr.sin_port = htons(atoi(argv[1]));
if(bind(serv_sock, (struct sockaddr*)&serv_Adr, sizeof(serv_Adr)) == -1)
error_handling("bind() error");
if(listen(serv_sock, 5) == -1)
error_handling("listen() error");
FD_ZERO(&reads);
FD_SET(serv_sock, &reads);
fd_max = serv_sock;
while(1)
{
cpy_reads = reads;
timeout.tv_sec = 5;
timeout.tv_usec = 5000;
if( (fd_num = select(fd_max +1, &cpy_reads, 0, 0, &timeout)) == -1)
break;
if(fd_num == 0)
continue;
for(i =0; i< fd_max+1; i++)
{
if(FD_ISSET(i, &cpy_reads))
{
if(i == serv_Sock ) //connection request!
{
adr_sz = sizeof(clnt_adr);
clnt_sock = accept(Serv_Sock, (struct sockaddr*)&clnt_Adr, &adr_sz);
FD_SET(clnt_Sock, &reads);
if(fd_max <clnt_Sock)
fd_max = clnt_sock;
printf("connected Client: %d \n ", clnt_sock);
}
else // read message !
{
str_len = read(i, buf, BUF_SIZE);
if(str_len == 0) // close request!
{
FD_CLR(i, &reads);
close(i);
printf("closed client : %d \n", i);
}
else
{
write(i, buf, str_len); //echo!
}
}
}
}
}
close(serv_sock);
return 0;
}
void error_handling(const char *buf)
{
fputs(buf, stderr);
fputc('\n', stderr);
exit(1);
}