제가 소켓 공부하면서 작은 프로그램 하나 공부용으로 짜볼려고 하는데 잘안됩니다..
이런 간단한 것도 잘 안되니.. 아 계속 삽질 하다 잘 안되서 여쭤봅니다..
코드가 조잡하시더라도 이해해주세요... ㅠ.ㅠ
프로그램이 돌아가는 형식은 먼저... 서버와 클라이언트를 실행시키면..
서버가 id와 패스워드를 묻습니다
패스워드와 id 가 맞으면 실행할 명령어를 보내줍니다 서버가,.
명령어라도 해봤자.. quit, 랑 process <-- 메시지 읽어주고 메시지 저장시켜주는함수
이게 전부입니다..
그리고 클라이언트가 play process 라고 하면 또 메시지를 입력시킬꺼냐 출력시킬꺼냐고
보내줍니다.. 클라이언트에..
이게 전부입니다.. 근데 서버 돌리고 클라이언트로 실행시키면..
INPUT ID: <-- 여기서 아이디만 입력하면 아이디가 안맞는다는소리와함께 종료되어버립니다.
문제는 그게 아니라 서버에서도 accept 에러 표시와함게 종료되어 버립니다!!
제생각에서 포크함수로 프로세스 생성할때 뭐가 잘못된것 같습니다!
고수님들이 좀 도와주세요 ㅠ.ㅠ
클라이언트와 서버 소스 올립니다.. 한번 실행해보시면 무슨뜻인지 아실껍니다.!!
서버있는 디렉토리에 id.txt 파일생성해서 거기에 아이디아무거나 하나랑 비밀번호 하나 적어주시면 됩니다.. ㅠ.ㅠ
서버 소스 :
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/wait.h>
#define BUFSIZE 100
#define DEFULT_PORT 9999
void error_handling(char *); //에러를 처리함수
void process(int,char *); //성적처리함수
int id_check(char *,char *); //아이디체크함수
void z_handler(int sig); //좀비프로세스를처리하는함수
fd_set reads,temps; //select
int fd_max;
struct timeval timeout;
int main(int argc, char **argv)
{
struct sockaddr_in serv_addr;
struct sockaddr_in clnt_addr;
int serv_sock;
int clnt_sock;
int clnt_addr_len;
int str_len;
int port;
char recv_buf[BUFSIZE];
char send_buf[BUFSIZE];
char cmd[2][BUFSIZE];
struct sigaction act; //프로세스생성관련 함수...
pid_t pid;
int state;
act.sa_handler = z_handler;
sigemptyset(&act.sa_mask);
act.sa_flags = 0;
state = sigaction(SIGCHLD, &act, 0);
if (state != 0){
error_handling("sig error");
}
if (argc == 2){
port = atoi(argv[1]);
}else port = DEFULT_PORT;
if( (serv_sock = socket(PF_INET, SOCK_STREAM, 0))==-1) //소켓생성
error_handling("socket error");
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(port);
if((bind(serv_sock, (struct sockaddr*)&serv_addr, /바인드함수적용
sizeof(serv_addr))) == -1)
error_handling("bind error");
listen(serv_sock,5);
FD_ZERO(&reads); //fd_set 자료형을 미리 초기화시켰습니다.
while(1){
temps=reads;
if((clnt_sock = accept(serv_sock, (struct sockaddr*)&clnt_addr,
&clnt_addr_len)) == -1)
error_handling("accept error");
if (( pid = fork()) == -1){ //프로세스생성
close(clnt_sock);
continue;
}
if (pid >0 ){ //부모프로세스면클라이언트소켓닫고다른클라이언트받아드릴준비..
close(clnt_sock);
printf("conect");
continue;
}
else{ //자식프로세스면서버소켓닫고 처리..
close(serv_sock);
FD_SET(clnt_sock, &temps); //fd_set 설정...
timeout.tv_sec = 100;
timeout.tv_usec = 0;
int i;
str_len = sprintf(send_buf, "IN PUT ID: "); //아이디를보내라고 여기서보냈습니다..
send(clnt_sock, send_buf, str_len, 0);
for(i=0; i<=1; i++){ //2번만 순회하여아이디와패스워드를cmd[0],과cmd[1]에 각각 저장하는부분입니다.
//cmd는2차원배열입니다..
if((select(clnt_sock +1, &temps, 0, 0, &timeout)) ==-1)
error_handling("select error"); //셀렉트함수로클라이언트가아이디를보낼때까지기다립니다.
if(FD_ISSET(clnt_sock, &temps)){
str_len = recv(clnt_sock, recv_buf, sizeof(recv_buf)-1,0);
recv_buf[str_len]='\0';
sscanf(recv_buf, "%s", cmd[i]); //첫번째에는아이디 두번째에는패스워드저장합니다..
}
if(i==0){ //처음루프돌때만 패스워드입력하라고 보냈습니다..
str_len = sprintf(send_buf,"INPUT passwd: ");
send(clnt_sock, send_buf, str_len,0);
}
}
i = id_check(cmd[0],cmd[1]); //아이디 체크하는 함수 호출..
if( i == 1 ){ //아이디와 패스워드가맞으면 1을 반환하도록했습니다..
strcat(send_buf, "Comment:\n" //아이디와패스워드가 맞으면 명령어를 보냅니다.
"play process\n"
"quit\n");
str_len = strlen(send_buf);
send(clnt_sock, send_buf, str_len,0);
while(1){
if((select (clnt_sock+1, &temps,NULL,NULL, &timeout)) == -1) //clnt가명령어를보낼때까지기다립니다.
error_handling("select error");
if(FD_ISSET(clnt_sock, &temps))
str_len = recv(clnt_sock, recv_buf, sizeof(recv_buf)-1,0);
if(strcmp(recv_buf,"process") ==0) //play process라는명령어를 받으면 함수를 실행합니다..
process(clnt_sock,cmd[0]);
else {
close(clnt_sock); //quit 면 종료합니다...
puts("disconnect");
exit(0);
}
}
}
else
{
sprintf(send_buf,"ID incorrect"); //아이디가 안맞으면 종료합니다..
send(clnt_sock, send_buf, sizeof(send_buf),0);
close(clnt_sock);
exit(0);
}
}
}
return 0;
}
int id_check(char *cmd1, char *cmd2)
{
FILE *fp;
int i=0;
char buf[BUFSIZE];
fp = fopen ("id.txt", "r" ); //여기서는그냥 id.txt에미리 아이디랑패스워드적어놓고 읽어드린다음에..
//값이 맞으면 1을 반환하도록 했습니다..
//error_handling("file open error");
while(fgets(buf, sizeof(buf), fp)){
if(strcmp(buf,cmd1)==0 && strcmp(buf,cmd2)==0)
i=1;
else
continue;
}
return i;
fclose(fp);
}
void process(int clnt_sock,char *id)
{
FILE *fp;
char recv_buf[BUFSIZE];
char send_buf[BUFSIZE];
int str_len;
char string[BUFSIZE];
fp = fopen(id,"a+");
//error_hanlding("file open error");
strcat(send_buf, "process comment:\n" //성적처리관련 명령어를 보냅니다..
"process input\n"
"process output\n"
"quite\n");
send(clnt_sock, send_buf, sizeof(send_buf),0);
while(1){
temps=reads;
timeout.tv_sec = 100;
timeout.tv_usec = 0;
if(select(clnt_sock+1,&temps, 0,0,&timeout) == -1) //clnt가 명령어보낼때까지 기다렸다가..
error_handling("select error");
if(FD_ISSET(clnt_sock, &temps)) //명령어가오면 실행합니다.
{
str_len = recv(clnt_sock, recv_buf,sizeof(recv_buf)-1,0);
if(strcmp(recv_buf,"process output")==0){
while(fgets(send_buf,sizeof(send_buf),fp)!=NULL){ //파일의저장된모든내용을보냅니다..!
send(clnt_sock, send_buf,sizeof(send_buf),0);
}
}else if(strcmp(recv_buf, "process input")==0){
send(clnt_sock,"message:",sizeof(10),0); //clnt가 보낸메시지를파일에저장합니다.
if(select(clnt_sock+1,&temps, 0, 0, &timeout) ==-1)
error_handling("select error");
if(FD_ISSET(clnt_sock, &temps))
{
while(1){
str_len = recv(clnt_sock, recv_buf,
sizeof(recv_buf)-1,0);
recv_buf[str_len]='\0';
fprintf(fp, "%s", recv_buf);
if(strcmp(recv_buf,"end")==0)
break;
}
}
}else if(strcmp(recv_buf, "quite")==0){
close(clnt_sock);
exit(0);
}
}
else continue;
}
}
//int log(int clnt_sock)
void z_handler(int sig) //좀비프로세스 처리하는 함수입니다..
{
pid_t pid;
int rtn;
pid = waitpid(-1, &rtn,WNOHANG);
}
void error_handling(char *message)//에러처리함수입니다..
{
fputs(message,stderr);
fputc('\n',stderr);
exit(1);
}
클라이언 트 소스:
문제가 서버에 있는것 같아 클라이언트 소스에 주석을 달지 않앗습니다..
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/time.h>
#define BUFSIZE 1000
#define DEFAULT_PORT 9999
void error_handling(char *);
int main(int argc, char **argv)
{
struct sockaddr_in serv_addr;
unsigned long dst_ip;
int port;
int serv_sock;
int str_len;
char recv_buf[BUFSIZE];
char send_buf[BUFSIZE];
struct timeval timeout;
fd_set readfd;
if(argc != 2 && argc !=3){
printf("Usage : %s <hostname><port>\n",argv[0]);
exit(1);
}
if (( dst_ip = inet_addr(argv[1]) )== INADDR_NONE){
struct hostent *he;
if((he = gethostbyname(argv[1])) == NULL ){
error_handling("gethostbyname error");
}
memcpy((char *)&dst_ip, (char *)he->h_addr, he->h_length);
}
// if(argc==3){
// if((port == atoi(argv[2]))==0){
// struct servent *se;
//;
// if((se = getservbyname(argv[2],"tcp"))!=NULL)
// port = (int)ntohs((u_short)se->s_port);
// else
// error_handling("getservbyport error");
// else
// port = DEFAULT_PORT;
// }
if((serv_sock = socket(PF_INET, SOCK_STREAM,0))==-1)
error_handling("socket erorr");
memset(&serv_addr,0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = dst_ip;
serv_addr.sin_port = htons(atoi(argv[2]));
if(connect(serv_sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)
)==-1)
error_handling("connect error");
while(1){
FD_ZERO(&readfd);
FD_SET(0,&readfd);
FD_SET(serv_sock,&readfd);
timeout.tv_sec = 100;
timeout.tv_usec = 0;
if((select(serv_sock+1, &readfd,NULL,NULL,&timeout))== -1){
error_handling("select erorr");
break;
}
if(FD_ISSET(0, &readfd)){
if(( str_len = read(0, send_buf, sizeof(send_buf)-1)) ==-1)
break;
send_buf[str_len]='\0';
if(send(serv_sock, send_buf, sizeof(send_buf),0) == -1)
break;
}
if(FD_ISSET(serv_sock, &readfd)){
if((str_len = recv(serv_sock, recv_buf, sizeof(recv_buf)-1,0))
==-1)
error_handling("recv error");
recv_buf[str_len]='\0';
printf("%s",recv_buf);
fflush(stdout);
}
}
strcpy(send_buf,"quit");
send(serv_sock,send_buf,sizeof(send_buf),0);
close(serv_sock);
return 0;
}
void error_handling(char *message)
{
fputs(message,stderr);
fputc('\n',stderr);
exit(1);
}
|
3206, 
6/161 
