수다닷컴

  • 해외여행
    • 괌
    • 태국
    • 유럽
    • 일본
    • 필리핀
    • 미국
    • 중국
    • 기타여행
    • 싱가폴
  • 건강
    • 다이어트
    • 당뇨
    • 헬스
    • 건강음식
    • 건강기타
  • 컴퓨터
    • 프로그램 개발일반
    • 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

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

  • 검사

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

  • 허리달

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

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

번호 제 목 글쓴이 날짜
2700041 초보인데요 ㅎ 배열안에 배열을 집어넣을수 있나요?? 헛장사 2025-07-01
2700012 배열// (1) 전갈자리 2025-07-01
2699895 무한루프에 빠집니다.!! 해결좀부탁드려요 (10) 선아 2025-06-30
2699842 질문을 너무 많이 하네여.....죄송.... (2) 해님꽃 2025-06-29
2699816 오류 질문입니다.. (1) 해비치 2025-06-29
2699763 질문입니다 ! 꼭 좀 도와주세요ㅠㅠ (2) 미라 2025-06-28
2699555 c언어 다항식을 입력을 했는데 왜 출력이 안될까요? 피스케스 2025-06-27
2699528 C언어 포인터연산 질문입니다. (3) 안녕나야 2025-06-26
2699476 끌어올림;;달력 짜봤는데요 이 소스 줄일 수 있나요? - 스샷첨부 (2) 클라우드 2025-06-26
2699444 [좀 급함] system("explorer [주소] ") 문에 변수를 사용할 수 있나요? 알 2025-06-26
2699415 파일//read//와 배열 아란 2025-06-25
2699386 구조체 안에 일부분만 char 배열에 복사하려면 어떻게 해야하나요? (1) 미즈 2025-06-25
2699361 연결리스트 정렬하는 부분에 대해서 질문 드립니다 아이처럼 2025-06-25
2699304 [기초]아직 안주무시는분 계신가요..?포인터배열? 좀 도와주세요. 놀리기 2025-06-24
2699272 printf() 함수이용해서 프로그램 만들기 질문요! (5) 다가 2025-06-24
2699221 PUSH와 POP코드를 더 간단하게 어떻게 해야할까요? 파라미 2025-06-24
2699192 설치오류가 자꾸 나요 한번봐주세여~ (1) 소녀틳향기 2025-06-23
2699161 for loop안에 있는 if문 (9) Orange 2025-06-23
2699105 링크더리스트 이전 링크값 출력함수. 꼬꼬마 2025-06-23
2699078 정수를 한자리씩 배열에 담는 법은 어떻게 하나요.. (4) 귀염포텐 2025-06-22
<<  이전  1 2 3 4 5 6 7 8 9 10  다음  >>

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