티스토리 툴바

Daum
Tistory
로그인
보이기/숨기기 가능합니다^^
분류 전체보기 (48)
Linux (2)
Database (6)
C (0)
C++ (0)
C# (9)
Java (9)
TCP / IP (2)
etc... (15)
알고리즘 (0)
보이기/숨기기 가능합니다^^
2011/12 (2)
2011/07 (2)
2011/03 (1)
2011/01 (1)
2010/12 (1)
'IOCP'에 해당되는 글 2건
[ java ] - IOCP chatting rev 0.001 2009/06/10
[ tcp / ip ] - Echo Server 2009/06/01 (1)
[ java ] - IOCP chatting rev 0.001
Java | 2009/06/10 20:07
SimpleChatServer.java
SimpleChatClient.java


좀..-_-
chatting, client, IOCP, java, server
Trackback 0 : Comment 0
위로
http://gustmder.tistory.com/trackback/101 관련글 쓰기
[ tcp / ip ] - Echo Server
TCP / IP | 2009/06/01 13:43
  1. #include <iostream>
  2. #include <winsock2.h>
  3. #pragma comment(lib, "ws2_32.lib")
  4. using namespace std;

  6. const int MAX_LEN = 100;
  7. typedef struct
  8. {
  9.     SOCKET hClntSock;
  10.     SOCKADDR_IN clntAddr;
  11. }PER_HANDLE_DATA, *LPPER_HANDLE_DATA;

  13. typedef struct
  14. {
  15.     OVERLAPPED overlapped;
  16.     char buffer[MAX_LEN];
  17.     WSABUF wsaBuf;
  18. }PER_IO_DATA, *LPPER_IO_DATA;

  20. DWORD WINAPI CompletionThread(LPVOID ComplectionPortIO);
  21. void ErrorHandling(char * msg);

  23. int main(void)
  24. {
  25.     WSADATA wsaData;
  26.     HANDLE hCompletionPort;
  27.     SYSTEM_INFO SystemInfo;
  28.     SOCKADDR_IN servAddr;
  29.     LPPER_IO_DATA PerIoData;
  30.     LPPER_HANDLE_DATA PerHandleData;

  32.     SOCKET hServSock;
  33.     unsigned long RecvBytes;
  34.     unsigned long i, Flags;

  36.     if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
  37.         ErrorHandling("윈속초기화에러");

  39.     //1. Completion Port 생성
  40.     hCompletionPort = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL,0, 0);
      
  41. GetSystemInfo(&SystemInfo);

  43.     //2. 쓰레드를 CPU 개수만큼 생성.
  44.     for (i = 0; i < SystemInfo.dwNumberOfProcessors; i++)
  45.         CreateThread(NULL, 0, CompletionThread, (LPVOID)hCompletionPort, 0, NULL);

  47.     hServSock = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);
  48.     servAddr.sin_family = AF_INET;
  49.     servAddr.sin_addr.s_addr = htonl(INADDR_ANY);
  50.     servAddr.sin_port = htons((u_short)atoi("9999"));

  52.     bind(hServSock, (SOCKADDR * )&servAddr, sizeof(servAddr));
  53.     listen(hServSock, 5);

  55.     while (true)
  56.     {
  57.         SOCKET hClntSock;
  58.         SOCKADDR_IN clntAddr;

  60.         int addrLen = sizeof(clntAddr);

  62.         hClntSock = accept(hServSock, (SOCKADDR *)&clntAddr, &addrLen);

  64.         // 연결된 클라이언트의 소켓 핸들 정보와 주소 정보를 설정.
  65.         PerHandleData =
  66. (LPPER_HANDLE_DATA)malloc(sizeof(PER_HANDLE_DATA));
  67.         PerHandleData->hClntSock = hClntSock;
  68.         memcpy(&(PerHandleData->clntAddr), &clntAddr, addrLen);
  69.        
  70.         //3. Overlapped 소켓과 CompletionPort의 연결.
  71.         CreateIoCompletionPort((HANDLE)hClntSock, hCompletionPort, (DWORD)PerHandleData, 0);

  73.         //클라이언트를 위한 버퍼를 설정, OVERLAPPED 변수 초기화
  74.         PerIoData = (LPPER_IO_DATA)malloc(sizeof(PER_IO_DATA));
  75.         memset(&(PerIoData->overlapped), 0, sizeof(OVERLAPPED));
  76.         PerIoData->wsaBuf.len = MAX_LEN;
  77.         PerIoData->wsaBuf.buf = PerIoData->buffer;
  78.         Flags = 0;

  80.         //4. 중첨된 데이터 입력.
  81.         WSARecv(PerHandleData->hClntSock,    // 데이터 입력소켓.
                    &(PerIoData->wsaBuf),        //데이터 입력 버퍼 포인터.
                    1,                            //데이터 입력버퍼의 수.
                    &RecvBytes,
                    &Flags,
                    &(PerIoData->overlapped),    //OVERLAPPED 변수 포인터.
                    NULL);
  82.     }
  83.     return 0;
  84. }

  86. DWORD WINAPI CompletionThread(LPVOID pComPort)
  87. {
  88.     HANDLE hCompletionPort = (HANDLE)pComPort;
  89.     DWORD BytesTransferred;
  90.     LPPER_HANDLE_DATA PerHandleData;
  91.     LPPER_IO_DATA PerIoData;

  93.     DWORD Flags;

  95.     while (true)
  96.     {
  97.         //5. 입. 출력이 완료된 소켓의 정보를 얻음.
  98.         GetQueuedCompletionStatus(hCompletionPort,    //Completion Port
                                      &BytesTransferred, //전송된 바이트수.
                                      (LPDWORD)&PerHandleData,
                                      (LPOVERLAPPED *)&PerIoData,
                                      INFINITE);

  99.         if (BytesTransferred == 0) // EOF전송시
  100.         {
  101.             closesocket(PerHandleData->hClntSock);
  102.             free(PerHandleData);
  103.             free(PerIoData);
  104.             continue;
  105.         }

  107.         //6. 메시지! 클라이언트로 에코.
  108.         PerIoData->wsaBuf.len = BytesTransferred;
  109.         WSASend(PerHandleData->hClntSock, &(PerIoData->wsaBuf), 1, NULL, 0, NULL, NULL);

  111.         //Receive Again
  112.         memset(&(PerIoData->overlapped), 0, sizeof(OVERLAPPED));
  113.         PerIoData->wsaBuf.len = MAX_LEN;
  114.         PerIoData->wsaBuf.buf = PerIoData->buffer;

  116.         Flags = 0;

  118.        WSARecv(PerHandleData->hClntSock, &(PerIoData->wsaBuf), 1, NULL, &Flags, &(PerIoData->overlapped), NULL);
  119.     }
  120.     return 0;
  121. }


  124. void ErrorHandling(char * msg)
  125. {
  126.     fputs(msg, stderr);
  127.     fputc('\n', stderr);
  128.     exit(1);
  129. }
C, echo server, IOCP, server
Trackback 0 : Comment 1
위로
http://gustmder.tistory.com/trackback/96 관련글 쓰기
From. 한남자＠ 2009/08/02 02:41
PERMALINKDELETE/MODIFYREPLY
echo 서버
공부한지 얼마 안된거라 그런지 눈에 들어오네요ㅋㅋㅋㅋㅋ
이전 페이지
[1]
다음 페이지
보이기/숨기기 가능합니다^^
«   2012/02   »
일 월 화 수 목 금 토
      1 2 3 4
5 6 7 8 9 10 11
12 13 14 15 16 17 18
19 20 21 22 23 24 25
26 27 28 29      
보이기/숨기기 가능합니다^^
RSSFeed