기술 [ 김택환(강상은,이건주,주옥찬,최현식) ] WSAEventSelect 를 이용한 파일전송

[21기 김택환]

WSAEventSelect실습	작성자 : 김택환 강상은, 이건주, 주옥찬, 최현식
	작성일 : 2011.2.14
제목 : WSAEventSelect를 이용한 파일 전송 기술 문서

1.프로그램 설명

CLIENT에서는 5개의 Thread로 5개의 파일을 전송한다.

SERVER에서는 WSAEventSelect를 이용하여 파일을 전송 받는다.

2.함수 소개

2-1.SERVER(EventSelect관련함수)

①WSACreateEvent(), WSACloseEvent()

WSAEVENT WSACreateEvent(void)

새로운 이벤트 객체를 생성하는 함수

BOOL WSACloseEvent(WSAEVENT hEvent)

이벤트 객체를 제거하는 함수

②WSAEventSelect()

int WSAEventSelect(SOCKET s, WSAEVENT hEvent,long lNetWorkEvents)

소켓과 이벤트 객체를 짝지으고 처리할 네트워크 이벤트를 등록한다.

③WSAWaitForMultipleEvents()

DWORD WSAWaitForMultipleEvents(

        DWORD               cEvents,//lphEvents의 이벤트 핸들의 개수(이벤트 객체 핸들의 최대 개수는 WSA_MAXIMUM_EVENTS 이다.)

        const WSAEVENT FAR*     lphEvents,//이벤트 객체 핸들의 배열

        BOOL                             fWaitAll,//기다림의 형태를 명시(TRUE이면 모든 이벤트 객체가 같은 시간에 신호를 받을 때 반환,FALSE이면 이벤트 객체 중 하나가 신호를 받을 때 반환됨.

        DWORD                 dwTimeOUT,//타임 아웃간격 m/sec(1/1000초) WSA_INFINITE : 시그널 상태가 될 때까지 반환하지 않음.

        BOOL                       fAlertable//시스템이 함수를 호출하는  쓰레드의 실행에 대한 I/O완료루틴을 큐 시켰을 때 함수가 반환될지를 명시. TRUE일 경우 완료루틴은 실행되고 함수는 반환된다. FALSE라면 완료루틴은 함수가 반환될 때 실행되지 않음.

)

신호를 받았을 때에 대기상태가 완료된 이벤트 객체 배열의 인덱스를 반환함.

④WSAEnumNetworkEvent()

int WSAEnumNetworkEvent(SOCKET s, WSAEVENT hEvent, LPWSANETWORKEVENTS lNetWorkEvents)// LPWSANETWORKEVENTS 구조체의 lNetWorkEvents맴버는 FD_READ와 같은 네트웍 이벤트가 발생됨을 명시

지정된 소켓에 대한 네트웍 이벤으의 발생을 알아낸다.

2-2.CLIENT(파일 전송 관련함수,구조체)

①WIN32_FIND_DATA구조체

typeef struct _WIN32_FINDdATA

{

    DWORD dwFileAttributes;     //검색한 파일의 속성을 나타내는 상수값

    FILETIME ftCreateionTime;      //파일이 만들어진 시간

    FILETIME ftLastAccessTime;   //마지막으로 읽었던 시간

    FILETIME ftLastWriteTime;       //마지막으로 기록했던 시간

    DWORD nFileSizeHigh;           //파일의 크기

    DWORD nFileSizeLow;           //파일의 크기

    DWORD dwReserved0;          //미래의 파일형태를 위한 예약 공간

    DWORD dwReserved1;         //미래의 파일형태를 위한 예약 공간

    TCHAR cFileName[MAX_PATH];    //파일명: 윈도우즈 형태

    TCHAR cAlternateFileName[14];     //파일명: 도스 형태

}WIN32_FIND_DATA;

②FindFirstFile(), FindClose()

HANDLE FindFirstFile(LPCTSTR lpFileName, //파일명

LPWIN32_FIND_DATA lpFindFileData); // WIN32_FIND_DATA구조체

지정한 파일과 일치하는 파일을 검사하여 그파일의 정보를 받아서 wfd구조체에 저장

BOOL FindClose (HANDLE hFindFile);

