수다닷컴

  • 해외여행
    • 괌
    • 태국
    • 유럽
    • 일본
    • 필리핀
    • 미국
    • 중국
    • 기타여행
    • 싱가폴
  • 건강
    • 다이어트
    • 당뇨
    • 헬스
    • 건강음식
    • 건강기타
  • 컴퓨터
    • 프로그램 개발일반
    • C언어
    • 비주얼베이직
  • 결혼생활
    • 출산/육아
    • 결혼준비
    • 엄마이야기방
  • 일상생활
    • 면접
    • 취업
    • 진로선택
  • 교육
    • 교육일반
    • 아이교육
    • 토익
    • 해외연수
    • 영어
  • 취미생활
    • 음악
    • 자전거
    • 수영
    • 바이크
    • 축구
  • 기타
    • 강아지
    • 제주도여행
    • 국내여행
    • 기타일상
    • 애플
    • 휴대폰관련
  • 프로그램 개발일반
  • C언어
  • 비주얼베이직

멀티스레드를 이용한 소켓프로그래밍 질문

VE

2023.04.01

#includestdio.h
#includestdlib.h
#includewinsock2.h
#includewindows.h
#includeprocess.h
DWORD WINAPI Server(void *arg);
DWORD WINAPI Client(void *arg);
void ErrorDisplay(char *szError);
void ErrorPrint(char *szError);
int main(int argc, char** argv)
{
HANDLE sThread;
DWORD sThreadID;
HANDLE cThread;
DWORD cThreadID;
sThread=(HANDLE)_beginthreadex(NULL,0,Server,NULL,0,(unsigned*)&sThreadID);
if(sThread==0)
{
puts(_beginthreadex() error);
exit(1);
}
cThread=(HANDLE)_beginthreadex(NULL,0,Client,NULL,0,(unsigned*)&cThreadID);
if(cThread==0)
{
puts(_beginthreadex() error);
exit(1);
}
Sleep(3000);
return 0;
}

DWORD WINAPI Server(void *arg)
{
int ret;
WSADATA wsa;
SOCKET s;
SOCKADDR_IN saddr;
SOCKADDR_IN caddr;
int caddrlen;
SOCKET cs;
int nSend;
ret = WSAStartup(MAKEWORD(2,2),&wsa);
if(ret != 0)
{
ErrorDisplay(WSAStartup);
}s = socket(AF_INET,SOCK_STREAM,0);
if(s==INVALID_SOCKET)
{
ErrorDisplay(socket());
}ZeroMemory(&saddr,sizeof(saddr));
saddr.sin_family = AF_INET; // 주소체계
saddr.sin_port = htons(5000); // 포트 번호
saddr.sin_addr.s_addr = htonl(INADDR_ANY); // 네트워크 카드 설정
//saddr.sin_addr.s_addr = inet_addr(127.0.0.1);
ret = bind(s,(SOCKADDR *)&saddr,sizeof(saddr));
if(ret == SOCKET_ERROR)
{
ErrorDisplay(bind());
}ret = listen(s,SOMAXCONN);
if(ret == SOCKET_ERROR)
{
ErrorDisplay(listen());
}
while(TRUE)
{
caddrlen =sizeof(caddr);
cs = accept(s,(SOCKADDR*)&caddr,&caddrlen);
if(cs == INVALID_SOCKET)
{
ErrorPrint(accept());
continue;
}printf(클라이언트 IP : %s\n,inet_ntoa(caddr.sin_addr));
printf(클라이언트 port: %d\n,ntohs(caddr.sin_port));
//클라이언트의 데이터 수신 및 재송신(Echo Server)
while(TRUE)
{
char buf[1024];
int nRecv;
memset(buf,0,sizeof(buf));nRecv = recv(cs,buf,sizeof(buf),0);
if(nRecv == SOCKET_ERROR)
{
ErrorPrint(recv());
break;
}
else if(nRecv == 0)
{
printf(클라이언트와의 접속이 끊어졌습니다.\n);
}
else
{
//받은 데이터 출력
printf(%d 바이트 수신 :%s\n,nRecv,buf);nSend = send(cs,buf,nRecv,0);
if(nSend == SOCKET_ERROR)
{
ErrorPrint(send());
break;
}}
}Sleep(8000);closesocket( cs );
}// 서버 접속용 소켓을 해제한다.closesocket( s );

WSACleanup();return 0;
}
DWORD WINAPI Client(void *arg)
{
int ret;
WSADATA wsa;
SOCKET s;
SOCKADDR_IN saddr;ret=WSAStartup(MAKEWORD(2,2),&wsa);
if(ret != 0)
{
ErrorDisplay(WSAStartup);
}
s = socket(AF_INET,SOCK_STREAM,0);
if(s == INVALID_SOCKET)
{
ErrorDisplay(socket());
}
saddr.sin_family = AF_INET;
saddr.sin_port = htons(5000);
saddr.sin_addr.s_addr = inet_addr(192.168.0.222);
ret = connect(s,(SOCKADDR*)&saddr,sizeof(saddr));
if(ret != 0)
{
ErrorDisplay(connect());
}
while(TRUE)
{
char buf[1024];
int nSend;
int nRecv;memset( buf, 0, sizeof buf );
gets( buf );
// scanf(%s,buf); //공백 포함을 안함..!!
nSend = send(s,buf,strlen(buf),0);
if(nSend == SOCKET_ERROR){
ErrorPrint(send());
break;
}
nRecv = recv(s,buf,sizeof(buf),0);
if(nRecv == SOCKET_ERROR)
{
ErrorPrint(recv());
break;
}
else if(nRecv == 0)
{
printf(클라이언트와 접속이 끊어졌습니다.\n);
break;
}
else
{
printf( %d 바이트 수신 : %s \n, nRecv, buf );
}Sleep(6000);
}
closeso;closesocket(s);
WSACleanup();
return 0;
}void ErrorDisplay(char *szError)
{
LPVOID lpBuff;
FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER |
FORMAT_MESSAGE_FROM_SYSTEM,
NULL,
WSAGetLastError(), // 에러 코드를 읽어 옴
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
(LPTSTR)&lpBuff,
0,
NULL );
MessageBox( NULL, (LPCTSTR)lpBuff, szError, MB_ICONSTOP );
LocalFree( lpBuff );
exit( 0 ); // 프로그램을 종료
}void ErrorPrint(char *szError)
{
LPVOID lpBuff;
FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER|
FORMAT_MESSAGE_FROM_SYSTEM,
NULL,
WSAGetLastError(),
MAKELANGID(LANG_NEUTRAL,SUBLANG_DEFAULT),
(LPTSTR)&lpBuff,
0,
NULL);
printf(%s : %s\n,szError,lpBuff);
LocalFree(lpBuff);
}
한개의 프로젝트에서 서버와 클라이언트를 합쳐봤습니다. Sleep함수를 써서 시간을 늦춰봤는데 4초정도 있다가 종료됩니다.아직 초보라서 어디가 문제점인지 모르겠습니다. 소켓을 닫을때 문제인거 같은데 ,,, 좀 알려주세요아이피는 본인 아이피 넣어서 실행시켜보시면 됩니다,.. ㅠㅠ

