goroutine和channel對tcp連接消息的收發(fā)

在看這篇文章之前,如果你沒看過golang利用socket封裝數(shù)據(jù),那我建議你看下;

同樣,如果沒看過goroutine和channel實(shí)現(xiàn)master-worker模式,同樣建議你看下并理解之后再來看這篇文章。

這篇文章主要是上兩篇文章的結(jié)合使用。

tcp消息的收發(fā)

我們已經(jīng)知道,socket是一個抽象層,其本質(zhì)是編程接口(API),對TCP/IP的封裝,TCP/IP也要提供可供程序員做網(wǎng)絡(luò)開發(fā)所用的接口,這就是Socket編程接口。所以我們隊tcp消息的收發(fā)即對socket中幾個接口的配合使用來完成。

golang利用socket封裝數(shù)據(jù)這篇文章中,我們對tcp的消息有收發(fā)的處理。但是,成千上萬個client發(fā)送到server端的tcp請求可能server端還能應(yīng)付得過來(每個tcp連接開啟一個goroutine,這是典型的BIO方式處理),要是數(shù)量級繼續(xù)往上呢?結(jié)果server端就不一定能應(yīng)付得過來了,因此考慮不用BIO的方式處理(之后會考慮寫一篇文章專門講一下BIO,NIO,AIO方式),暫時改用master-worker模式來處理tcp連接消息的收發(fā),對于剛看完上兩篇文章的你可能已經(jīng)想到了,將前兩篇文章稍作修改,就可以完成這個工作,因此我建議你最好動手試試,代碼完成之后運(yùn)行一遍看看是否成功。





















如果你任然沒有頭緒,這里或許會給你一點(diǎn)提示,在worker的Job中封裝conn,然后將server端的handleConn(conn net.Conn)函數(shù)移到worker中,在處理job那里調(diào)用handleConn()。由于對這個Job的處理不需要返回結(jié)果集,所以你可以嘗試取出master和worker中的結(jié)果集Result。









如果你已經(jīng)完成了上面的步驟,多次嘗試能否成功運(yùn)行且在server端正確解析數(shù)據(jù),如果都能成功解析數(shù)據(jù),那么恭喜你,成功了。


如果你發(fā)現(xiàn)在server端不斷接受數(shù)據(jù),而client端沒有接收到server返回的數(shù)據(jù),那么也恭喜你,踏入另外一個坑,你可以嘗試分析一下server接收到的數(shù)據(jù),看看問題出在什么地方,或者從tcp連接出發(fā),想想可能在哪個地方出現(xiàn)問題。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容