생성된 핸들을 닫는다.

3.사용 절차

3-1.SERVER

①socket을 생성할 때마다 해당 socket을 WSACreateEvent()함수를 이용하여

벤트 객체를 생성
②socket과 이벤트 객체를 짝짓기 위하여 WSAEventSelect()함수를 사용 그리고

받을 socket메시지를 등록
③WSAWaitForMultipleEvents()함수를 호출하여 이벤트 객체가 신호 상태가

되기를 기다린다. 등록한 네트워크 이벤트가 발생하면 해당 socket과 연관된

이벤트 객체가 signaled상태가 된다.
④WSAEnumNetworkEvent()함수를 호출하여 이벤트 객체에 어떤 socket메시지

가 왔는지 검사하며 처리를 한다.

⑤WSACloseEvent()함수를 사용하여 Event객체 핸들을 소멸 합니다.

4-1.실제 사용 절차(CLIENT)

WIN32_FIND_DATA wfd;
FindClose(FindFirstFile(fname,&wfd)

char buf[1000];

strcpy(buf,fname);

*((int *)(buf+FNLEN)) = wfd.dwFileAttributes;

*((int *)(buf+FNLEN+sizeof(int))) = wfd.nFileSizeLow;

send(sock,buf,1000,0);

HANDLE hFile;

DWORD dwRead;

hFile = CreateFile(fname,GENERIC_READ,0,0,OPEN_EXISTING,

wfd.dwFileAttributes,0);

while(wfd.nFileSizeLow>1000) //파일을 1000 씩 잘라서 전달한다.

{

         ReadFile(hFile,buf,1000,&dwRead,0);

         send(sock,buf,1000,0);

         wfd.nFileSizeLow -= 1000;

}

if(wfd.nFileSizeLow)

{

         ReadFile(hFile,buf,wfd.nFileSizeLow,&dwRead,0);

         send(sock,buf,1000,0);

}

4-2.실제 사용 절차(SERVER)

app.hEarr[app.now] = WSACreateEvent();

WSAEventSelect(app.sarr[app.now],app.hEarr[app.now],FD_ACCEPT);

app.now++;

WSANETWORKEVENTS ev;

int index;

while(1)

{

index=WSAWaitForMultipleEvents(app.now,app.hEarr,FALSE,WSA_INFINITE,FALSE);

         index -= WSA_WAIT_EVENT_0;

         WSAEnumNetworkEvents(app.sarr[index],app.hEarr[index],&ev);

         switch(ev.lNetworkEvents)

         {

         case FD_ACCEPT:     AcceptProc(index);            break;

         case FD_READ:        ReadProc(index);               break;

         case FD_CLOSE:       CloseProc(index);              break;

         }

}

void ReadProg(int index)

{

         if(app.hFileArr[index] != INVALID_HANDLE_VALUE)

         {

                  RecvFileFrag(index);

void RecvFileFrag(int index)

{

         char buf[1000];

         SOCKET sock = app.sarr[index];

         DWORD dw;

         recv(sock,buf,1000,0);

         if(app.fsize[index] >= 1000)

         {

                  WriteFile(app.hFileArr[index],buf,1000,&dw,0);

         }Else{

                  WriteFile(app.hFileArr[index],buf,app.fsize[index],&dw,0);       

         }

         app.fsize[index] = app.fsize[index] - dw;

         if(app.fsize[index] == 0){

                  send(app.sarr[index],buf,1,0);

         }

}

         }else

         {

                  RecvFileInfo(index);//파일의 정보를 받는다.

void RecvFileInfo(int index)

{

char buf[1000];

SOCKET sock = app.sarr[index];

recv(sock,buf,1000,0);

memcpy(app.fname[index],buf,FILE_NAME_LEN);

int fattr = *((int *)(buf + FILE_NAME_LEN));

app.fsize[index] = *((int *)(buf+FILE_NAME_LEN+sizeof(int)));

app.hFileArr[index] = CreateFile(buf,GENERIC_WRITE,0,0,CREATE_ALWAYS,fattr,0);

printf("[ %s ]다운로드시작\n",app.fname[index]);

}

         }

}

5.프로그램 실행화면