[發明專利]一種時延控制方法、系統及相關設備

在審

• 申請號: 202110080836.7
• 申請日: 2021-01-21
• 公開（公告）號: CN114816778A
• 公開（公告）日: 2022-07-29
• 發明（設計）人: 王日新;楊文杰;舒茂松
• 申請（專利權）人: 華為技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F13/16
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 熊永強;李稷芳

本申請提供了一種時延控制方法、系統及相關設備。其中，該方法包括：時延控制系統接收生產者發送的消息，根據所述消息的產生時間，確定所述消息產生時間所屬的時間段，從而確定可寫入的文件組，并將所述消息寫入所述文件組中；根據消息產生時間、消息到達時間及消息源的標識獲得波動指標，所述波動指標用于描述所述消息源的時延波動幅度；根據所述波動指標更新所述文件組的狀態，并將處于可消費狀態的文件組輸出給消費者。上述方法可以免去消費者在處理過程中緩存消息的過程，降低了內存和CPU計算資源的占用率，同時也提高了響應速度。

技術領域

本申請涉及消息總線技術領域，尤其涉及一種時延控制方法、系統及相關設備。

背景技術

隨著第四代、第五代通信技術的商用普及，網絡吞吐率不斷攀升，網絡結構復雜度顯著提高，數據量指數級提升，同時通信運營商對于大規模網絡規劃優化數據分析的應用也越來越多，網絡規劃優化面臨著很大的挑戰。例如，在5G非獨立組網(Non-Standalone，NSA)場景下，進行網絡優化規劃往往需要把相同時間產生的來自不同源頭的消息放到一起處理分析。

為滿足上述業務場景，需要一種具有高吞吐量、高可靠性等特點的消息系統。現有的消息系統Apache Kafka是一個高吞吐量的分布式發布訂閱消息系統，生產者按順序將消息提供給Kafka，消費者也按順序取出消息并將其分發到各自對應的任務線程中，等任務線程中的消息齊全時再進行處理，這就導致任務線程總是需要緩存一部分低時延的消息，同時花較長時間等待高時延的消息，從而持續占用大量的隨機存取存儲器(Random AccessMemory，RAM)資源(即持續占用大量內存資源)和中央處理器(Central Processing Unit，CPU)資源，大大提高了處理邏輯的復雜度，同時也降低了消息處理的效率。

因此，如何在消息總線系統中進行時延控制是目前亟待解決的問題。

發明內容

本申請提供了一種時延控制方法、系統及相關設備，能夠讓消費者直接獲取同一時間產生的消息，避免了長時間等待，大大節省了RAM資源和CPU計算資源，提高了響應速度。

第一方面，本申請提供一種時延控制方法，所述方法可包括：接收生產者發送的消息，所述生產者用于采集消息源產生的數據，其中，所述消息攜帶消息產生時間和所述消息源的標識；根據所述消息產生時間，確定所述消息產生時間所屬的時間段，所述時間段與文件組存在一一對應關系，其中，所述文件組用于存儲所述時間段內產生的消息；將所述消息寫入所述消息產生時間所屬的時間段對應的文件組中，并根據所述消息產生時間、消息到達時間及所述消息源的標識獲得波動指標，其中，所述消息到達時間為所述生產者采集到所述消息的時間，所述波動指標用于描述所述消息源的時延波動幅度，所述時延包括所述消息到達時間與所述消息產生時間的差值；根據所述波動指標更新所述文件組的狀態，并將處于可消費狀態的文件組輸出給消費者。

在本申請提供的方案中，首先將消息寫入對應的文件組中進行持久化存儲，然后根據確定的波動指標更新文件組的狀態，并將處于可消費者狀態的文件組傳送給消費者，在這個過程中，相同時間產生的來自不同消息源的消息可寫入同一個文件組中，當所述消息收集完全后(確定所述文件組處于可消費狀態)，再將所述文件組輸出給消費者，使得消費者免于等待消息緩存，降低了RAM資源和CPU計算資源的占用率，提升了響應速度。

結合第一方面，在第一方面的一種可能的實現方式中，所述根據所述消息產生時間、消息到達時間及所述消息源的標識獲得波動指標，具體包括：根據所述消息產生時間和所述消息到達時間，確定波動指標觀測值；所述波動指標觀測值為所述消息源的原始時延波動幅度；基于所述波動指標觀測值，確定濾波器增益系數；所述濾波器增益系數用于對所述波動指標觀測值進行校正；基于所述濾波器增益系數，確定所述波動指標。