[發(fā)明專(zhuān)利]一種消息鎖處理方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201810289426.1
• 申請(qǐng)日: 2018-03-30
• 公開(kāi)（公告）號(hào): CN108686373B
• 公開(kāi)（公告）日: 2021-07-23
• 發(fā)明（設(shè)計(jì)）人: 孟志兵;張文明;陳少杰
• 申請(qǐng)（專(zhuān)利權(quán)）人: 武漢斗魚(yú)網(wǎng)絡(luò)科技有限公司
• 主分類(lèi)號(hào): A63F13/355
• 分類(lèi)號(hào): A63F13/355;A63F13/70;A63F13/79;G06F9/54;H04L29/06;H04L29/08
• 代理公司: 北京眾達(dá)德權(quán)知識(shí)產(chǎn)權(quán)代理有限公司 11570
• 代理人: 劉杰

1.一種消息鎖處理方法，應(yīng)用于游戲客戶端，其特征在于，包括：

監(jiān)控所述游戲客戶端與游戲服務(wù)端之間是否發(fā)生斷線重連；

步驟a、在所述游戲客戶端與所述游戲服務(wù)端之間發(fā)生斷線重連之前，若接收到當(dāng)前socket消息，存儲(chǔ)所述當(dāng)前socket消息至本地?cái)?shù)組；

步驟b、從所述本地?cái)?shù)組中取出所述當(dāng)前socket消息進(jìn)行處理，基于處理得到的游戲數(shù)據(jù)進(jìn)行游戲過(guò)程；

重復(fù)執(zhí)行所述步驟a至步驟b，直至所述游戲客戶端與所述游戲服務(wù)端之間發(fā)生所述斷線重連；

如果所述游戲客戶端與所述游戲服務(wù)端之間發(fā)生所述斷線重連，對(duì)所述游戲客戶端的所述本地?cái)?shù)組加鎖，觸發(fā)從所述本地?cái)?shù)組中取出第一socket消息的事件中斷，其中，所述第一socket消息為在所述游戲客戶端與所述游戲服務(wù)端之間發(fā)生斷線重連之前存入所述本地?cái)?shù)組的至少一個(gè)socket消息；

在所述游戲客戶端與所述游戲服務(wù)端之間重新處于連接狀態(tài)下，若監(jiān)控到所述游戲客戶端的游戲界面重新打開(kāi)，對(duì)所述本地?cái)?shù)組解鎖；

向所述本地?cái)?shù)組中存入第二socket消息，觸發(fā)對(duì)從所述本地?cái)?shù)組中取出所述第一socket消息和所述第二socket消息進(jìn)行處理的事件執(zhí)行。

2.如權(quán)利要求1所述的消息鎖處理方法，其特征在于，所述從所述本地?cái)?shù)組中取出所述當(dāng)前socket消息進(jìn)行處理，包括：

判斷所述本地?cái)?shù)組中當(dāng)前是否存在未處理的socket消息；

如果是，從所述本地?cái)?shù)組中取出所述未處理的socket消息進(jìn)行處理，否則將用于從所述本地?cái)?shù)組中取出socket消息進(jìn)行處理的進(jìn)程處于阻塞狀態(tài)，直到向所述本地?cái)?shù)組中存入所述當(dāng)前socket消息，從所述本地?cái)?shù)組中取出所述當(dāng)前socket消息進(jìn)行處理。

3.如權(quán)利要求1或2所述的消息鎖處理方法，其特征在于，向所述本地?cái)?shù)組中存入第二socket消息，觸發(fā)對(duì)從所述本地?cái)?shù)組中取出所述第一socket消息和所述第二socket消息進(jìn)行處理的事件執(zhí)行，包括：

向所述游戲服務(wù)端發(fā)送空消息，所述空消息用于觸發(fā)所述游戲服務(wù)端向所述游戲客戶端反饋所述第二socket消息；

接收并存儲(chǔ)所述第二socket消息至所述本地?cái)?shù)組；

以存儲(chǔ)所述第二socket消息至所述本地?cái)?shù)組的事件，觸發(fā)對(duì)從所述本地?cái)?shù)組中順次取出所述第一socket消息和所述第二socket消息進(jìn)行處理的事件執(zhí)行。

4.如權(quán)利要求1或2所述的消息鎖處理方法，其特征在于，所述向所述本地?cái)?shù)組中存入第二socket消息，觸發(fā)對(duì)從所述本地?cái)?shù)組中取出所述第一socket消息和所述第二socket消息進(jìn)行處理的事件執(zhí)行，包括：

等待所述游戲服務(wù)端主動(dòng)下發(fā)所述第二socket消息；

將所述游戲服務(wù)端主動(dòng)下發(fā)的所述第二socket消息存儲(chǔ)至所述本地?cái)?shù)組；

以存儲(chǔ)所述第二socket消息至所述本地?cái)?shù)組的事件，觸發(fā)對(duì)從所述本地?cái)?shù)組中順次取出所述第一socket消息和所述第二socket消息進(jìn)行處理的事件執(zhí)行。

5.如權(quán)利要求1所述的消息鎖處理方法，其特征在于，所述接收到當(dāng)前socket消息，包括：

接收來(lái)自所述游戲服務(wù)端的N個(gè)二進(jìn)制消息塊，其中，所述N個(gè)二進(jìn)制消息塊為所述游戲服務(wù)端下發(fā)的原始socket消息被拆分為所述N個(gè)二進(jìn)制消息塊，將所述N個(gè)二進(jìn)制消息塊傳送至所述游戲客戶端，N為大于或等于1的整數(shù)；

將所述N個(gè)二進(jìn)制消息塊拼接為二進(jìn)制完整消息；

解析所述二進(jìn)制完整消息，獲得所述當(dāng)前socket消息。