[發(fā)明專利]一種適用于高并發(fā)場(chǎng)景的TCP通道管理系統(tǒng)及其方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201810097944.3
• 申請(qǐng)日: 2018-01-31
• 公開(kāi)（公告）號(hào): CN108459915A
• 公開(kāi)（公告）日: 2018-08-28
• 發(fā)明（設(shè)計(jì)）人: 馬漢鑄
• 申請(qǐng)（專利權(quán)）人: 中電福富信息科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 福州君誠(chéng)知識(shí)產(chǎn)權(quán)代理有限公司 35211
• 代理人: 林世庭

1.一種適用于高并發(fā)場(chǎng)景的TCP通道管理系統(tǒng)，其特征在于：其包括接入網(wǎng)關(guān)、消息中間件、數(shù)據(jù)分析服務(wù)和TSP業(yè)務(wù)服務(wù)，多個(gè)客戶端連接接入網(wǎng)關(guān)，接入網(wǎng)關(guān)連接消息中間件，消息中間件分別連接數(shù)據(jù)分析服務(wù)和TSP業(yè)務(wù)服務(wù)，接入網(wǎng)關(guān)提供客戶端接入、鏈路合法性驗(yàn)證以及超時(shí)管理服務(wù)；

接入網(wǎng)關(guān)包括接收器、socket管理表、任務(wù)池和鏈路檢測(cè)器，接收器用于啟動(dòng)監(jiān)聽(tīng)服務(wù)、接受客戶端連接請(qǐng)求、加入epoll通訊模型以及藉由epoll事件監(jiān)測(cè)socket鏈路操作；socket管理表用于存儲(chǔ)客戶端與接入建立的socket鏈路信息；任務(wù)池用于藉由epoll事件監(jiān)測(cè)線程、根據(jù)分發(fā)策略分配放入任務(wù)隊(duì)列的分發(fā)事件處理、任務(wù)消費(fèi)線程處理和解析業(yè)務(wù)邏輯通過(guò)業(yè)務(wù)線程處理；鏈路檢測(cè)器用于定時(shí)的鏈路管理、監(jiān)測(cè)到通道狀態(tài)、以事件的方式通知消息處理模塊實(shí)例以及將消息處理實(shí)例以任務(wù)的形式分發(fā)到任務(wù)隊(duì)列。

2.根據(jù)權(quán)利要求1所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理系統(tǒng)，其特征在于：所述socket鏈路信息包括socket鏈路唯一標(biāo)識(shí)和socket管理信息。

3.根據(jù)權(quán)利要求2所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理系統(tǒng)，其特征在于：所述socket的管理信息包括鏈路狀態(tài)、時(shí)間戳、句柄和流水號(hào)。

4.根據(jù)權(quán)利要求1所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理系統(tǒng)，其特征在于：所述鏈路管理包括鏈路心跳和鏈路合法性驗(yàn)證超時(shí)管理。

5.一種適用于高并發(fā)場(chǎng)景的TCP通道管理方法，其特征在于：其包括以下步驟：

S1，初始化全局?jǐn)?shù)據(jù)，創(chuàng)建任務(wù)隊(duì)列池，綁定處理線程，實(shí)例化epoll實(shí)現(xiàn)類、接收器；

S2，接收器啟動(dòng)監(jiān)聽(tīng)服務(wù)，由一個(gè)線程循環(huán)接收epoll事件；

S3，接收器處理接受連接事件，創(chuàng)建接入socket實(shí)例，并socket鏈路信息加入socket管理表，

S4，處理讀寫事件根據(jù)socket句柄分配放入任務(wù)隊(duì)列，由讀寫線程去處理，解析業(yè)務(wù)邏輯由業(yè)務(wù)線程去處理；

S5，鏈路檢測(cè)器根據(jù)socket管理表，定時(shí)負(fù)責(zé)鏈路管理，監(jiān)測(cè)到通道狀態(tài)，以事件的方式通知消息處理模塊實(shí)例，消息處理實(shí)例再以任務(wù)的形式分發(fā)到任務(wù)隊(duì)列，由任務(wù)隊(duì)列線程去處理具體的任務(wù)。

6.根據(jù)權(quán)利要求5所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理方法，其特征在于：所述步驟S3中socket鏈路信息包括socket鏈路唯一標(biāo)識(shí)和socket管理信息，socket管理信息包括鏈路狀態(tài)、時(shí)間戳、句柄和流水號(hào)。

7.根據(jù)權(quán)利要求5所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理方法，其特征在于：所述步驟S4中socket句柄采用取模策略分配放入任務(wù)隊(duì)列，解析業(yè)務(wù)邏輯由一協(xié)議解析模塊完成。

8.根據(jù)權(quán)利要求5所述的一種適用于高并發(fā)場(chǎng)景的TCP通道管理方法，其特征在于：所述步驟S5中的定時(shí)負(fù)責(zé)鏈路管理包括鏈路心跳和鏈路合法性驗(yàn)證超時(shí)。