가장 간단한 서버와 클라이언트 (CSocket 사용)

BOOL CListenThread::InitInstance()

{

// 	if (!AfxSocketInit())

// 	{

// 		AfxMessageBox(IDP_SOCKETS_INIT_FAILED);

// 		return FALSE;

// 	}

	m_bListening = TRUE;			//              

	while(1)

	{

		if(m_bListening)

		{

			StartListen();

		}

	}



	return TRUE;

}



int CListenThread::ExitInstance()

{

	StopListen();



	return CWinThread::ExitInstance();

}



BOOL CListenThread::StartListen()

{

	CString sResult;

	try

	{

		if(m_pListenSocket == NULL)

			m_pListenSocket = new CSocket;

		if(m_pListenSocket && m_pListenSocket->Create(m_nPort))		// Create()     Bind()

		{

			m_pListenSocket->Listen();

			m_pMainDlg->ShowInfo("      ");

			PostMessage(m_pMainDlg->GetSafeHwnd(), WM_ENABLE_LISTENING, 0, 0);

			while(1)

			{

				CSocket clientSocket;

				if(m_pListenSocket->Accept(clientSocket))

				{

					char buffer[1024] = {0};

					CString sText;

					clientSocket.Receive(buffer, 1024);

					sText = buffer;

					m_pMainDlg->ShowInfo(sText);



					CString s = "Thank you, JoeBlack";

					clientSocket.Send(s, s.GetLength());

//					send(clientSocket.m_hSocket, s, s.GetLength(), 0);		//       



					if(sText == "close")			// stop listening

					{

						StopListen();

						break;

					}

					else if(sText == "quit")		// post a message to let the main thread delete listen-thread

					{

						EndMyThread();

						return TRUE;

					}

				}

			}

			return TRUE;

		}

	}

	catch (CException* e)

	{

		char str[300] = {0};

		e->GetErrorMessage(str, 300);

		sResult.Format("      ，   ：%d", str);

		m_pMainDlg->ShowInfo(sResult);

	}

	catch(...)

	{

		int err;

		err = WSAGetLastError();

		sResult.Format("      ，   ：%d", err);

		m_pMainDlg->ShowInfo(sResult);

	}

	m_bListening = FALSE;



	return FALSE;

}



BOOL CListenThread::StopListen()					//        

{

	if(m_pListenSocket)

	{

		m_pListenSocket->Close();

		delete m_pListenSocket;

		m_pListenSocket = NULL;

		m_pMainDlg->ShowInfo("Stop listening successful");

		m_bListening = FALSE;

		m_pMainDlg->PostMessage(WM_ENABLE_LISTENING, 1, 0);	//  “    ”      

	}

	return TRUE;

}



BOOL CListenThread::EndMyThread()						//   CSocket      

{

	StopListen();

	m_pMainDlg->ShowInfo("Exit from Listen-Thread");

	PostMessage(m_pMainDlg->GetSafeHwnd(), WM_FREE_LISTENTHREAD, 0, 0);



	return TRUE;

}

void CClientAppDlg::OnBtnSend()

{

	CSocket sendSocket;

	if(sendSocket.Create())

	{

		if(sendSocket.Connect("127.0.0.1", 5050))

		{

			UpdateData();

			sendSocket.Send(m_strEdit, m_strEdit.GetLength());

			Sleep(100);  //           



			char buf[1024] = {0};

			CString sResponse;

			while(sendSocket.Receive(buf, 1024))

			//while(recv(sendSocket, buf, 1024, 0))

			{

				sResponse += buf;

			}



			MessageBox(sResponse);

			sendSocket.Close();

		}

	}

}