writeAndFlush亂序問題

項(xiàng)目背景

Server端使用netty 4,Client端使用websocket與server交互袁辈。

client與server有兩種交互方式(如下圖):

從圖中可以看出菜谣,對(duì)于 server -> client B(標(biāo)紅的那段),簡單來說分兩種:

1晚缩、client B 主動(dòng)請(qǐng)求后的response

2尾膊、server的主動(dòng)push

client與server的兩種交互方式

亂序問題

無論是response還是push,在服務(wù)端都是使用netty的ctx.channel().writeAndFlush()荞彼。但是在并發(fā)情況下冈敛,發(fā)現(xiàn)某些消息到達(dá)客戶端是亂序的,如下圖鸣皂。

亂序問題

經(jīng)過一段追查后終于找到原因抓谴,是netty線程模型搞的鬼。netty線程模型的介紹可以參見Netty版本升級(jí)血淚史之線程篇的第6點(diǎn)寞缝。

簡單來說就是癌压,netty 4中,使用ctx.channel().writeAndFlush()時(shí)荆陆,會(huì)去檢查?當(dāng)前線程 是否為 netty為channel分配的eventLoop所對(duì)應(yīng)的線程滩届,如果是的話就直接調(diào)用,不是的話就封裝成一個(gè)task提交到eventLoop的任務(wù)隊(duì)列中被啼。

對(duì)應(yīng)到本case中帜消,因?yàn)閷?duì)于request - response方式棠枉,我是直接在netty的work線程(netty為channel分配的eventLoop所對(duì)應(yīng)的線程)中直接處理request,并回response泡挺。所以對(duì)于給Client B的response辈讶,調(diào)用Client B的ctx.channel().writeAndFlush()是直接寫出,只要在業(yè)務(wù)層面上保證調(diào)用ctx.channel().writeAndFlush()是有序的娄猫,那么寫出到Client B就是有序的贱除。

但是對(duì)于push方式,是在其他線程中調(diào)用Client B的ctx.channel().writeAndFlush()稚新,這時(shí)候會(huì)把消息封裝成task提交到Client B的eventLoop任務(wù)隊(duì)列中,與response消息混在一起跪腹。在并發(fā)情況下褂删,即便在業(yè)務(wù)層上做了有序性的保證,但無法去保證netty是先執(zhí)行task的消息冲茸,還是先執(zhí)行那種直接調(diào)用ctx.channel().writeAndFlush()的消息屯阀。

解決方案

業(yè)務(wù)層面上,對(duì)消息增加時(shí)序性保證的id(我這里采用的是遞增id)轴术,端上接收到消息后难衰,按照id去做消息重排序,這樣就能保證消息按序到達(dá)逗栽。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末盖袭,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子彼宠,更是在濱河造成了極大的恐慌鳄虱,老刑警劉巖,帶你破解...
    沈念sama閱讀 211,290評(píng)論 6 491
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件凭峡,死亡現(xiàn)場(chǎng)離奇詭異拙已,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)摧冀,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,107評(píng)論 2 385
  • 文/潘曉璐 我一進(jìn)店門倍踪,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人索昂,你說我怎么就攤上這事建车√愀龋” “怎么了焦影?”我有些...
    開封第一講書人閱讀 156,872評(píng)論 0 347
  • 文/不壞的土叔 我叫張陵丸升,是天一觀的道長铐刘。 經(jīng)常有香客問我更耻,道長,這世上最難降的妖魔是什么错英? 我笑而不...
    開封第一講書人閱讀 56,415評(píng)論 1 283
  • 正文 為了忘掉前任菠秒,我火速辦了婚禮,結(jié)果婚禮上戒突,老公的妹妹穿的比我還像新娘屯碴。我一直安慰自己,他們只是感情好膊存,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,453評(píng)論 6 385
  • 文/花漫 我一把揭開白布导而。 她就那樣靜靜地躺著,像睡著了一般隔崎。 火紅的嫁衣襯著肌膚如雪今艺。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,784評(píng)論 1 290
  • 那天爵卒,我揣著相機(jī)與錄音虚缎,去河邊找鬼。 笑死钓株,一個(gè)胖子當(dāng)著我的面吹牛实牡,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播轴合,決...
    沈念sama閱讀 38,927評(píng)論 3 406
  • 文/蒼蘭香墨 我猛地睜開眼创坞,長吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來了受葛?” 一聲冷哼從身側(cè)響起题涨,我...
    開封第一講書人閱讀 37,691評(píng)論 0 266
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎总滩,沒想到半個(gè)月后携栋,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,137評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡咳秉,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,472評(píng)論 2 326
  • 正文 我和宋清朗相戀三年婉支,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片澜建。...
    茶點(diǎn)故事閱讀 38,622評(píng)論 1 340
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡向挖,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出炕舵,到底是詐尸還是另有隱情何之,我是刑警寧澤,帶...
    沈念sama閱讀 34,289評(píng)論 4 329
  • 正文 年R本政府宣布咽筋,位于F島的核電站溶推,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜蒜危,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,887評(píng)論 3 312
  • 文/蒙蒙 一虱痕、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧辐赞,春花似錦部翘、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,741評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至赘风,卻和暖如春夹囚,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背邀窃。 一陣腳步聲響...
    開封第一講書人閱讀 31,977評(píng)論 1 265
  • 我被黑心中介騙來泰國打工荸哟, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人蛔翅。 一個(gè)月前我還...
    沈念sama閱讀 46,316評(píng)論 2 360
  • 正文 我出身青樓敲茄,卻偏偏與公主長得像位谋,于是被迫代替她去往敵國和親山析。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,490評(píng)論 2 348