色综合久久综合中文综合网,香港aa三级久久三级,91久久精品国产成人久久

rpc應(yīng)答太快造成請(qǐng)求超時(shí)

rpc應(yīng)答太快造成請(qǐng)求超時(shí)

(金慶的專欄 2020.9)

在壓測(cè)中發(fā)現(xiàn)總有幾個(gè)請(qǐng)求超時(shí)，超時(shí)時(shí)長設(shè)大也會(huì)有，而成功的請(qǐng)求延時(shí)遠(yuǎn)小于超時(shí)時(shí)間。
查錯(cuò)的第一方向是查網(wǎng)絡(luò)庫中有消息丟失。
跟蹤所有消息，發(fā)現(xiàn)超時(shí)的消息應(yīng)該是正常處理并返回了。
于是查接收應(yīng)答消息后的處理，最終找到代碼：
```go
func (c *Client) onRpcRet(cbIndex uint32, ...) {
   ii, ok := c.callbacks.Load(cbIndex)
   if !ok {
        // logger.Errorf("onRpcRet can not find cbIndex %d", cbIndex) // 可能是超時(shí)已刪
        return
   }
```
打開日志，發(fā)現(xiàn)超時(shí)的請(qǐng)求對(duì)應(yīng)有該條錯(cuò)誤日志。
此處回調(diào)不存在的情況，正常是先超時(shí)刪除回調(diào)，然后再收到應(yīng)答。
現(xiàn)在是先收到了應(yīng)答，發(fā)現(xiàn)找不到回調(diào)，然后過了一段時(shí)間會(huì)被判為超時(shí)無響應(yīng)。

將下面代碼換個(gè)次序就好了：
```go
   if err := c.Session.Send(msg); err != nil {
        ...
        return
   }
   c.callbacks.Store(cbIndex, ...)
```
改為
```go
   // 必須先設(shè)回調(diào)，然后發(fā)送，因?yàn)閼?yīng)答可能會(huì)很快
   c.callbacks.Store(cbIndex, ...)
   if err := c.Session.Send(msg); err...
```

壓測(cè)時(shí)因?yàn)榧訅簷C(jī)CPU是滿負(fù)載運(yùn)轉(zhuǎn)，所以 Send() 和 Store() 之間可能會(huì)間隔數(shù)毫秒，
足夠 rpc 請(qǐng)求處理完成并返回，而應(yīng)答返回時(shí)回調(diào)還沒設(shè)置。

先 Send() 后 Store() 寫代碼會(huì)稍微簡(jiǎn)單點(diǎn)，因?yàn)?Send() 失敗后可以直接返回。
先 Store() 后 Send() 時(shí)，Send() 失敗則需要相應(yīng) Delete().

posted on 2020-09-17 15:59 金慶閱讀(498) 評(píng)論(0) 編輯收藏引用所屬分類: 2. 網(wǎng)游開發(fā) 、3. Golang

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh UE4 Blueprint Multiple Event BeginPlay 第9代游戲主機(jī) Canvas Scaler 的3種模式幀同步是否允許客戶端指定命令幀號(hào) rpc應(yīng)答太快造成請(qǐng)求超時(shí) 測(cè)試 tolua 例子 TestErrorStack lua變量缺少local造成unity死鎖 C# tolua 之間互傳 byte[] Unity使用異步grpc

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