[發(fā)明專利]非可靠物理傳輸通道下的多并發(fā)調(diào)用式通信方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202210918020.1
• 申請(qǐng)日: 2022-08-01
• 公開（公告）號(hào): CN115297193A
• 公開（公告）日: 2022-11-04
• 發(fā)明（設(shè)計(jì)）人: 杜若蒙;魏志峰
• 申請(qǐng)（專利權(quán)）人: 北京左江科技股份有限公司
• 主分類號(hào): H04L69/16
• 分類號(hào): H04L69/16;H04L67/568
• 代理公司: 中國(guó)兵器工業(yè)集團(tuán)公司專利中心 11011
• 代理人: 辛海明

本發(fā)明涉及一種非可靠物理傳輸通道下的多并發(fā)調(diào)用式通信方法，屬于云計(jì)算領(lǐng)域。本發(fā)明通過(guò)用戶數(shù)據(jù)處理服務(wù)將多用戶并行的數(shù)據(jù)串行化，同時(shí)保證所有用戶并發(fā)數(shù)據(jù)流的獨(dú)立性和完整性，實(shí)現(xiàn)單進(jìn)程支持高并發(fā)的調(diào)用式服務(wù)；本發(fā)明通過(guò)設(shè)備管理服務(wù)，能夠提供設(shè)備的虛擬化，提高設(shè)備服務(wù)的利用率；本發(fā)明通過(guò)優(yōu)化的可靠傳輸協(xié)議，能夠在對(duì)端服務(wù)設(shè)備資源受限的前提下，實(shí)現(xiàn)高質(zhì)量可靠傳輸。本發(fā)明所述方法在非可靠物理傳輸通道對(duì)端服務(wù)設(shè)備資源受限的情況下，對(duì)設(shè)備服務(wù)在通信質(zhì)量，通信傳輸效率，服務(wù)并發(fā)數(shù)方面有較高提升。

技術(shù)領(lǐng)域

本發(fā)明屬于云計(jì)算領(lǐng)域，具體涉及一種非可靠物理傳輸通道下的多并發(fā)調(diào)用式通信方法。

背景技術(shù)

隨著云計(jì)算和大數(shù)據(jù)的發(fā)展，數(shù)據(jù)中心的數(shù)據(jù)越來(lái)越龐大，既有結(jié)構(gòu)化數(shù)據(jù)也有非結(jié)構(gòu)化數(shù)據(jù)，這些數(shù)據(jù)均需要服務(wù)器處理，更需要大容量的存儲(chǔ)設(shè)備進(jìn)行存儲(chǔ)。云計(jì)算和大數(shù)據(jù)提供了對(duì)物理服務(wù)器上的資源最大化利用的一個(gè)切實(shí)可行的解決方案。另一方面，現(xiàn)在高性能的硬件設(shè)備價(jià)格昂貴，在沒有高性能通信技術(shù)的前提下，這種昂貴的硬件設(shè)備，性能并沒有得到最大程度上的利用，PCI-E專用數(shù)據(jù)處理卡就是其中一種。

傳統(tǒng)PCI-E專用數(shù)據(jù)處理卡使用上大多采用基于PCI-E協(xié)議專用通道提供服務(wù)，開發(fā)周期短，穩(wěn)定性高。這為本發(fā)明提供了基礎(chǔ)。

目前市場(chǎng)上能夠提供調(diào)用式服務(wù)的PCI-E專用數(shù)據(jù)處理卡大都結(jié)構(gòu)簡(jiǎn)單，功能單一，服務(wù)速度一般在每秒幾兆到幾十兆，存在速度不高，不能支持海量數(shù)據(jù)讀取，無(wú)法使用大量專用服務(wù)請(qǐng)求高并發(fā)和高速專用計(jì)算的需求。

發(fā)明內(nèi)容

(一)要解決的技術(shù)問題

