• <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>

            focus on linux, c/c++, lua

            Epoll網(wǎng)絡(luò)模型總結(jié)

            整個(gè)網(wǎng)絡(luò)模型分為兩個(gè)層次,一個(gè)是網(wǎng)絡(luò)消息層(Epoll), 一個(gè)是邏輯層。這兩層開(kāi)兩個(gè)線程同時(shí)進(jìn)行。當(dāng)socket連接服務(wù)器成功之后,在epoll維護(hù)的事件隊(duì)列中,加入該socket,并標(biāo)記其當(dāng)前為已連接狀態(tài),可以進(jìn)行發(fā)送或是接受消息。下面針對(duì)Send和Recv兩個(gè)分別描述。
            首先epoll會(huì)在主循環(huán)中輪詢新建立的鏈接,如果有新的鏈接,則執(zhí)行鏈接動(dòng)作,(邏輯層在鏈接時(shí),有時(shí)候也需要做一些事情,可提供接口回調(diào))。
            1,Recv,接收網(wǎng)絡(luò)消息為被動(dòng)動(dòng)作。只能由epoll的主循環(huán)驅(qū)動(dòng)。當(dāng)epoll檢測(cè)到某個(gè)socket接收到新的數(shù)據(jù)時(shí),connection把其中的數(shù)據(jù)取出來(lái),放在本地緩存,并對(duì)其進(jìn)行判斷,是否是一個(gè)完整的包,根據(jù)tcp的滑動(dòng)窗口協(xié)議,socket的一次recv的數(shù)據(jù)可能并不是像邏輯層想象的那樣,一次就發(fā)一個(gè)完整的包,要對(duì)包進(jìn)行判斷和處理。 如果在connection中,收到并判斷是一個(gè)完整的包。則把該包的數(shù)據(jù),加入到邏輯層的數(shù)據(jù)隊(duì)列,讓邏輯層去處理。
            2,Send, Send不同與Recv,Send是主動(dòng)事件,由邏輯層的某發(fā)送接口觸發(fā),所以在connection中要提供一個(gè)循函數(shù)(Send)給邏輯層回調(diào)。首先把要發(fā)送的數(shù)據(jù),放在本地緩存,讓后修改當(dāng)前socket的狀態(tài),告訴Epoll我有數(shù)據(jù)要發(fā)送,讓Epoll來(lái)回調(diào)我的發(fā)送接口。Epoll來(lái)回調(diào)的時(shí)候,有可能發(fā)現(xiàn)我有很多包要發(fā),或是因?yàn)槠渌W(wǎng)絡(luò)原因,包積攢了很多,那么就要把這些包有順序的放在隊(duì)列中,一個(gè)一個(gè)的有序的發(fā)出去。如果一個(gè)包很大,一次發(fā)不完,怎么辦?那也只能通過(guò)本地的緩存調(diào)整,最終發(fā)送完。不過(guò)一般會(huì)規(guī)定最大的包長(zhǎng)的。
            至于邏輯層的主循環(huán),就很簡(jiǎn)單了,因?yàn)樗灰幚肀粍?dòng)的接受包的邏輯,這個(gè)時(shí)候,不管邏輯層的分層多么的詳細(xì),都無(wú)所謂了,思路已經(jīng)很清晰了!

            寫完這篇文章,還有個(gè)道理就是鼓勵(lì)下自己:今天搞不懂的代碼,明天可以搞懂,明天不行,后天,總有一天搞懂的,相信自己最重要!

            posted on 2010-06-10 10:40 zuhd 閱讀(1381) 評(píng)論(1)  編輯 收藏 引用 所屬分類: server

            評(píng)論

            # re: Epoll網(wǎng)絡(luò)模型總結(jié)[未登錄](méi) 2012-01-17 11:22 冷鋒

            我用的epoll ET模式,我的recv跟你一樣,但是Send的有點(diǎn)區(qū)別,我是在邏輯線程里面嘗試直接發(fā)送,先判斷下發(fā)送隊(duì)列是否為空,如果為空的話那么直接發(fā)送,當(dāng)然這里可能遇到發(fā)不完的情況,因此要記錄下發(fā)送的位置,然后丟到發(fā)送隊(duì)列中,IO線程里面,在可寫事件到來(lái)時(shí)去檢查隊(duì)列并發(fā)送隊(duì)列的數(shù)據(jù)。

            PS:
            IO線程通知邏輯線程我是通過(guò)條件變量,有點(diǎn)好奇你在邏輯線程是怎么通知IO線程的,IO線程應(yīng)該已經(jīng)在epoll_wait了,你是弄了個(gè)管道什么的嗎?像memcached那樣的做法。  回復(fù)  更多評(píng)論   

            久久综合给合久久国产免费| 久久99精品国产麻豆宅宅| 日本精品久久久中文字幕| 97精品伊人久久久大香线蕉| 久久久久久国产a免费观看黄色大片| 国产精品伦理久久久久久| 久久亚洲国产午夜精品理论片| 久久婷婷五月综合97色一本一本| 亚洲色欲久久久综合网| 一本色道久久HEZYO无码| 无码日韩人妻精品久久蜜桃 | 99久久精品国产一区二区| 国产精品久久久久9999| 99久久精品国产一区二区蜜芽| 久久99精品久久久久久齐齐| 久久精品亚洲欧美日韩久久 | 久久久久亚洲精品天堂久久久久久| 9999国产精品欧美久久久久久| 日韩美女18网站久久精品| 伊人久久精品无码av一区 | 国产69精品久久久久777| 91久久香蕉国产熟女线看| 综合久久一区二区三区 | 国产精品久久久香蕉| 亚洲va国产va天堂va久久| 热久久国产精品| 国产精品久久新婚兰兰| 国产亚洲婷婷香蕉久久精品| 国产精品亚洲综合专区片高清久久久| 亚洲欧美精品一区久久中文字幕| 久久精品国产亚洲AV蜜臀色欲| 69SEX久久精品国产麻豆| 久久精品国产一区二区| 久久青青草原亚洲av无码app | 99久久综合国产精品二区| 欧美精品九九99久久在观看| 国产综合久久久久久鬼色| 思思久久99热只有频精品66| 久久精品国产99国产电影网| 国产精品亚洲综合久久| 精品久久久久久国产牛牛app|