• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            jake1036

            larbin源碼分析(九) NamedSite站點的抽象類

            larbin源碼分析(九) NamedSite站點的抽象類

               一 類的主要功能
                    NamedSite 該類為一個主站點的抽象類,主站點類似www.baidu.com.
              二 類的主要成員變量
                   /* name of the site */
                  (1) char name[maxSiteSize]; 主站點的名稱
                  (2) uint16_t port;                // 主站點的端口號
                  (3) uint16_t nburls;             //內(nèi)存中該站點的所有url的數(shù)目  
                  (4) url *fifo[maxUrlsBySite]; //內(nèi)存中該站點的url緩沖區(qū)隊列
                  (5) uint8_t inFifo;               //內(nèi)存中隊列的隊首
                  (6)uint8_t outFifo;             //內(nèi)存中隊列的尾部 
                  (7)bool isInFifo;                 //該站點是否在dnsSite中,即已經(jīng)遍歷完畢
                   (8)char dnsState;            //dns的狀態(tài)
                   (9)   /** internet addr of this server */
                        char dnsState;          //internet的網(wǎng)站地址
                        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
                 
             


               三 成員函數(shù)
                    (1)NamedSite構造函數(shù)
                           實質是將上述各個成員變量進行初始化操作。
                    (2)putInFifo(url *u)  將u插入進隊列fifo中,隊列為循環(huán)隊列。
                    (3)url *NamedSite::getInFifo() 將fifo中的url取出隊頭
                    (4)int fifoLength() {(inFifo - outFifo + maxUrlsBySite) % maxUrlsBySite ;}

                    (5)putGenericUrl(url *u, int limit, bool prio) //將獲取的url插入進入站點的fifo隊列中
                           //當當前的nburls的數(shù)量大于限制的時候,需要根據(jù)優(yōu)先級將其存儲在URLsPriorityWait隊列或者URLsDiskWait隊列中。         
                          函數(shù)實現(xiàn)方法如下:
                           if (nburls > maxUrlsBySite-limit) {       //當前內(nèi)存中的nburls數(shù)目,已經(jīng)超過該限制了,下面就判斷是否需要忽略該URL
                               if (!strcmp(name, u->getHost())) { //首先判斷當前的站點名稱和url的host名稱是否一致
                                   if (dnsState == errorDns) {     //如果當前的dns請求狀態(tài)是 errorDns,則進行忽略操作
                                      nburls++;
                                      forgetUrl(u, noDNS);
                                      return;
                                     }
                                   if (dnsState == noConnDns) { //當當前的dns狀態(tài)為 無連接,則進行URL忽略
                                      nburls++;
                                      forgetUrl(u, noConnection);
                                      return;
                                   }
                                if (u->getPort() == port           //如果當前的url在對應網(wǎng)站的forbid列表中,則將對應的url加入忽略
                                   && dnsState == doneDns && !testRobots(u->getFile())) {
                                   nburls++;
                                   forgetUrl(u, forbiddenRobots);
                                  return;
                                }
                            }           
                             //此時URL的host名稱和當前站點的host地址不同,則需要記錄(此時仍然無法放入fifo隊列中,需要放入等待隊列中)
                       refUrl();
                        global::inter->getOne(); //實際上inter表示全部站點中,fifo隊列的數(shù)量
                        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數(shù)目增加
                  // 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 ()  //該函數(shù),主要用于發(fā)起一個新的dns請求
                      若請求成功,則調用調用dnsOk()。該函數(shù)中,主要有處理代理地址,若沒有解析到dns,則需要調用adns包中的請求函數(shù)。
              (7)void NamedSite::dnsAns (adns_answer *ans)  未看明白
               
            (8)void NamedSite::dnsOK () {                             //請求各個站點的robots.txt文件
              Connexion *conn = global::freeConns->get();         //從全局變量中獲取空閑鏈接
              char res = getFds(conn, &addr, port);                     //根據(jù)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的列表中
                     若在則執(zhí)行forgetUrl,否則添加到global::IPSiteList[ipHash].putUrl(u);中。

            四 綜上:
                該類主要是站點類的抽象,涉及到了 請求DNS ,請求robots.txt ,打開connexion中的鏈接。



             

            posted on 2011-06-15 14:30 kahn 閱讀(725) 評論(1)  編輯 收藏 引用

            Feedback

            # re: larbin源碼分析(九) NamedSite站點的抽象類 2011-10-16 22:46 koma

            你好,怎么沒有第八部分呢,從(七)一下子到(九)了  回復  更多評論   


            久久久久亚洲国产| 久久久精品久久久久影院| 久久免费精品一区二区| 精品久久久久久99人妻| 久久久久亚洲av成人网人人软件| 狼狼综合久久久久综合网| 国产福利电影一区二区三区久久老子无码午夜伦不 | 久久99热这里只有精品66| 久久精品国产亚洲AV麻豆网站| 久久精品国产一区二区三区日韩| 香蕉99久久国产综合精品宅男自| 人妻无码中文久久久久专区| 久久亚洲中文字幕精品一区四| 欧美亚洲色综久久精品国产| 久久亚洲高清综合| 久久精品?ⅴ无码中文字幕| 久久久久成人精品无码中文字幕| 伊人久久一区二区三区无码| 国产999精品久久久久久| 2021久久国自产拍精品| 久久久久国产精品嫩草影院| 久久久久国产一区二区| 蜜桃麻豆www久久| 2021久久精品国产99国产精品| 久久久久久久综合狠狠综合| 婷婷久久综合| 无码人妻久久一区二区三区蜜桃| 99久久精品九九亚洲精品| 国产精品久久久久久福利漫画 | 很黄很污的网站久久mimi色| 久久精品人人做人人妻人人玩| 国产香蕉久久精品综合网| 亚洲午夜精品久久久久久浪潮| 久久国产精品免费一区| 国产精品成人无码久久久久久| 天天综合久久久网| 国产亚洲精午夜久久久久久| 久久精品国产一区二区三区| 久久免费观看视频| 久久精品一本到99热免费| 亚洲va久久久噜噜噜久久天堂|