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

            服務(wù)器多線程方案的選擇

            Posted on 2011-11-20 22:35 冷鋒 閱讀(2957) 評論(11)  編輯 收藏 引用 所屬分類: linux
            最近想寫個多線程模型的服務(wù)器,但是一直糾結(jié)要選哪種方式,參考了memcached,但是覺得不完美.
            備選方案,當(dāng)然這些都是NIO
            1.一個IO線程,專門處理連接讀寫數(shù)據(jù),一個邏輯線程,專門處理數(shù)據(jù)。
            2.一個IO線程,一個線程池,可任意配置線程池的數(shù)量。
            先考慮1,假設(shè)連接層用epoll的ET模式實(shí)現(xiàn),當(dāng)IO線程發(fā)生可讀事件時,必須把接收緩沖區(qū)的數(shù)據(jù)全部收完,一直read直到發(fā)生EAGAIN錯誤,否則就必須自己在上層維護(hù)一個可讀隊(duì)列。
            方法a:每收到一個協(xié)議包,就轉(zhuǎn)發(fā)給邏輯處理.處理完再接著收取剩下的包。但是TCP是無邊界的,有可能收到0.5個或者2.5個包,這時你得為每個連接準(zhǔn)備個buf,并且每收到個包都要跟邏輯線程同步加鎖一次,還有個很大的弊端就是,連接層已經(jīng)跟邏輯協(xié)議相關(guān)了,這似乎不是很好。
            方法b:IO線程把所有數(shù)據(jù)都收完再通知邏輯線程。當(dāng)然這樣也無法避免收到半個協(xié)議包的情況,所以我是想維護(hù)一個recv到的數(shù)據(jù)隊(duì)列,IO線程把每次收到的包都丟到這個隊(duì)列。
            a,b2種方法都面臨著send的麻煩,現(xiàn)在send也有以下方案.
            方法a.每次需要write的時候就直接send發(fā)不完的就加到發(fā)送隊(duì)列中去。在發(fā)送前必須要先判斷一下隊(duì)列是不是空,如果不為空就必須先處理隊(duì)列,剩余數(shù)據(jù)待可讀事件發(fā)生時再處理,   于是腦子中又出現(xiàn)一大堆鎖了。有2個線程可能對socket進(jìn)行寫操作。
            方法b.每次需要send的時候都直接把數(shù)據(jù)丟到發(fā)送隊(duì)列去,等到可讀事件到來時再盡量把隊(duì)列都發(fā)送完。但是響應(yīng)可能沒那么迅速了。
            這兩種方法都必須為每個數(shù)據(jù)包增加一個標(biāo)識TCP連接的字段,因?yàn)閟ocket fd是可以重復(fù)使用的,比如用戶A連接分配的socket是100,邏輯線程正在為A處理數(shù)據(jù),但是用戶A斷開連接了,同時立即有另外個用戶連接進(jìn)來并且分配的socket是100,這時悲劇就發(fā)生了。
            再考慮下線程池的2種情況.
            a.主線程負(fù)責(zé)IO,包括處理連接,讀寫,把讀到的數(shù)據(jù)加入recv隊(duì)列,子線程把需要寫的加入send隊(duì)列.
            這個方案有個很大的缺陷:無法保證先到的請求先返回,這是很致命的,只能通過客戶端來確保收到前一個請求的結(jié)果以后再發(fā)送下一個請求。
            b.主線程只負(fù)責(zé)監(jiān)聽連接,收到連接到來事件后,通知線程池去accept連接,因此每個連接的數(shù)據(jù)都會由同一個線程處理,也就保證了順序,但是這樣的話子線程就必須承擔(dān)起IO的任務(wù)了,這樣好像就有些分工不清了,這個是memcached中用的方案.
            PS:用epoll的ET模式需要一直recv,這樣有可能是使得活躍的連接占用了全部帶寬,因此需要在上層對連接進(jìn)行限速,因此也就需要維護(hù)可讀事件了。
            糾結(jié)好幾天了,第一次寫多線程服務(wù)器,一直為選方案糾結(jié)啊,我本人傾向于線程池,畢竟可以利用多核的優(yōu)勢啊。不知道大家實(shí)際上用的都是什么方案呢,非常想知道,請指教。
            再PS:做了個小測試,nginx+memcached,下載一個700多K的文件,開100個線程,每個線程下載100次,全部命中跟全部不命中的情況幾乎沒有差別,這是為什么呢?難道linux系統(tǒng)本身就已經(jīng)有cached了嗎?

            Feedback

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 07:08 by 一念天堂
            單線程的非阻塞IO應(yīng)該還是最高效的,因?yàn)橐话銇碚f瓶頸是 IO,不管開多少個線程,IO 還是一套。阻塞多線程只是把切換從用戶代碼換到了內(nèi)核,編程會容易,提高效率就不一定了

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 08:48 by 冷鋒
            我說的是非阻塞的多線程啊,單線程的話如果要操作數(shù)據(jù)庫的話怎么辦?@一念天堂

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 08:51 by 一念天堂
            其實(shí)我們說的原則可能差不多,我說的單線程,其實(shí)是一個 epoll 一個線程,或者更準(zhǔn)確的說,一套 IO 一個線程

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 09:07 by yanxinmeng
            你以上說的幾種方案都很對。 但是沒有一種方案可以適用很多情況。
            memcache也有適用的場景。

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 09:57 by 冷鋒
            假如需要異步訪問數(shù)據(jù)庫的話怎么來保證順序呢,由客戶端來保證嗎?一定要前一個請求返回了才發(fā)送下一個請求?假如是寫游戲服務(wù)器的話呢?@yanxinmeng

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-21 13:38 by mentalmap
            不是一定非加鎖不可的,如果是單一的讀和寫線程的話

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-22 09:45 by zuhd
            正如你說的多線程對于管理網(wǎng)絡(luò)包的順序很麻煩,IO線程+邏輯線程做起來比較清晰,估計(jì)大家都傾向于此吧,至于粘包和切包這個就是對IO數(shù)據(jù)流的重新整理分類,自己肯定要做個包長度吧。
            a.在while中檢查是否有完整包,有完整包,就調(diào)用下層session的邏輯,也能清晰分層做到的。
            b.即使100的前一個用戶斷開,新的用戶來了,也不會有麻煩,底層的網(wǎng)絡(luò)庫根本不會關(guān)心這個socket是誰的,照常處理IO就是,只是邏輯層的session要自己處理了
            c.Send我是傾向于第一種實(shí)時的方案,也沒有一堆的鎖,一個連接一個而已,總算很清晰是吧,也值了
            總結(jié):1個IO+1個邏輯+1個session池

            # re: 服務(wù)器多線程方案的選擇[未登錄]  回復(fù)  更多評論   

            2011-11-22 21:52 by 冷鋒
            b.新的用戶來了,還是用100,就會把本該發(fā)給用戶A的發(fā)給用戶B了,不過這個可以自己維護(hù)一個session ID搞定,c實(shí)時send的話如果發(fā)不完得有個緩沖區(qū)延遲到下次再發(fā),由于主線程跟邏輯線程都在操作同一個fd,所以要加鎖,除非你把fd分給邏輯線程單獨(dú)維護(hù),負(fù)責(zé)它的讀寫,我已經(jīng)按照1a實(shí)現(xiàn)服務(wù)器的邏輯層了,你說的session是線程池還是全局的一個表?我這邊事維護(hù)了一個全局的connection的表@zuhd

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-23 09:13 by zuhd
            send是要加鎖的,session是邏輯層的session,從網(wǎng)絡(luò)庫繼承出去的,能被網(wǎng)絡(luò)回調(diào)的,至于是哪種設(shè)計(jì)模式我也記不住那名

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-23 12:59 by Todd
            個人覺得要看你的應(yīng)用是什么類型。 如果是像Web服務(wù)器這樣的,可以為每個連接分配一個線程, 從IO到邏輯都由這一個線程來處理, 線程之間沒什么好同步的, 因?yàn)閮蓚€客戶端之間沒什么交互。而且Web服務(wù)器服務(wù)每一個請求的時間不長(長了客戶端不等你)。

            如果是游戲服務(wù)器這種, 那IO和邏輯肯定要隔離的。 邏輯層可以用一個線程(如果并發(fā)用戶量很大必須是一個線程了, 開幾K個線程不現(xiàn)實(shí),鎖來鎖去也浪費(fèi)), IO層我個人理解上還存在障礙, 不確定是多線程同步IO+線程池好還是單線程異步IO好, 但肯定不能單線程同步IO, 否則 客戶端之間要相互阻塞了。 在IO層與邏輯層之間共享一個收發(fā)緩沖區(qū),肯定要有鎖了,但只是存取緩沖區(qū),代價(jià)不高, 單核心時甚至不存在什么代價(jià)吧? 再有我覺得高并發(fā)服務(wù)器難以維持長連接,應(yīng)該是客戶端定時請求吧(IO層需限定請求頻次吧)

            # re: 服務(wù)器多線程方案的選擇  回復(fù)  更多評論   

            2011-11-25 22:01 by 冷鋒
            如果玩家同時發(fā)兩個消息給服務(wù)端,前一個是需要操作數(shù)據(jù)庫的,假如應(yīng)用服務(wù)器跟數(shù)據(jù)庫服務(wù)器之間是用異步回調(diào)方式通信的,那么在應(yīng)用服務(wù)器要怎么保證返回給客戶端的是順序的呢?@Todd

            posts - 15, comments - 18, trackbacks - 0, articles - 0

            Copyright © 冷鋒

            亚洲国产一成久久精品国产成人综合| 亚洲国产婷婷香蕉久久久久久| 欧美亚洲国产精品久久久久| 免费精品国产日韩热久久| 久久亚洲AV成人无码| 久久精品无码专区免费| 欧美熟妇另类久久久久久不卡| 久久亚洲国产成人精品无码区| 久久香蕉国产线看观看99| 亚洲精品无码久久毛片| 一本一本久久a久久综合精品蜜桃| 久久综合精品国产一区二区三区| 亚洲人成网站999久久久综合| 国产婷婷成人久久Av免费高清| 色8久久人人97超碰香蕉987| 国产精品综合久久第一页| MM131亚洲国产美女久久| 久久久99精品成人片中文字幕 | 久久久久人妻一区精品性色av| 久久噜噜久久久精品66| 亚洲午夜久久久久久久久久| 亚洲精品久久久www| 中文字幕久久欲求不满| 久久国产成人午夜aⅴ影院| 91精品婷婷国产综合久久| 久久精品亚洲精品国产色婷| 性做久久久久久久久老女人| 亚洲精品国产自在久久| 青青青国产成人久久111网站| 久久久久久久久久久久中文字幕| 老男人久久青草av高清| 午夜精品久久久久成人| 亚洲七七久久精品中文国产| 久久免费99精品国产自在现线 | 久久久噜噜噜久久熟女AA片| 久久精品国产亚洲AV忘忧草18| 亚洲精品乱码久久久久久自慰| 天天躁日日躁狠狠久久| 77777亚洲午夜久久多喷| 亚洲午夜无码久久久久| 无码国内精品久久人妻|