신청하기





COMMENT

댓글을 입력해주세요. 비속어와 욕설은 삼가해주세요.

  • 검사

    음.. 그러니깐 서버가 열린상태에서 계속 대기를해야되는데 몇초가 지나면 실행된게 종료됩니다..

  • 허리달

    질문의 요지가 좀 정확했으면..

    이러한 문제가 발생했는데, 이부분이 문제인거같은데 해결방법을 모르겠다. 라는 식으로..

번호 제 목 글쓴이 날짜
2694778 순열 계산요. 맛조이 2025-05-14
2694754 ShowWindow 함수를 이용하려 하는데 질문있습니다. (2) 파도 2025-05-14
2694731 리눅스 커널의 시작점 질문 미르 2025-05-13
2694702 이거 뭐가문제인가요 코드수정좀 (3) 맑은 2025-05-13
2694675 C언어 후위표기를 중위표기로 앨런 2025-05-13
2694646 안녕하세요 파일 합치기 함수! (1) 연블루 2025-05-13
2694618 잘몰라서 설명부탁드립니다. scanf 관련 (3) 파라 2025-05-12
2694590 이 코드가 뭐하는 코드일까요? #2 빵순 2025-05-12
2694559 동적할당으로 배열(2차원열)을 만드는데 있어 그걸 함수화시키는데... (1) 늘솔길 2025-05-12
2694532 네트워크에 관하여... (4) 황소자리 2025-05-12
2694503 프로그램 연산 후 바로 종료되는 현상 (6) Judicious 2025-05-11
2694450 while문질문입니다. (1) 허리품 2025-05-11
2694420 C언어 질문할게요(유니코드,자료형,버퍼,캐스트연산자) 은새 2025-05-11
2694370 내일까진데 함수호출 제발 도와주세요!!!!!!!!!11 들찬 2025-05-10
2694339 putchar()의 괄호 안에 int c=10;로 전에 선언된 c를 넣으면 안되는 이유에서 제가 생각한 것이 그 이유가 되는지 확인하고 싶습니다. (3) 미르 2025-05-10
2694316 이 코드 어디가 잘못되었는지 고수분들 ㅠㅠ (2) 나빛 2025-05-10
2694285 언어 공부하는 과정 좀 추천해주세요! (1) 아빠몬 2025-05-09
2694258 카운터.. 질문입니다. (4) 하늘빛눈망울 2025-05-09
2694229 단순한 질문이요 (8) 여름 2025-05-09
2694202 용돈을 가지고 할 수 있는 일을 여러가지로 출력하는 방법 좀 알려주세요! (2) 미나 2025-05-09
<<  이전  1 2 3 4 5 6 7 8 9 10  다음  >>

수다닷컴 | 여러분과 함께하는 수다토크 커뮤니티 수다닷컴에 오신것을 환영합니다.
사업자등록번호 : 117-07-92748 상호 : 진달래여행사 대표자 : 명현재 서울시 강서구 방화동 890번지 푸르지오 107동 306호
copyright 2011 게시글 삭제 및 기타 문의 : clairacademy@naver.com