VC FTP服务器程序分析（二）

　　上面讲到了CClientThread类，打开这个类的实现，这个类实现了4个函数。依次分析：

　　1、InitInstance   其说明如下：InitInstance必须被重载以初始化每个用户界面线程的新实例。统称，你重载InitInstance函数来执行当线程首次被创建时必须完成的任务。此成员函数仅在用户界面线程中使用。

BOOL CClientThread::InitInstance()
{
    // Attach the socket handle to a CSocket object.
    // This makes sure that the socket notifications are sent to this thread.
    m_ControlSocket.Attach(m_hSocket);
    m_ControlSocket.m_pThread = this;

    // send welcome message to client
    m_ControlSocket.SendResponse("220 欢迎使用CC的FTP 服务器!!!");

    UINT nPort;
    m_ControlSocket.GetPeerName(m_strPeerName, nPort);

    // dynamically allocate memory for IP address (receiver will delete it!)
    int nLength = m_strPeerName.GetLength();
    LPSTR lpszPeerName = new char[nLength+1];
    lstrcpy(lpszPeerName, m_strPeerName);
    
    // Post a message to the main thread so that it can update the number of open connections
    ::PostMessage(m_hWndOwner, WM_THREADSTART, (WPARAM)lpszPeerName, (LPARAM)m_nThreadID);
    return TRUE;
}

 　第5行，m_ControlSocket类关联了m_hSocket句柄，m_hSocket是在创建线程对象之后传递进来的。m_ControlSocket是与客户端通信使用的控制命令套接字。第9行，调用了m_ControlSocket的成员函数SendResponse。这里涉及到CControlSocket类，这个类下篇分析再讲。这里就是给客户端回复了一个信息，信息里面为什么是220,这里就是具体的通信协议了，后面再讲。

　第11至20，就是将客户端信息显示在主窗口上面了。

　2、ExitInstance  其说明如下：框架通过很少被重载的Run成员函数调用此函数以退出线程的这个实例；或者当调用InitInstance失败时，调用此函数。除了在Run成员函数内之外，不得在任何地方调用此成员函数。此成员函数仅被用户界面线程使用。当m_bAutoDelete为真时，此函数的缺省实现删除CWinThread对象。如果你希望当线程终止时执行额外的清除工作，请重载此函数。当你的程序代码被执行之后，你的ExitInstance实现应调用基类的ExitInstance函数。

int CClientThread::ExitInstance()
{
    // delete this thread from the linked list
    CServerDlg *pWnd = (CServerDlg *)AfxGetApp()->m_pMainWnd;
    if (pWnd != NULL)
    {
        pWnd->m_CriticalSection.Lock();
        POSITION pos = pWnd->m_ThreadList.Find(this);
        if(pos != NULL)
        {
            pWnd->m_ThreadList.RemoveAt(pos);
        }
        pWnd->m_CriticalSection.Unlock();
    } 
    // dynamically allocate memory for IP address (receiver will delete it!)
    int nLength = m_strPeerName.GetLength();
    LPSTR lpszPeerName = new char[nLength+1];
    lstrcpy(lpszPeerName, m_strPeerName);
    
    // Post message to the main thread that this socket connection has closed
    ::PostMessage(m_hWndOwner, WM_THREADCLOSE, (WPARAM)lpszPeerName, (LPARAM)m_nThreadID);
    return CWinThread::ExitInstance();
}

　　上面这个函数，第4至14行 删除了在界面类中保存的本线程对象指针。第16至21行，给界面发送了线程退出的消息。

　　3、PostStatusMessage函数，此函数就是在给主窗口发送消息。

void CClientThread::PostStatusMessage(LPCTSTR lpszStatus)
{
    CString strData = lpszStatus;

    int nLength = strData.GetLength();
    
    // dynamically allocate memory for status message (receiver will delete it!)
    LPSTR lpszData = new char[nLength+1];
    lstrcpy(lpszData, strData);
    ::PostMessage(m_hWndOwner, WM_ADDTRACELINE, (WPARAM)lpszData, (LPARAM)m_nThreadID); 
}

　　WM_ADDTRACELINE从字面上看就是增加一条记录信息。

　　4、OnDestroyDataConnection  这是一个消息响应函数，也就是一个线程对象如果去接收并处理一个消息，这就是个很好的例子了。

BEGIN_MESSAGE_MAP(CClientThread, CWinThread)
    //{{AFX_MSG_MAP(CClientThread)
        // NOTE - the ClassWizard will add and remove mapping macros here.
    //}}AFX_MSG_MAP
    ON_THREAD_MESSAGE(WM_DESTROYDATACONNECTION, OnDestroyDataConnection)
END_MESSAGE_MAP()


void CClientThread::OnDestroyDataConnection(WPARAM wParam, LPARAM lParam)
{
    m_ControlSocket.DestroyDataConnection();
}

　　这里调用了CControlSocket类的成员函数DestroyDataConnection。下面就分析CConntrolSocket类的实现。