本發(fā)明要解決的技術(shù)問題是如何提供一種非可靠物理傳輸通道下的多并發(fā)調(diào)用式通信方法，以解決傳統(tǒng)PCI-E專用數(shù)據(jù)處理卡存在速度不高，不能支持海量數(shù)據(jù)讀取，無(wú)法使用大量專用服務(wù)請(qǐng)求高并發(fā)和高速專用計(jì)算的問題。

(二)技術(shù)方案

為了解決上述技術(shù)問題，本發(fā)明提出一種非可靠物理傳輸通道下的多并發(fā)調(diào)用式通信方法，該方法包括如下步驟：

用戶數(shù)據(jù)處理服務(wù)接收到用戶實(shí)體發(fā)來(lái)的請(qǐng)求數(shù)據(jù)，記錄用戶實(shí)體信息和I/O端口信息，并對(duì)用戶實(shí)體發(fā)來(lái)的請(qǐng)求數(shù)據(jù)做相應(yīng)處理，交給下行數(shù)據(jù)處理組件；

下行數(shù)據(jù)處理組件收到請(qǐng)求數(shù)據(jù)，根據(jù)服務(wù)實(shí)體的需求對(duì)請(qǐng)求數(shù)據(jù)做解封裝和封裝處理，將請(qǐng)求數(shù)據(jù)中的元數(shù)據(jù)組織為服務(wù)實(shí)體能夠識(shí)別的請(qǐng)求數(shù)據(jù)包，并將處理完畢的請(qǐng)求數(shù)據(jù)包交給設(shè)備數(shù)據(jù)處理服務(wù)；

設(shè)備數(shù)據(jù)處理服務(wù)收到請(qǐng)求數(shù)據(jù)包，通過(guò)設(shè)備數(shù)據(jù)處理服務(wù)與服務(wù)實(shí)體間的可靠傳輸協(xié)議，發(fā)送給服務(wù)實(shí)體，同時(shí)設(shè)備數(shù)據(jù)處理服務(wù)還異步地接收服務(wù)實(shí)體的響應(yīng)數(shù)據(jù)包，收到響應(yīng)數(shù)據(jù)包后將會(huì)通知上行數(shù)據(jù)處理組件，并將響應(yīng)數(shù)據(jù)包交給上行數(shù)據(jù)處理組件；

上行數(shù)據(jù)處理組件收到通知，收取響應(yīng)數(shù)據(jù)包，通過(guò)解析數(shù)據(jù)包，將響應(yīng)數(shù)據(jù)中的元數(shù)據(jù)封裝為用戶實(shí)體能夠解析的響應(yīng)數(shù)據(jù)，并交給用戶數(shù)據(jù)處理服務(wù)；

用戶數(shù)據(jù)處理服務(wù)收到響應(yīng)數(shù)據(jù)，通過(guò)查找用戶信息，查找到匹配的I/0端口,異步的將響應(yīng)數(shù)據(jù)發(fā)給用戶；

其中，TCP服務(wù)器及用戶API調(diào)用為用戶實(shí)體，PCI-E數(shù)據(jù)處理設(shè)備為服務(wù)實(shí)體。

進(jìn)一步地，用戶數(shù)據(jù)處理服務(wù)的服務(wù)建立流程包括如下步驟：

步驟S21、初始化通信服務(wù)，創(chuàng)建TCP監(jiān)聽服務(wù)；并創(chuàng)建如下數(shù)據(jù)結(jié)構(gòu)：

創(chuàng)建請(qǐng)求數(shù)據(jù)隊(duì)列sort_q_s，并初始化，用于多用戶并行數(shù)據(jù)的串行化處理；

創(chuàng)建滑動(dòng)窗口隊(duì)列wind_q_s，并初始化，用于實(shí)現(xiàn)用戶數(shù)據(jù)處理服務(wù)到物理設(shè)備的可靠傳輸；

創(chuàng)建客戶端隊(duì)列clients_s，并初始化，用于實(shí)現(xiàn)用戶和用戶數(shù)據(jù)的管理；