[發(fā)明專利]分布式系統(tǒng)中提升網(wǎng)絡(luò)IO讀寫性能的方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202010739220.1
• 申請(qǐng)日: 2020-07-28
• 公開（公告）號(hào): CN111897496A
• 公開（公告）日: 2020-11-06
• 發(fā)明（設(shè)計(jì)）人: 南坤;謝赟;韓欣;孫卓峰
• 申請(qǐng)（專利權(quán)）人: 上海德拓信息技術(shù)股份有限公司
• 主分類號(hào): G06F3/06
• 分類號(hào): G06F3/06;G06F9/48;G06F9/54;H04L29/06;H04L29/08
• 代理公司: 上海中外企專利代理事務(wù)所(特殊普通合伙) 31387
• 代理人: 孫益青

1.一種分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于包括如下步驟：

S1：設(shè)立事件中心預(yù)定義四類消息事件，所述四類消息事件包括FD類事件，定時(shí)器類事件，外部事件和輪詢事件；

S2：工作線程啟動(dòng)，事件中心對(duì)消息事件進(jìn)行格式分類，并基于格式分類結(jié)果在消息事件上標(biāo)記格式基類；所述格式基類包括數(shù)據(jù)消息，心跳消息，集群消息和回復(fù)消息；

S3：消息管理器將消息事件分發(fā)給消息分發(fā)器；

S4：消息分發(fā)器基于格式基類對(duì)消息事件設(shè)立優(yōu)先級(jí)隊(duì)列；

S5：基于S4所得優(yōu)先級(jí)隊(duì)列對(duì)消息事件進(jìn)行管理。

2.如權(quán)利要求1所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于，步驟S5中基于QOS機(jī)制，在DT_m_dispatchers中設(shè)計(jì)優(yōu)先級(jí)隊(duì)列。

3.如權(quán)利要求1所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于步驟S4包括：

S41：讀取消息事件上標(biāo)記的格式基類，若消息事件為數(shù)據(jù)消息則跳轉(zhuǎn)至S42，若消息事件為心跳消息則跳轉(zhuǎn)至S43，若消息事件為集群消息則跳轉(zhuǎn)至S44，若消息事件為回復(fù)消息則跳轉(zhuǎn)至S45；

S42：在寫管道中啟動(dòng)寫工作線程，將消息事件編碼后發(fā)送至指定消息服務(wù)進(jìn)程，跳轉(zhuǎn)至S5；

S43：在寫管道中啟動(dòng)寫工作線程，將消息事件編碼后投遞到消息優(yōu)先級(jí)隊(duì)列并發(fā)送外部事件、在下次循環(huán)中發(fā)送至指定消息服務(wù)進(jìn)程，跳轉(zhuǎn)至S5；

S44：在寫管道中啟動(dòng)寫工作線程，將消息事件編碼后投遞到消息優(yōu)先級(jí)隊(duì)列并發(fā)送外部事件、在下次循環(huán)中發(fā)送至指定消息服務(wù)進(jìn)程，跳轉(zhuǎn)至S5；

S45：在讀管道中啟動(dòng)讀工作線程，對(duì)消息事件編碼后發(fā)送至指定客戶端服務(wù)進(jìn)程，跳轉(zhuǎn)至S5。

4.如權(quán)利要求3所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于，步驟S42包括：

S421：向已注冊(cè)的寫管道中寫入喚醒字符，喚醒寫事件或使寫工作線程檢測(cè)到寫事件；

S422：寫工作線程按照指定協(xié)議編碼對(duì)消息事件做編碼處理；

S423：將編碼后的消息通過發(fā)送消息接口發(fā)到指定消息服務(wù)進(jìn)程。

5.如權(quán)利要求3所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于，步驟S43包括：

S431：向已注冊(cè)的寫管道中寫入喚醒字符，喚醒寫事件或使寫工作線程檢測(cè)到寫事件；

S432：寫工作線程按照指定協(xié)議對(duì)消息事件做編碼處理，并將編碼后的消息投遞到消息優(yōu)先級(jí)隊(duì)列并發(fā)送外部事件；

S433：在下次循環(huán)處理時(shí)，寫工作線程將S432所得編碼后的消息通過發(fā)送消息接口發(fā)到指定消息服務(wù)進(jìn)程。

6.如權(quán)利要求3所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于，步驟S44包括：

S441：向已注冊(cè)的寫管道中寫入喚醒字符，喚醒寫事件或使寫工作線程檢測(cè)到寫事件；

S442：寫工作線程按照指定協(xié)議對(duì)消息事件做編碼處理，并將編碼后的消息投遞到消息優(yōu)先級(jí)隊(duì)列并發(fā)送外部事件；

S443：在下次循環(huán)處理時(shí)，寫工作線程將S442所得編碼后的消息通過發(fā)送消息接口發(fā)到指定消息服務(wù)進(jìn)程。

7.如權(quán)利要求1所述分布式存儲(chǔ)系統(tǒng)的網(wǎng)絡(luò)IO讀寫方法，其特征在于，步驟S45包括：

S451：向已注冊(cè)的讀管道中寫入喚醒字符，喚醒讀事件或使工作線程檢測(cè)到讀事件；

S452：讀工作線程按照指定協(xié)議對(duì)消息事件做編碼處理；

S453：讀工作線程將S452所得編碼后的消息通過發(fā)送消息接口發(fā)到指定客戶端服務(wù)進(jìn)程。