수다닷컴

#includepthread.h
#includestdio.h
#includestdlib.h
#includestring.h
#includeunistd.h
#includearpa/inet.h //AF_INET 외부 내트워크 도메인
#includesys/types.h
#includesys/socket.h
#define MAXLINE 511
void *thread_server(void *arg);
void *thread_client(void *arg);
int main(int argc,char **argv)
{
int state;
pthread_t s_id;
pthread_t c_id;

void *s_return;
void *c_return;

state=pthread_create(&s_id,NULL,thread_server,NULL);

//state=pthread_join(s_id , &s_return);

state=pthread_create(&c_id,NULL,thread_client,NULL);

state=pthread_join(s_id , &s_return);

free(s_return);
free(c_return);

return 0;
}
void *thread_server(void *arg)
{
int serv_sock;
int conn_sock;
int on;
struct sockaddr_in serv_addr;
struct sockaddr_in conn_addr;
int addrlen, datalen;
char buf[MAXLINE +1];
int nbytes;
pid_t pid;
serv_sock = socket(PF_INET,SOCK_STREAM, IPPROTO_TCP); // serv_sock를 소켓 파일 서술자로 만든다.
if(serv_sock == -1)
{
perror(socket() error\n);
exit(0);
}
on=1;
setsockopt(serv_sock, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(5000);
if(bind(serv_sock, (struct sockaddr*)&serv_addr,sizeof(serv_addr)) == -1)
{
perror(bind() error\n); //bind(). 소켓 파일 서술자에게 ip, port 주소를 가진 구조체를 넣어준다.
exit(0);
}
if(listen(serv_sock,1) == -1)
{ // 소켓 대기열 생성
perror(listen() error\n);
exit(0);
}
addrlen = sizeof(conn_sock);
conn_sock = accept(serv_sock, (struct sockaddr*)&conn_addr, &addrlen); //전화오기를 기다림.
if(conn_sock == -1){
perror(accept() error\n);
exit(0);
}
if((pid=fork())==-1){close(conn_sock);perror(fork() error);exit(0);}
else if (pid == 0)
{ //자식프로세스이다.6
while(1)
{
fgets(buf,sizeof(buf),stdin);
nbytes = strlen(buf);
write(conn_sock,buf,MAXLINE);
if((strncmp,exit,4) == 0)
{
puts(Good Bye.);
exit(0);
} //자식프로세스는 stdin으로 사용자가 입력한 문자를 buf에 저장하여 소켓에다 write 시스템콜을 이용해
} //client에게 문자열을 보내고, exit를 입력시 종료하게 한다.
exit(0);
}
else if(pid0)
{ //부모프로세스이다.
while(1)
{
if((nbytes = read(conn_sock,buf,MAXLINE)) 0)
{
perror(read() error\n);
exit(0);
}
printf(%s,buf);
if(strncmp(buf,exit,4) == 0)
exit(0);
} //부모프로세스는 client가 소켓에 보낸 문자열을 read로 읽어 저장한다.
} //역시 exit 가 날라왔을시에는 종료.
return 0;
}

void *thread_client(void *arg)
{

int cli_sock;
struct sockaddr_in serv_addr;
int datalen;
pid_t pid;
char buf[MAXLINE+1];
int nbytes; cli_sock = socket(PF_INET, SOCK_STREAM, 0); //cli_sock을 소켓 파일 서술자로 만듭니다. if(cli_sock == -1)
{
perror(socket() error\n);
exit(0);
} memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = inet_addr(192.168.0.222); //ip와
serv_addr.sin_port = htons(5000); //port의 입력 if(connect(cli_sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == -1)
{ //서버에게 접근 시도
perror(connect() error\n);
exit(0);
} if((pid=fork()) ==1)
{ //다중 프로세스를 위한 fork함수. 자식 프로세스 생성
perror(fork() error\n);
exit(0);
}
else if(pid == 0)
{ //자식 프로세스 부분. stdin로 사용자가 입력한 문자를 buf에 저장하여 소켓에다
while(1)
{ //write 시스템콜을 이용해 server에게 문자를 보낸다. exit 입력시 종료
fgets(buf,sizeof(buf),stdin);
nbytes = strlen(buf);
write(cli_sock,buf,MAXLINE);
if((strncmp,exit,4) == 0)
{
puts(Good Bye.);
exit(0);
}
}
exit(0); }
else if(pid0)
{ //부모프로세스. server가 보낸 문자열을 받아 출력한다.
while(1)
{ //역시 exit 를 받을시 종료
if(nbytes = read(cli_sock,buf,MAXLINE) 0)
{
perror(read() error\n);
exit(0);
}
printf(%s,buf);
if(strncmp(buf,exit,4) == 0)
exit(0);
}
} close(cli_sock);
return 0;
}

리눅스 채팅 프로그램입니다멀티 스레드를 이용하여 서버와 클라이언트를 한 프로젝트에서 실행되게끔 만들었습니다.bind() error가 나는데 ... setsockopt(serv_sock, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));를 사용했는데도 오류가납니다..저는 윈도우 에서도 멀티스레드를 이용하여 서버와클라이언트를 한프로젝트로 만든 프로그램만들었습니다.이 프로그램과 채팅을 해야합니다...

신청하기