larbin源碼分析(九) NamedSite站點的抽象類
一 類的主要功能
NamedSite 該類為一個主站點的抽象類,主站點類似www.baidu.com.
二 類的主要成員變量
/* name of the site */
(1) char name[maxSiteSize]; 主站點的名稱
(2) uint16_t port; // 主站點的端口號
(3) uint16_t nburls; //內存中該站點的所有url的數目
(4) url *fifo[maxUrlsBySite]; //內存中該站點的url緩沖區隊列
(5) uint8_t inFifo; //內存中隊列的隊首
(6)uint8_t outFifo; //內存中隊列的尾部
(7)bool isInFifo; //該站點是否在dnsSite中,即已經遍歷完畢
(8)char dnsState; //dns的狀態
(9) /** internet addr of this server */
char dnsState; //internet的網站地址
struct in_addr addr; //ipv4地址
uint ipHash; //iphash值
(10) time_t dnsTimeout; //請求dns以及獲取robots.txt的時延 * Date of expiration of dns call and robots.txt fetch */
(11)Vector<char> forbidden; /** test if a file can be fetched thanks to the robots.txt */ robots文件中禁止訪問的url
三 成員函數
(1)NamedSite構造函數
實質是將上述各個成員變量進行初始化操作。
(2)putInFifo(url *u) 將u插入進隊列fifo中,隊列為循環隊列。
(3)url *NamedSite::getInFifo() 將fifo中的url取出隊頭
(4)int fifoLength() {(inFifo - outFifo + maxUrlsBySite) % maxUrlsBySite ;}
(5)putGenericUrl(url *u, int limit, bool prio) //將獲取的url插入進入站點的fifo隊列中
//當當前的nburls的數量大于限制的時候,需要根據優先級將其存儲在URLsPriorityWait隊列或者URLsDiskWait隊列中。
函數實現方法如下:
if (nburls > maxUrlsBySite-limit) { //當前內存中的nburls數目,已經超過該限制了,下面就判斷是否需要忽略該URL
if (!strcmp(name, u->getHost())) { //首先判斷當前的站點名稱和url的host名稱是否一致
if (dnsState == errorDns) { //如果當前的dns請求狀態是 errorDns,則進行忽略操作
nburls++;
forgetUrl(u, noDNS);
return;
}
if (dnsState == noConnDns) { //當當前的dns狀態為 無連接,則進行URL忽略
nburls++;
forgetUrl(u, noConnection);
return;
}
if (u->getPort() == port //如果當前的url在對應網站的forbid列表中,則將對應的url加入忽略
&& dnsState == doneDns && !testRobots(u->getFile())) {
nburls++;
forgetUrl(u, forbiddenRobots);
return;
}
}
//此時URL的host名稱和當前站點的host地址不同,則需要記錄(此時仍然無法放入fifo隊列中,需要放入等待隊列中)
refUrl();
global::inter->getOne(); //實際上inter表示全部站點中,fifo隊列的數量
if (prio) {
global::URLsPriorityWait->put(u);
} else {
global::URLsDiskWait->put(u);
}
}
//此處沒有超出fifo隊列的大小限制
else {
nburls++;
if (dnsState == waitDns
|| strcmp(name, u->getHost())
|| port != u->getPort()
|| global::now > dnsTimeout) {
// dns not done or other site
putInFifo(u); //將此url放入進fifo中
addNamedUrl(); //將namesites中的url數目增加
// Put Site in fifo if not yet in
if (!isInFifo) { //如果當前該namesites沒在dnsites中時,則進行添加操作
isInFifo = true;
global::dnsSites->put(this);
}
} else switch (dnsState) {
case doneDns:
transfer(u);
break;
case errorDns:
forgetUrl(u, noDNS);
break;
default: // noConnDns
forgetUrl(u, noConnection);
}
}
(6)void NamedSite::newQuery () //該函數,主要用于發起一個新的dns請求
若請求成功,則調用調用dnsOk()。該函數中,主要有處理代理地址,若沒有解析到dns,則需要調用adns包中的請求函數。
(7)void NamedSite::dnsAns (adns_answer *ans) 未看明白
(8)void NamedSite::dnsOK () { //請求各個站點的robots.txt文件
Connexion *conn = global::freeConns->get(); //從全局變量中獲取空閑鏈接
char res = getFds(conn, &addr, port); //根據addr建立連接
if (res != emptyC) {
conn->timeout = timeoutPage;
if (global::proxyAddr != NULL) {
// use a proxy
conn->request.addString("GET http://");
conn->request.addString(name);
char tmp[15];
sprintf(tmp, ":%u", port);
conn->request.addString(tmp);
conn->request.addString("/robots.txt HTTP/1.0\r\nHost: ");
} else {
// direct connection
conn->request.addString("GET /robots.txt HTTP/1.0\r\nHost: ");
}
conn->request.addString(name);
conn->request.addString(global::headersRobots); //具體請求報文,在global.cc中
conn->parser = new robots(this, conn); //應該在file文件中,構建一個解析類robots
conn->pos = 0;
conn->err = success;
conn->state = res;
} else {
// Unable to get a socket
global::freeConns->put(conn);
dnsState = noConnDns;
dnsErr();
}
}
(9)bool NamedSite::testRobots(char *file) //判斷該文件是否在robots.txt中的屏蔽列表中
(10)NamedSite::robotsResult (FetchError res) 獲取robots.txt ,然后掃描fifo隊列,
將其中與namesite類的站點名稱以及端口號相同的transfer到 Ipsite中,需要計算其Iphash
(11)NamedSite::transfer (url *u) 將站點地址copy到url中,然后判斷是否在robots.txt的列表中
若在則執行forgetUrl,否則添加到global::IPSiteList[ipHash].putUrl(u);中。
四 綜上:
該類主要是站點類的抽象,涉及到了 請求DNS ,請求robots.txt ,打開connexion中的鏈接。