[發(fā)明專利]消息處理方法、系統(tǒng)、裝置及電子設(shè)置

有效

• 申請?zhí)枺?/td>: 202010761914.5
• 申請日: 2020-07-31
• 公開（公告）號: CN111885198B
• 公開（公告）日: 2023-07-11
• 發(fā)明（設(shè)計）人: 蔡林桐;李健;武衛(wèi)東
• 申請（專利權(quán)）人: 北京捷通華聲科技股份有限公司
• 主分類號: H04L67/14
• 分類號: H04L67/14;H04L67/143
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 黃海英

本申請公開了一種消息處理方法、系統(tǒng)、裝置及電子設(shè)置。該方法包括：接收目標(biāo)分片的處理請求，其中，目標(biāo)分片為目標(biāo)會話中的任意一個分片；查詢待辦任務(wù)流中是否已存在目標(biāo)會話的流式任務(wù),其中，目標(biāo)會話的流式任務(wù)基于目標(biāo)會話的任意一個分片的處理請求建立；在存在的情況下，判斷目標(biāo)會話的流式任務(wù)是否攜帶有過載標(biāo)簽；在目標(biāo)會話的流式任務(wù)未攜帶有過載標(biāo)簽的情況下，將目標(biāo)分片添加至目標(biāo)會話的流式任務(wù)中，并對目標(biāo)會話的流式任務(wù)進行處理。通過本申請，解決了相關(guān)技術(shù)中采用HTTP協(xié)議完成流式任務(wù)時，在流量過載的情況下大量丟包的問題。

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

本申請涉及消息處理技術(shù)領(lǐng)域，具體而言，涉及一種消息處理方法、系統(tǒng)、裝置及電子設(shè)置。

背景技術(shù)

一句話語音識別常見于智能家居、語音助手等場景中。例如，用戶使用遙控器或手機進行語音輸入，先按鍵或按鈕開始錄音，然后說出指令，最后再次按鍵或松開按鈕結(jié)束錄音，過程中將錄音進行壓縮，并采用流式分片的方式發(fā)送給語音識別服務(wù)器進行語音識別。

相關(guān)技術(shù)中，由于http協(xié)議標(biāo)準(zhǔn)，易于對接聯(lián)調(diào)，通常使用http協(xié)議實現(xiàn)一句話語音識別過程中的數(shù)據(jù)傳輸，具體地，客戶端發(fā)送音頻時在請求頭攜帶會話的唯一標(biāo)識、分片序號、結(jié)束標(biāo)識等信息，服務(wù)端收到分片序號為1的請求，創(chuàng)建流式任務(wù)，并在流式任務(wù)中等待每個分片到達，全部分片到達后開始進行語音識別。具體地，在同一個會話的唯一標(biāo)識下，有從1開始的連續(xù)序號的分片，且序號最大的一個分片帶有結(jié)束標(biāo)識，即表明全部分片到達。但是，使用http協(xié)議實現(xiàn)數(shù)據(jù)傳輸存在的缺陷時，http協(xié)議的每個分片在邏輯上是獨立的，使得實際業(yè)務(wù)中可能會偶發(fā)出現(xiàn)分片丟包或分片到達亂序等問題。

進一步需要說明的是，為規(guī)避突發(fā)大流量導(dǎo)致的業(yè)務(wù)訪問問題，一般需要根據(jù)等效測試結(jié)果設(shè)置過載保護的線程數(shù)；為規(guī)避客戶端發(fā)送錯誤或網(wǎng)絡(luò)阻塞等請求異常問題，一般需要給每個分片和會話分別設(shè)置等待超時時間，超過指定時間后未能觸發(fā)后續(xù)流程，則會超時返回錯誤，清除當(dāng)前分片或會話占用的資源。

具體地，對于低流量或網(wǎng)絡(luò)穩(wěn)定的場景，即使存在偶發(fā)的分片丟包或分片到達亂序問題，也不會影響系統(tǒng)整體的業(yè)務(wù)使用。但對于高流量或網(wǎng)絡(luò)不穩(wěn)定的場景，有可能請求數(shù)會大于過載保護的線程數(shù)，一旦出現(xiàn)該問題，超過線程數(shù)后到達的請求會直接返回錯誤，主動丟棄，不再處理?？蛻舳巳詴^續(xù)發(fā)送會話的其它請求分片，而會話中只要有一個分片因過載不處理，其余分片均會等待，直到等待超時；后續(xù)流量恢復(fù)到過載線程數(shù)以下，也會有大量已經(jīng)占用了線程數(shù)的等待中的請求，使得系統(tǒng)實際能夠正常處理的請求數(shù)遠遠低于預(yù)期值。此時繼續(xù)對部分分片過載不處理，而其余分片繼續(xù)占用線程等待，會導(dǎo)致出現(xiàn)惡性循環(huán)，系統(tǒng)將逐漸無法正常處理業(yè)務(wù)請求。從用戶角度看，體現(xiàn)為用戶量出現(xiàn)一個突增后，最開始會有一部分過載的用戶無法使用，隨著時間推移，流量逐漸恢復(fù)正常，但卻有越來越多的用戶無法使用，最終直至全部用戶均無法使用系統(tǒng)。

針對相關(guān)技術(shù)中采用HTTP協(xié)議完成流式任務(wù)時，在流量過載的情況下大量丟包的問題，目前尚未提出有效的解決方案。

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

本申請?zhí)峁┮环N消息處理方法、系統(tǒng)、裝置及電子設(shè)置，以解決相關(guān)技術(shù)中采用HTTP協(xié)議完成流式任務(wù)時，在流量過載的情況下大量丟包的問題。

根據(jù)本申請的一個方面，提供了一種消息處理方法。該方法包括：接收目標(biāo)分片的處理請求，其中，目標(biāo)分片為目標(biāo)會話中的任意一個分片；查詢待辦任務(wù)流中是否已存在目標(biāo)會話的流式任務(wù),其中，目標(biāo)會話的流式任務(wù)基于目標(biāo)會話的任意一個分片的處理請求建立；在存在的情況下，判斷目標(biāo)會話的流式任務(wù)是否攜帶有過載標(biāo)簽；在目標(biāo)會話的流式任務(wù)未攜帶有過載標(biāo)簽的情況下，將目標(biāo)分片添加至目標(biāo)會話的流式任務(wù)中，并對目標(biāo)會話的流式任務(wù)進行處理。

可選地，在查詢待辦任務(wù)流中是否已存在目標(biāo)會話的流式任務(wù)之前，該方法還包括：判斷當(dāng)前是否存在目標(biāo)操作，其中，目標(biāo)操作包括以下之一：查詢流式任務(wù)的操作，創(chuàng)建流式任務(wù)的操作；在當(dāng)前不存在目標(biāo)操作的情況下，執(zhí)行查詢待辦任務(wù)流中是否已存在目標(biāo)會話的流式任務(wù)的步驟。