• <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構(gòu)造函數(shù)
                           實質(zhì)是將上述各個成員變量進行初始化操作。
                    (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隊列中
                           //當(dāng)當(dāng)前的nburls的數(shù)量大于限制的時候,需要根據(jù)優(yōu)先級將其存儲在URLsPriorityWait隊列或者URLsDiskWait隊列中。         
                          函數(shù)實現(xiàn)方法如下:
                           if (nburls > maxUrlsBySite-limit) {       //當(dāng)前內(nèi)存中的nburls數(shù)目,已經(jīng)超過該限制了,下面就判斷是否需要忽略該URL
                               if (!strcmp(name, u->getHost())) { //首先判斷當(dāng)前的站點名稱和url的host名稱是否一致
                                   if (dnsState == errorDns) {     //如果當(dāng)前的dns請求狀態(tài)是 errorDns,則進行忽略操作
                                      nburls++;
                                      forgetUrl(u, noDNS);
                                      return;
                                     }
                                   if (dnsState == noConnDns) { //當(dāng)當(dāng)前的dns狀態(tài)為 無連接,則進行URL忽略
                                      nburls++;
                                      forgetUrl(u, noConnection);
                                      return;
                                   }
                                if (u->getPort() == port           //如果當(dāng)前的url在對應(yīng)網(wǎng)站的forbid列表中,則將對應(yīng)的url加入忽略
                                   && dnsState == doneDns && !testRobots(u->getFile())) {
                                   nburls++;
                                   forgetUrl(u, forbiddenRobots);
                                  return;
                                }
                            }           
                             //此時URL的host名稱和當(dāng)前站點的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) { //如果當(dāng)前該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請求
                      若請求成功,則調(diào)用調(diào)用dnsOk()。該函數(shù)中,主要有處理代理地址,若沒有解析到dns,則需要調(diào)用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);  //應(yīng)該在file文件中,構(gòu)建一個解析類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 閱讀(735) 評論(1)  編輯 收藏 引用

            Feedback

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

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



            只有注冊用戶登錄后才能發(fā)表評論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            精品久久久久久久久免费影院 | 一本久久a久久精品综合香蕉| 婷婷综合久久中文字幕蜜桃三电影| 99精品国产在热久久无毒不卡| 色88久久久久高潮综合影院| 亚洲欧洲精品成人久久奇米网| 伊人久久无码中文字幕| 久久夜色精品国产噜噜噜亚洲AV| 久久精品国产亚洲av麻豆色欲 | 99久久国产宗和精品1上映| 欧美精品一区二区精品久久| 国产美女久久精品香蕉69| 国产亚洲美女精品久久久| 亚洲AV无码久久| 久久伊人五月天论坛| 亚洲国产成人久久综合一| 97久久超碰成人精品网站| 亚洲国产另类久久久精品黑人| 久久久久久国产a免费观看黄色大片| 女人香蕉久久**毛片精品| 国产精品日韩深夜福利久久| 国内精品久久久久久久涩爱 | 国产亚洲精久久久久久无码77777| 久久精品国产清自在天天线| 久久久久国产视频电影| 久久人人添人人爽添人人片牛牛| 国产成人精品久久| 久久久久久久综合日本| 久久狠狠爱亚洲综合影院| 亚洲国产天堂久久综合网站| 久久久久一本毛久久久| 日韩av无码久久精品免费| 久久国产精品国产自线拍免费| 久久精品国产亚洲Aⅴ香蕉| 996久久国产精品线观看| 久久久久久久91精品免费观看| 久久综合给合久久狠狠狠97色| 国内精品免费久久影院| 亚洲一区二区三区日本久久九| 久久久久精品国产亚洲AV无码| 一本大道久久东京热无码AV|