Describe 권�기/채팅프로그램 here
2012/3/30 - ì�¼ëŒ€ì�¼ 채팅 프로그램 만들기 ¶
설명 ¶
exit를 치면 채팅� 종료합니다.
ë¬¸ì œì � ¶
exit를 쳤ì�„ 때, 종료가 ì œëŒ€ë¡œ ë�˜ì§€ 않는 것ì�´ ë¬¸ì œìž…ë‹ˆë‹¤.
clientì—�서 exit를 쳤ì�„ 때, "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤." ë�¼ëŠ” 메세지가 바로 뜨지 않습니다. serverì—�서 아무거나 ìž…ë ¥í•˜ë©´ ê·¸ì œì„œì•¼ clientì—�서 "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤."ê°€ ì¶œë ¥ë�©ë‹ˆë‹¤.
ê·¸ë¦¬ê³ ë‚˜ì„œ server는 채팅 종료ì§�ì „ì—� 받았ë�˜ 메세지를 무한히 ì¶œë ¥í•©ë‹ˆë‹¤.
serverì—�서 exit를 쳤ì�„ 때, "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤." ë�¼ëŠ” 메세지가 바로 뜨지 않습니다. clientì—�서 아무거나 ìž…ë ¥í•˜ë©´ ê·¸ì œì„œì•¼ serverì—�서 "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤."ê°€ ì¶œë ¥ë�©ë‹ˆë‹¤.
ê·¸ë¦¬ê³ ë‚˜ì„œ client는 채팅 종료ì§�ì „ì—� 받았ë�˜ 메세지를 무한히 ì¶œë ¥í•©ë‹ˆë‹¤.
clientì—�서 exit를 쳤ì�„ 때, "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤." ë�¼ëŠ” 메세지가 바로 뜨지 않습니다. serverì—�서 아무거나 ìž…ë ¥í•˜ë©´ ê·¸ì œì„œì•¼ clientì—�서 "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤."ê°€ ì¶œë ¥ë�©ë‹ˆë‹¤.
ê·¸ë¦¬ê³ ë‚˜ì„œ server는 채팅 종료ì§�ì „ì—� 받았ë�˜ 메세지를 무한히 ì¶œë ¥í•©ë‹ˆë‹¤.
serverì—�서 exit를 쳤ì�„ 때, "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤." ë�¼ëŠ” 메세지가 바로 뜨지 않습니다. clientì—�서 아무거나 ìž…ë ¥í•˜ë©´ ê·¸ì œì„œì•¼ serverì—�서 "채팅ì�´ 종료ë�˜ì—ˆìŠµë‹ˆë‹¤."ê°€ ì¶œë ¥ë�©ë‹ˆë‹¤.
ê·¸ë¦¬ê³ ë‚˜ì„œ client는 채팅 종료ì§�ì „ì—� 받았ë�˜ 메세지를 무한히 ì¶œë ¥í•©ë‹ˆë‹¤.
무한 루프ì—� 관한 ë¬¸ì œëŠ” í•´ê²°ë�˜ì—ˆìŠµë‹ˆë‹¤. - 2012. 4. 3
서버 ¶
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<pthread.h>
#define SIZE 1024
int client_socket, server_socket;
int client_addr_size, flag = 0;
char buff_snd[SIZE + 5], buff_rcv[SIZE + 5];
void* snd(void *data){
while(!flag){
gets(buff_rcv);
if(strcmp(buff_rcv, "exit") == 0)flag = 1;
else{
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
send(client_socket, buff_snd, strlen(buff_snd)+1, 0);
}
}
}
void *rcv(void *data){
int temp;
while(!flag){
if(recv(client_socket, buff_rcv, SIZE, 0) <= 0)continue;
else{
if(strcmp(buff_rcv, "exit") == 0)flag = 1;
else{
printf( "receive: %s\n", buff_rcv);
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
}
}
}
}
int main(void){
int option = 1;
pthread_t pthread[2];
struct sockaddr_in server_addr, client_addr;
server_socket = socket(PF_INET, SOCK_STREAM, 0);
setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option));
if (-1 == server_socket)
{
printf( "server socket �성 실패");
exit( 1) ;
}
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(4000);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr))){
printf( "bind() 실행 �러\n");
exit( 1);
}
if(listen(server_socket, 5) == -1){
printf( "대기ìƒ�태 모드 ì„¤ì • 실패\n");
exit( 1);
}
client_addr_size = sizeof(client_addr);
client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_size);
if(client_socket == -1){
printf( "���언트 연결 수� 실패\n");
exit(1);
}
pthread_create(&pthread[0], NULL, snd, (void *)NULL);
pthread_create(&pthread[1], NULL, rcv, (void *)NULL);
int status;
pthread_join(pthread[0], (void**)&status);
pthread_join(pthread[1], (void**)&status);
printf("채팅� 종료�었습니다.\n");
close(server_socket);
return 0;
}
í�´ë�¼ì�´ì–¸íЏ ¶
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#define SIZE 1024
int flag = 0;
char buff_snd[SIZE + 5], buff_rcv[SIZE + 5];
int client_socket;
void* snd(void *data){
while(!flag){
gets(buff_rcv);
if(strcmp(buff_rcv, "exit") == 0)flag = 1;
else{
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
send(client_socket, buff_snd, strlen(buff_snd)+1, 0);
}
}
}
void *rcv(void *data){
int temp;
while(!flag){
if(recv(client_socket, buff_rcv, SIZE, 0) <= 0)continue;
else{
if(strcmp(buff_rcv, "exit") == 0)flag = 1;
else{
printf( "receive: %s\n", buff_rcv);
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
}
}
}
}
int main( int argc, char **argv)
{
pthread_t pthread[2];
struct sockaddr_in server_addr;
client_socket = socket( PF_INET, SOCK_STREAM, 0);
if( -1 == client_socket)
{
printf( "socket �성 실패\n");
exit( 1);
}
memset( &server_addr, 0, sizeof( server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons( 4000);
server_addr.sin_addr.s_addr= inet_addr( "127.0.0.1");
if( -1 == connect( client_socket, (struct sockaddr*)&server_addr, sizeof( server_addr) ) )
{
printf( "ì ‘ì†� 실패\n");
exit( 1);
}
pthread_create(&pthread[0], NULL, snd, (void *)NULL);
pthread_create(&pthread[1], NULL, rcv, (void *)NULL);
int status;
pthread_join(pthread[0], (void**)&status);
pthread_join(pthread[1], (void**)&status);
printf("채팅� 종료�었습니다.\n");
close(client_socket);
return 0;
}
2012/4/3 - 멀티채팅 프로그램 만들기 ¶
설명 ¶
멀티 채팅� �니다.
ì�´ì „ì—� 작성했ë�˜ ì�¼ëŒ€ì�¼ 채팅 프로그램ì�˜ 소스는 구조ì �으로 ë¬¸ì œê°€ 많았기 때문ì—� ë§Žì�€ ìˆ˜ì •ì�´ 필요했습니다.
ì�´ì œ 멀티채팅ì�„ 완성했는ë�°, í�¬ì„±ì�´ëŠ” ê³„ì •ì�´ ì �ìš©ë�œ 채팅ì�„ 만들었군요.. 멘붕
ì�´ì „ì—� 작성했ë�˜ ì�¼ëŒ€ì�¼ 채팅 프로그램ì�˜ 소스는 구조ì �으로 ë¬¸ì œê°€ 많았기 때문ì—� ë§Žì�€ ìˆ˜ì •ì�´ 필요했습니다.
ì�´ì œ 멀티채팅ì�„ 완성했는ë�°, í�¬ì„±ì�´ëŠ” ê³„ì •ì�´ ì �ìš©ë�œ 채팅ì�„ 만들었군요.. 멘붕
- 난 그냥 �걸 너네가 만들었다는거 �체�서 멘붕.. -김태진
ì�˜ë¬¸ì � ¶
프로그램ì�„ 작성하면서 들었ë�˜ ì�˜ë¬¸ì �ì�€ Pthread_joinì—� 관한 것입니다. 서버쪽ì—�서 ì“°ë ˆë“œë¥¼ 쓰면서 Joinì�„ 어디다가 ë†”ì•¼í• ì§€ë¥¼ ëª¨ë¥´ê² ì–´ì„œ 한번 ë¹¼ë†“ê³ í•´ë³´ë‹ˆê¹Œ 프로그램ì�´ 잘 ìž‘ë�™ì�´ ë�˜ì—ˆìŠµë‹ˆë‹¤.(ìš°ì—°ì�˜ 산물 ã… ã… )
하지만 joinì�´ 없으면 ìž�ì›�ì�´ í•´ì œê°€ ë�˜ì§€ 않으니 메모리 누수가 ìƒ�길 ê²�니다. 그래서 ì €ëŠ” joinì�„ ì‚¬ìš©í•˜ê³ ì‹¶ì�€ë�° 어떻게 í•´ì•¼í• ì§€ë¥¼ ëª¨ë¥´ê² ë„¤ìš”.
하지만 joinì�´ 없으면 ìž�ì›�ì�´ í•´ì œê°€ ë�˜ì§€ 않으니 메모리 누수가 ìƒ�길 ê²�니다. 그래서 ì €ëŠ” joinì�„ ì‚¬ìš©í•˜ê³ ì‹¶ì�€ë�° 어떻게 í•´ì•¼í• ì§€ë¥¼ ëª¨ë¥´ê² ë„¤ìš”.
- 서버ì�˜ 경우 listenì�„ 하기위하여 while문으로 무한 루프를 ë�Œê³ 있으므로 ì¡°ì�¸ì�´ 없어ë�„ ìŠ¤ë ˆë“œê°€ 중간ì—� 죽지않습니다. ê·¸ë¦¬ê³ mainì�´ returnì�„ 하여 프로세스가 종료ë� 경우 ì§€ì‹�ìŠ¤ë ˆë“œë�„ 모ë‘� 종료ë�˜ë¯€ë¡œ main 함수 실행 ë�„중ì—� 종료해야하는 경우 ì�´ì™¸ì—�는 따로 처리를 하지 않아ë�„ë�©ë‹ˆë‹¤. - ê¹€í�¬ì„±
ì°¸ê³ íŽ˜ì�´ì§€- http://www.google.co.kr/url?sa=t&source=web&cd=5&ved=0CEkQFjAE&url=http://211.221.225.175/~comsys/NP_PDF/chapter9.pdf&ei=B1B6T-XQLsaNiAfp7ozmAg&usg=AFQjCNGSvHjDhJuPzKXNM753wAi0WINORQ
ë¬¸ì œì � ¶
소스가 ì •ë¦¬ê°€ 안ë�˜ì„œ ì§€ì €ë¶„í•©ë‹ˆë‹¤.
서버 ¶
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<pthread.h>
#define SIZE 1024
#define N 40
int client_socket[N+5], check[N+5], server_socket;
int client_addr_size, flag = 0;
char buff_snd[SIZE + 5], buff_rcv[SIZE + 5];
void *rcv(void *data){
int i;
int temp = (int *)data;
while(1){
if(recv(client_socket[temp], buff_rcv, SIZE, 0) <= 0)continue;
else{
if(strcmp(buff_rcv, "exit") == 0){
printf("채팅� 종료�었습니다.\n");
break;
}
printf( "receive: %s\n", buff_rcv);
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
for(i = 1; i<=N; i++){
if(check[i])send(client_socket[i], buff_snd, strlen(buff_snd)+1, 0);
}
}
}
close(client_socket[temp]);
client_socket[temp] = check[temp] = 0;
}
int main(void){
int option = 1;
pthread_t pthread[N+5];
struct sockaddr_in server_addr, client_addr;
int i;
server_socket = socket(PF_INET, SOCK_STREAM, 0);
setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option));
if (-1 == server_socket)
{
printf( "server socket �성 실패");
exit( 1) ;
}
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(4000);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr))){
printf( "bind() 실행 �러\n");
exit( 1);
}
while(1){
if(listen(server_socket, 5) == -1){
printf( "대기ìƒ�태 모드 ì„¤ì • 실패\n");
exit( 1);
}
for(i = 1; i<=N; i++){
if(!check[i]){
client_addr_size = sizeof(client_addr);
client_socket[i] = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_size);
if(client_socket[i] == -1){
printf( "���언트 연결 수� 실패\n");
exit( 1);
}
check[i] = 1;
pthread_create(&pthread[i], NULL, rcv, (void *)i);
//int status;
//pthread_join(pthread[i], (void **)&status);
break;
}
}
}
printf("채팅� 종료�었습니다.\n");
close(server_socket);
exit(1);
return 0;
}
í�´ë�¼ì�´ì–¸íЏ ¶
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <pthread.h>
#define SIZE 1024
int flag1 = 0, flag2 = 0;
char buff_snd[SIZE + 5], buff_rcv[SIZE + 5];
int client_socket;
void* snd(void *data){
while(!flag1){
while(flag2);
gets(buff_rcv);
send(client_socket, buff_rcv, strlen(buff_rcv)+1, 0);
if(strcmp(buff_rcv, "exit") == 0){
flag1 = 1;
printf("채팅� 종료�었습니다.\n");
pthread_exit((void *)NULL);
}
flag2 = 1;
}
}
void *rcv(void *data){
int temp;
while(!flag1){
if(recv(client_socket, buff_rcv, SIZE, 0) <= 0)continue;
else{
printf( "receive: %s\n", buff_rcv);
sprintf( buff_snd, "%d : %s", strlen( buff_rcv), buff_rcv);
flag2 = 0;
}
}
}
int main( int argc, char **argv)
{
pthread_t pthread[2];
struct sockaddr_in server_addr;
client_socket = socket( PF_INET, SOCK_STREAM, 0);
if( -1 == client_socket)
{
printf( "socket �성 실패\n");
exit( 1);
}
memset( &server_addr, 0, sizeof( server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons( 4000);
server_addr.sin_addr.s_addr= inet_addr( "127.0.0.1");
if( -1 == connect( client_socket, (struct sockaddr*)&server_addr, sizeof( server_addr) ) )
{
printf( "ì ‘ì†� 실패\n");
exit( 1);
}
pthread_create(&pthread[0], NULL, snd, (void *)NULL);
pthread_create(&pthread[1], NULL, rcv, (void *)NULL);
int status;
pthread_join(pthread[0], (void**)&status);
pthread_join(pthread[1], (void**)&status);
close(client_socket);
exit(1);
return 0;
}










