• <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源碼分析(十) IpSite站點的抽象類

                          IpSite站點的抽象類

             一 該類的功能
                 NamedSite中的類經過dns請求之后,就會將站點名轉換為ip,然后將url transfer到Ipsite中,由Ipsite具體完成爬蟲工作。
             二 類的具體成員參數
                    time_t lastAccess; //該IP最后獲取的時間
                    bool isInFifo;         //當該對象完成了一次fetch之后,將其加入到oksites中,并將其置為true,或者將一個url加入進fifo中
                    url *getUrl ();       //獲取隊列中的 url對象
                    IPSite ();
                    ~IPSite (); 
                    Fifo<url> tab;      //隊列中進行爬取的url列表
                     int fetch ();        //具體執行爬取

               三 具體函數實現
                   (1) 構造函數IPSite() 函數的具體實現為 lastAccess = 0 ; isInFifo = false ;
                   (2)IPSite::putUrl (url *u) 
                       將url放入IPSite的fifo隊列中,然后將isInFifo設置為true。如果lastAccess+waitDuration <= now
                       以及當期存在空閑的連接,則可以 調用fetch以進行爬取網頁。
                       否則將該IpSite加入進okSites中。
                  (3)inline url *IPSite::getUrl ()  從fifo中獲取一個url
                   (4) fetch() 函數,用以爬取網頁
                         Connexion *conn = global::freeConns->get(); //首先獲取一個空閑的連接
                         url *u = getUrl();                                          //獲取一個url
                         char res = getFds(conn, &(u->addr), u->getPort()); //然后根據url建立一個連接
                          if (res != emptyC) {       //下面則為一個具體發送http報文請求的過程
                            lastAccess = global::now;
                           conn->timeout = timeoutPage;
                          conn->request.addString("GET ");
                    if (global::proxyAddr != NULL) {
                      char *tmp = u->getUrl();
                      conn->request.addString(tmp);
                    } else {
                      conn->request.addString(u->getFile());
                    }
                    conn->request.addString(" HTTP/1.0\r\nHost: ");
                    conn->request.addString(u->getHost());
            #ifdef COOKIES
                    if (u->cookie != NULL) {
                      conn->request.addString("\r\nCookie: ");
                      conn->request.addString(u->cookie);
                    }
            #endif // COOKIES
                    conn->request.addString(global::headers);
                    conn->parser = new html (u, conn); //建立頁面解析類
                    conn->pos = 0;                              //獲取的數據中的下標位置 ,pos
                    conn->err = success;
                    conn->state = res;
                    if (tab.isEmpty()) {
                      isInFifo = false;
                    } else {
                      global::okSites->put(this);
                    }
                    return 0;
                  }
               下面附帶上一次http請求的頭部的格式
              

            GET /index.html HTTP/1.1

            Accept:text/html

            User-Agent:larbin

            Host: ioa.rising.com.cn

            Fromjiangzy@rising.com.cn


              四 總結:
                   該類IpSite主要用來向http服務器發送連接請求,并構建出對應的文件解析類html,存儲在conn中。


            posted on 2011-06-16 14:13 kahn 閱讀(542) 評論(0)  編輯 收藏 引用

            亚洲?V乱码久久精品蜜桃| 久久久久99精品成人片欧美| 亚洲天堂久久精品| 久久久久18| 7777久久久国产精品消防器材 | 91精品国产高清久久久久久io| 精品久久久久久久久中文字幕| 久久久久久久综合综合狠狠| 久久免费看黄a级毛片| 国产亚洲欧美成人久久片| 久久这里只有精品视频99| 久久精品天天中文字幕人妻| 性做久久久久久久久老女人| 久久亚洲欧美日本精品| 无遮挡粉嫩小泬久久久久久久 | yy6080久久| 一本久久久久久久| 久久影院综合精品| 99蜜桃臀久久久欧美精品网站| 精品欧美一区二区三区久久久| 亚洲AV无一区二区三区久久| 久久综合色之久久综合| 国产精品9999久久久久| 亚洲精品乱码久久久久久| 色悠久久久久久久综合网| 久久久久久亚洲精品不卡| 国产精品久久久天天影视香蕉 | 国产精品久久久久9999| 一本色道久久88精品综合| 亚洲国产精品无码久久九九| 国产成人99久久亚洲综合精品| 国内精品久久久久久野外| 久久久免费精品re6| 少妇高潮惨叫久久久久久 | 久久99精品久久久久久噜噜| 99久久精品午夜一区二区| 色8久久人人97超碰香蕉987| 久久精品无码专区免费东京热| 99精品久久精品一区二区| 久久亚洲欧美国产精品| 久久国产欧美日韩精品|