CSocket派生于CAsyncSocket, 所有施諸于上的操作皆為同步操作。比如Connnect,Receive等。
同步操作的優點是簡單易用，但缺點也顯而易見，效率低下，因為你必須等到一個操作完成之后才能進行下一個操作。
如果你很關心效率，就應該優先使用CAsyncSocket。反之就用CSocket。
下面將說明如何用CSocket創建簡單的服務器和客戶端。
[創建服務器]
服務器的運作有5個階段:
1. 創建服務器Socket并開啟監聽。
2. 獲取新的客戶端連接Socket，將之加入客戶端Socket列表以管理之。
3. 客戶端Socket讀取數據并發送數據。
4. 客戶端連接被動關閉，從列表刪除。
5. 程序關閉，進而服務器連接主動關閉。
為了維持5階段的運作，需要兩種Socket協同工作, 第一種用作服務器監聽（負責步驟1，2，5），第二種用作客戶端管理（負責步驟3，4）。
兩種Socket皆派生自CSocket, 通過重寫不同的CSocket成員函數以實現不同的功能。
前者需要在服務器初始化階段創建出來CSocket::Create()并開啟監聽CSocket::Listen()（步驟1）。并在服務器退出時主動關閉連接CSocket::Close()（步驟5）。
前者還需要重寫OnAccept以在新的客戶端連接到來時被通知，同時產生客戶端管理Socket（步驟2）。
后者需要重寫OnReceive以在有數據到來時被通知，或重寫OnClose以在連接被動關閉（客戶端關閉）時被通知（步驟3，4）。
讀寫數據需要CSocketFile以及CArchieve的支持。前者將CSocket當作一個文件，后者則完成在此文件上的讀寫操作。
通常你需要添加一個CSocketFile成員，兩個CArchieve成員（一個用于讀，一個用于寫），然后在Socket創建完成后初始化這些成員
socketFile_ = new CSocketFile( this ); // 在archive創建出來后基本上就不需要操作他了，直到Socket關閉
archiveIn_ = new CArchive( socketFile_, CArchive::load ); // 用于讀
archiveOut_ = new CArchive( socketFile_, CArchive::store ); // 用于取
并在OnRecevie中用archiveIn_讀取數據，用archiveOut_寫入數據。像這樣：
int value;
archiveIn_ >> value;
archiveOut_ << value * value;
下面是比較完整的Server端的源代碼:
//---------------------------------------------------------------------------------
// CServerDoc.cpp
//---------------------------------------------------------------------------------
BOOL CServerDoc::OnNewDocument()
{
...
serverSocket_ = new CServerSocket( this );
serverSocket_->Create( 5001 );
serverSocket_->Listen( 5 );
return TRUE;
}
void CServerDoc::DeleteContents()
{
// TODO: Add your specialized code here and/or call the base class
delete serverSocket_;
serverSocket_ = NULL;
// 主動斷開連接
// release all client sockets
POSITION position = clientSockets_.GetHeadPosition();
while ( position != NULL ) {
delete clientSockets_.GetNext( position );
}
clientSockets_.RemoveAll();
CDocument::DeleteContents();
}
void CServerDoc::OnAccept()
{
CClientSocket* newClientSocket = new CClientSocket( this );
serverSocket_->Accept( *newClientSocket );
newClientSocket->Initialize();
clientSockets_.AddTail( newClientSocket );
}
// 被動斷開連接
void CServerDoc::OnClose( CClientSocket* clientSocket )
{
POSITION position = clientSockets_.Find( clientSocket );
clientSockets_.RemoveAt( position );
delete clientSocket;
}
void CServerDoc::OnReceive( CClientSocket* clientSocket )
{
// receive data with clientSocket
}
//---------------------------------------------------------------------------------
// CServerSocket.cpp
//---------------------------------------------------------------------------------
CServerSocket::CServerSocket( CServerDoc* document )
: document_( document )
{
}
CServerSocket::~CServerSocket()
{
}
void CServerSocket::OnAccept(int nErrorCode)
{
// TODO: Add your specialized code here and/or call the base class
document_->OnAccept();
CSocket::OnAccept(nErrorCode);
}
//---------------------------------------------------------------------------------
// CClientSocket.cpp
//---------------------------------------------------------------------------------
CClientSocket::CClientSocket( CServerDoc* document )
: document_( document )
, socketFile_( NULL )
, archiveIn_( NULL )
, archiveOut_( NULL )
{
}
CClientSocket::~CClientSocket()
{
delete archiveIn_;
archiveIn_ = NULL;
delete archiveOut_;
archiveOut_ = NULL;
// 必須在刪除archive以后刪除
delete socketFile_;
socketFile_ = NULL;
}
void CClientSocket::OnClose(int nErrorCode)
{
// TODO: Add your specialized code here and/or call the base class
CSocket::OnClose(nErrorCode);
document_->OnClose( this ); // 一定要在最后一行
}
void CClientSocket::OnReceive(int nErrorCode)
{
// TODO: Add your specialized code here and/or call the base class
document_->OnReceive( this );
CSocket::OnReceive(nErrorCode);
}
BOOL CClientSocket::Initialize()
{
socketFile_ = new CSocketFile( this );
archiveIn_ = new CArchive( socketFile_, CArchive::load );
archiveOut_ = new CArchive( socketFile_, CArchive::store );
return TRUE;
}
[創建客戶端]
客戶端的運作比服務器簡單
1. 創建客戶端Socket并連接到服務器。 CSocket::Create() -> CSocket::Connect()
2. 客戶端Socket讀取數據并發送數據。 CSocket::OnReceive()
3. 客戶端連接被動關閉。 CSocket::OnClose()
4. 程序關閉，進而客戶端連接主動關閉。CSocket::Close()
下面是比較完整的Client端的源代碼:
//---------------------------------------------------------------------------------
// CClientDlg.cpp
//---------------------------------------------------------------------------------
CClientDlg::CClientDlg(CWnd* pParent /*=NULL*/)
: CDialog(CClientDlg::IDD, pParent)
, socket_( NULL )
{
...
}
void CClientDlg::OnDestroy()
{
CDialog::OnDestroy();
// TODO: Add your message handler code here
// 主動斷開連接
delete socket_;
socket_ = NULL;
}
void CClientDlg::OnBnClickedConnnect()
{
// TODO: Add your control notification handler code here
UpdateData( TRUE );
socket_ = new CClientSocket( this );
socket_->Create();
if ( !socket_->Connect( "127.0.0.1", 5001 ) ) {
delete socket_;
socket_ = NULL;
MessageBox( _T( "連接失敗" ) );
return;
}
socket_->Initialize();
}
// 主動斷開連接
void CClientDlg::OnBnClickedDisconnect()
{
// TODO: Add your control notification handler code here
delete socket_;
socket_ = NULL;
}
// 被動斷開連接
void CClientDlg::OnClose()
{
delete socket_;
socket_ = NULL;
MessageBox( _T("服務器斷開") );
}
void CClientDlg::OnReceive()
{
// receive data with socket_
}
//---------------------------------------------------------------------------------
// CClientSocket.cpp
//---------------------------------------------------------------------------------
CClientSocket::CClientSocket( CClientDlg* dialog )
: dialog_( dialog )
, socketFile_( NULL )
, archiveIn_( NULL )
, archiveOut_( NULL )
{
}
CClientSocket::~CClientSocket()
{
delete archiveIn_;
archiveIn_ = NULL;
delete archiveOut_;
archiveOut_ = NULL;
delete socketFile_;
socketFile_ = NULL;
}
void CClientSocket::OnClose(int nErrorCode)
{
// TODO: Add your specialized code here and/or call the base class
CSocket::OnClose(nErrorCode);
dialog_->OnClose();
}
void CClientSocket::OnReceive(int nErrorCode)
{
// TODO: Add your specialized code here and/or call the base class
dialog_->OnReceive();
CSocket::OnReceive(nErrorCode);
}
BOOL CClientSocket::Initialize()
{
socketFile_ = new CSocketFile( this );
archiveIn_ = new CArchive( socketFile_, CArchive::load );
archiveOut_ = new CArchive( socketFile_, CArchive::store );
return TRUE;
}