TcpCAsyncClient

class CMyAsysncSocket : public CAsyncSocket { public: public: CMyAsyncSocket(); virtual ~CMyAsyncSocket(); char m_SendBuf[4096]; //보낼데이터 버퍼 char* m_pSendCurBuf; //보내야할 버퍼 현재 위치 int m_nSendLeft; //보내기 위해 남은 길이 BOOL AsyncSend(char* pBuf, int nLen); void DoSenBuf(); public: public: virtual void OnConnect(int nErrorCode); virtual void OnRecevie(int nErrorCode); virtual void OnSend(int nErrorCode); virtual void OnClose(int nErrorCode); protected: }; #include "stdafx.h" #include "TcpCAsyncClient.h" #include "MyAsyncSocket.h" CMyAsyncSocket::CMyAsyncSocket() { m_nSendLeft = 0; m_pSendCurBuf = m_SendBuf; } CMyAsyncSocket::~CMyAsyncSocket() { } void CMyAsyncSocket::OnConnect(int nErrorCode) { if( nErrorCode == 0 ) { AfxMessageBox( "접속 성공" ); } else { int err = GetLastError(); AfxMessageBox( "접속 실패" ); } CAsyncSocket::OnConnect(nErrorCode); } void CMyAsyncSocket::OnReceive(int nErrorCode) { char buf[4096]; ZeroMemory( buf, 4096 ); int nRead = Receive( buf, 4096 ); if( nRead == 0 ) // 연결이 끊어졌다. Close(); else if( nRead == SOCKET_ERROR ) { int nErr = GetLastError(); // 네트워크 리소스를 잠시 사용 못하는 경우가 아닌 모든 오류시 연결 끊음 if( nErr != WSAEWOULDBLOCK ) Close(); } else { // 데이터를 받았다. AfxMessageBox( buf ); } CAsyncSocket::OnReceive(nErrorCode); } BOOL CMyAsyncSocket::AsyncSend( char* pBuf, int nLen ) { // 현재 이 버전은 보낼 데이터를 버퍼 큐로 쌓아 놓지 않는다. if( m_nSendLeft != 0 ) { AfxMessageBox( "아직 보내야할 데이터를 다 보내지 못했습니다." ); return FALSE; } // 현재 버전은 고정 크기의 버퍼에 담아 보내기 때문에 버퍼 크기보다 // 큰 데이터를 한번에 보낼 수 없다. if( nLen > 4096 ) { AfxMessageBox( "버퍼 크기보다 큰 데이터를 보낼 수 없습니다." ); return FALSE; } // 보낼 데이터를 보내기버퍼에 복사한다. memcpy( m_SendBuf, pBuf, nLen ); m_pSendCurBuf = m_SendBuf; m_nSendLeft = nLen; // 버퍼 보내기를 시도한다. DoSendBuf(); return TRUE; } void CMyAsyncSocket::DoSendBuf() { while( m_nSendLeft > 0 ) { int nSend; nSend = Send( m_pSendCurBuf, m_nSendLeft ); if( nSend == SOCKET_ERROR ) { int nErr = GetLastError(); if( nErr == WSAEWOULDBLOCK ) break; else { Close(); m_nSendLeft = 0; AfxMessageBox( "보내기에 실패하여 연결을 끊습니다." ); return; } } else { // 보내기 성공으로 현재 보내야 할 위치와 남은 양을 변경 m_pSendCurBuf += nSend; m_nSendLeft -= nSend; } } } void CMyAsyncSocket::OnSend(int nErrorCode) { DoSendBuf(); CAsyncSocket::OnSend(nErrorCode); } void CMyAsyncSocket::OnClose(int nErrorCode) { Close(); AfxMessageBox( "접속 종료" ); CAsyncSocket::OnClose(nErrorCode); } #include "stdafx.h" #include "TcpCAsyncClient.h" #include "TcpCAsyncClientDlg.h" CTcpCAsyncClientApp::CTcpCAsyncClientApp() { // TODO: add construction code here, // Place all significant initialization in InitInstance } CTcpCAsyncClientApp theApp; BOOL CTcpCAsyncClientApp::InitInstance() { if (!AfxSocketInit()) { AfxMessageBox(IDP_SOCKETS_INIT_FAILED); return FALSE; } AfxEnableControlContainer(); #ifdef _AFXDLL Enable3dControls(); #else Enable3dControlsStatic(); #endif CTcpCAsyncClientDlg dlg; m_pMainWnd = &dlg; int nResponse = dlg.DoModal(); if (nResponse == IDOK) { } else if (nResponse == IDCANCEL) { } return FALSE; }