U E D R , A S I H C RSS

권�기/채팅프로그램

Describe 권�기/채팅프로그램 here

2012/3/30 - �대� 채팅 프로그램 만들기
2012/4/3 - 멀티채팅 프로그램 만들기

2012/3/30 - �대� 채팅 프로그램 만들기


설명


서버�서� 메세지를 보낼 수 있고, ���언트�서� 메세지를 보낼 수 있습니다.
exit를 치면 채팅� 종료합니다.

문제�


exit를 쳤� 때, 종료가 제대로 �지 않는 것� 문제입니다.
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ì�„ 사용하고 ì‹ì�€ë�° 어떻게 해야할 지를 모르겠네요.
  • 서버ì�˜ 경우 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;
}

Valid XHTML 1.0! Valid CSS! powered by MoniWiki
last modified 2021-02-07 05:28:46
Processing time 0.0064 sec