FileZilla 源代碼分析5
FileZilla是一種快速、可信賴的FTP客戶端以及服務(wù)器端開放源代碼程式，具有多種特色、直覺的接口。本文就給大家分析下FileZilla的源代碼。
< type="text/javascript"> < src="http://pagead2.googlesyndication.com/pagead/show_ads.js" type="text/javascript"> < type="text/javascript"> < src="http://pagead2.googlesyndication.com/pagead/show_ads.js" type="text/javascript">
在CServer的Create()中，創(chuàng)建對(duì)象CListenSocket來監(jiān)聽21端口，來看看具體的代碼實(shí)現(xiàn)：
CListenSocket *pListenSocket = new CListenSocket(this, ssl);
if (!pListenSocket->Create(nPort, SOCK_STREAM, FD_ACCEPT, NULL) || !pListenSocket->Listen())
基本上分三步：
1、new CListenSocket：沒有什么特別的，基本就是初始化成員變量
2、Create
注：在所有的代碼中，先不看大量的if (m_pFirstLayer)這種代碼，這是CAsyncSocketExLayer的機(jī)制。
Create其實(shí)調(diào)用的是父類CAsyncSocketEx的create()方法，這個(gè)方法中第一件事情就是建立m_spAsyncSocketExThreadDataList鏈、分發(fā)線程t_AsyncSocketExThreadData以及CAsyncSocketEx之間的關(guān)系，CAsyncSocketEx的create()方法首先調(diào)用InitAsyncSocketExInstance()，下面是CAsyncSocketEx::InitAsyncSocketExInstance()代碼片斷：
DWORD id=GetCurrentThreadId();
...
//Get thread specific data
if (m_spAsyncSocketExThreadDataList) // 這個(gè)鏈已經(jīng)建立了
{
t_AsyncSocketExThreadDataList *pList=m_spAsyncSocketExThreadDataList;
while (pList) // 遍歷鏈
{
ASSERT(pList->pThreadData);
ASSERT(pList->pThreadData->nInstanceCount>0);
if (pList->pThreadData->nThreadId==id) // 對(duì)當(dāng)前線程已經(jīng)有分發(fā)線程了，就把當(dāng)前socket的分發(fā)由這個(gè)分發(fā)線程來代理
{
m_pLocalAsyncSocketExThreadData=pList->pThreadData;
m_pLocalAsyncSocketExThreadData->nInstanceCount++; // 多了這一個(gè)socket
break;
}
pList=pList->pNext;
}
//Current thread yet has no sockets
if (!pList) // 當(dāng)前線程還沒有分發(fā)線程，則創(chuàng)建一個(gè)
{
//Initialize data for current thread
pList=new t_AsyncSocketExThreadDataList;
pList->pNext=m_spAsyncSocketExThreadDataList;
m_spAsyncSocketExThreadDataList=pList;
m_pLocalAsyncSocketExThreadData=new t_AsyncSocketExThreadData;
m_pLocalAsyncSocketExThreadData->nInstanceCount=1; // 只掛了當(dāng)前的socket
m_pLocalAsyncSocketExThreadData->nThreadId=id; // 這個(gè)分發(fā)線程的threadID
m_pLocalAsyncSocketExThreadData->m_pHelperWindow=new CAsyncSocketExHelperWindow(m_pLocalAsyncSocketExThreadData); // 為這個(gè)分發(fā)線程創(chuàng)建CAsyncSocketExHelperWindow
m_spAsyncSocketExThreadDataList->pThreadData=m_pLocalAsyncSocketExThreadData;
}
}
else // 如果分發(fā)線程鏈還沒有創(chuàng)建，則創(chuàng)建一個(gè)
{ //No thread has instances of CAsyncSocketEx; Initialize data
m_spAsyncSocketExThreadDataList=new t_AsyncSocketExThreadDataList;
m_spAsyncSocketExThreadDataList->pNext=0;
m_pLocalAsyncSocketExThreadData=new t_AsyncSocketExThreadData; // 第一個(gè)分發(fā)線程
m_pLocalAsyncSocketExThreadData->nInstanceCount=1; // 只掛了當(dāng)前的socket
m_pLocalAsyncSocketExThreadData->nThreadId=id; // 這個(gè)分發(fā)線程的threadID
m_pLocalAsyncSocketExThreadData->m_pHelperWindow=new CAsyncSocketExHelperWindow(m_pLocalAsyncSocketExThreadData); // 為這個(gè)分發(fā)線程創(chuàng)建CAsyncSocketExHelperWindow
m_spAsyncSocketExThreadDataList->pThreadData=m_pLocalAsyncSocketExThreadData;
...
}
下面看一個(gè)創(chuàng)建CAsyncSocketExHelperWindow的過程：
CAsyncSocketExHelperWindow(CAsyncSocketEx::t_AsyncSocketExThreadData* pThreadData)
{
// m_pAsyncSocketExWindowData是一個(gè)t_AsyncSocketExWindowData數(shù)組，
// 數(shù)組的每一個(gè)元素代表了一個(gè)CAsyncSocketEx，即要服務(wù)的socket
//Initialize data
m_pAsyncSocketExWindowData = new t_AsyncSocketExWindowData[512]; //Reserve space for 512 active sockets
memset(m_pAsyncSocketExWindowData, 0, 512*sizeof(t_AsyncSocketExWindowData));
m_nWindowDataSize=512; // 當(dāng)前數(shù)組的大小，這是可自動(dòng)擴(kuò)充的，不過最大不能超過一個(gè)最大值
m_nSocketCount=0; // 當(dāng)前數(shù)組中CAsyncSocketEx的數(shù)量
m_nWindowDataPos=0; // 如果要加一個(gè)新的CAsyncSocketEx進(jìn)來，加到數(shù)組的哪個(gè)位置
m_pThreadData = pThreadData; // 這個(gè)CAsyncSocketExHelperWindow對(duì)應(yīng)的分發(fā)線程，兩者一一對(duì)應(yīng)的
// 下面創(chuàng)建一個(gè)標(biāo)準(zhǔn)的窗口，不過并不顯示出來
//Create window
WNDCLASSEX wndclass;
wndclass.cbSize=sizeof wndclass;
wndclass.style=0;
wndclass.lpfnWndProc=WindowProc;
wndclass.cbClsExtra=0;
wndclass.cbWndExtra=0;
wndclass.hInstance=GetModuleHandle(0);
wndclass.hIcon=0;
wndclass.hCursor=0;
wndclass.hbrBackground=0;
wndclass.lpszMenuName=0;
wndclass.lpszClassName=_T("CAsyncSocketEx Helper Window");
wndclass.hIconSm=0;
RegisterClassEx(&wndclass);
m_hWnd=CreateWindow(_T("CAsyncSocketEx Helper Window"), _T("CAsyncSocketEx Helper Window"), 0, 0, 0, 0, 0, 0, 0, 0, GetModuleHandle(0));
ASSERT(m_hWnd);
SetWindowLongPtr(m_hWnd, GWL_USERDATA, (LONG)this);
};
在調(diào)用完InitAsyncSocketExInstance()之后，CAsyncSocketEx的create()方法然后：
SOCKET hSocket = socket(m_SocketData.nFamily, nSocketType, 0); // 這是真正的socket api，建立一個(gè)socket
if (hSocket == INVALID_SOCKET)
return FALSE;
m_SocketData.hSocket = hSocket;
AttachHandle(hSocket); // 將當(dāng)前創(chuàng)建的socket加到分發(fā)線程管理中，這樣可以讓分發(fā)線程來負(fù)責(zé)這個(gè)socket的消息
AttachHandle()調(diào)用了CAsyncSocketExHelperWindow的AddSocket方法：
BOOL AddSocket(CAsyncSocketEx *pSocket, int &nSocketIndex)
{
...
//Search for free slot
// 從m_nWindowDataPos開始搜索, 共搜m_nWindowDataSize個(gè)位置
// 由于是下面的模運(yùn)算i%m_nWindowDataSize，因此到達(dá)數(shù)組尾時(shí)，從重從繞回來，即收遍數(shù)組的每一個(gè)位置
for (int i=m_nWindowDataPos;i<(m_nWindowDataSize+m_nWindowDataPos);i++)
{
// 注意模運(yùn)算
if (!m_pAsyncSocketExWindowData[i%m_nWindowDataSize].m_pSocket) // 這個(gè)位置是空的
{
m_pAsyncSocketExWindowData[i%m_nWindowDataSize].m_pSocket=pSocket;
nSocketIndex=i%m_nWindowDataSize; // 在list中的pos
m_nWindowDataPos=(i+1)%m_nWindowDataSize; // 以后從下一個(gè)搜索位置開臺(tái)
m_nSocketCount++;
return TRUE;
}
}
...
}
即在CAsyncSocketExHelperWindow管理的socket數(shù)組中，加上這次的這個(gè)CAsyncSocketEx。
CAsyncSocketEx的create()方法然后：
if (!AsyncSelect(lEvent))
{
Close();
return FALSE;
}
這里AsyncSelect()方法里調(diào)用了windows socket api: WSAAsyncSelect()，這個(gè)方法可以讓windows在CAsyncSocketEx指定的socket上，當(dāng)socket事件accept, read, write等發(fā)生時(shí)，發(fā)送消息到CAsyncSocketExHelperWindow中的窗口hWnd，然后CAsyncSocketExHelperWindow再通過回調(diào)函數(shù)WindowProc將消息發(fā)回到負(fù)責(zé)處理這個(gè)消息的CAsyncSocketEx上(這部分下面再詳細(xì)分析)。
繼續(xù)CAsyncSocketEx的create()方法：
if (!Bind(nSocketPort, lpszSocketAddress))
{
Close();
return FALSE;
}
Bind()實(shí)際上調(diào)用了socket api: bind()方法，實(shí)現(xiàn)了local address和socket的綁定。
3、Listen
create完以后，就是listen，這個(gè)比較簡單，直接調(diào)用了socket api: listen()，在指定地址、端口進(jìn)行監(jiān)聽。
程序運(yùn)行到這里，核心的類已經(jīng)初始化完成了，下面分析當(dāng)socket有活動(dòng)時(shí)，消息是如何從CAsyncSocketExHelperWindo分發(fā)到CAsyncSocketEx的。
< type="text/javascript"> < src="http://pagead2.googlesyndication.com/pagead/show_ads.js" type="text/javascript">
通過文章完整的描述，大家應(yīng)該知道了FileZilla 源代碼，希望對(duì)大家有幫助！
【編輯推薦】
