[發明專利]分布式監管方法和系統

有效

• 申請號: 201911037879.6
• 申請日: 2019-10-29
• 公開（公告）號: CN110781034B
• 公開（公告）日: 2022-11-29
• 發明（設計）人: 牟巍;江偉;石君明
• 申請（專利權）人: 成都中航信虹科技股份有限公司
• 主分類號: G06F11/14
• 分類號: G06F11/14;H04L41/0654;H04L47/50;H04L69/16
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 董艷芳

1.一種分布式監管方法，其特征在于，應用于分布式監管系統，所述分布式監管系統包括呼叫服務器、傳輸層服務器以及多個隊列服務器，所述方法包括：

所述呼叫服務器在接收到呼叫發起端發送的呼叫請求時，將獲得的語音信息發送至所述傳輸層服務器；

所述傳輸層服務器對所述語音信息進行解析，將解析后的語音信息發送至所述多個隊列服務器中的其中一個隊列服務器；

所述隊列服務器在接收到所述語音信息后，獲取所述語音信息攜帶的該語音信息所屬組別的組別編碼以及該語音信息的唯一標識碼，按所述組別編碼以及唯一標識碼將所述語音信息存入消息隊列中，并將所述消息隊列同步至所述多個隊列服務器中的其他隊列服務器；

所述傳輸層服務器包括TCP服務器以及UDP服務器，所述語音信息包括信令數據包和語音數據，所述傳輸層服務器對所述語音信息進行解析，將解析后的語音信息發送至所述多個隊列服務器中的其中一個隊列服務器的步驟，包括：

所述TCP服務器在接收到所述呼叫服務器發送的表征語音監管開始的信令數據包時，將該信令數據包發送至所述多個隊列服務器中的其中一個隊列服務器以觸發語音監管過程；

所述UDP服務器接收在語音監管過程中所述呼叫服務器發送的語音數據，解析所述語音數據并將解析后的語音數據發送至所述其中一個隊列服務器；

所述TCP服務器在接收到所述呼叫服務器發送的表征本次語音監管結束的信令數據包時，將該信令數據包發送至所述其中一個隊列服務器，以結束本次語音監管；

所述分布式監管系統還包括數據處理服務器，所述方法還包括：

在結束本次語音監管后，所述數據處理服務器從所述其中一個隊列服務器中讀取本次語音監管過程所存儲的多條語音信息，并獲取各所述語音信息的唯一標識碼；

按讀取到的各所述語音信息的唯一標識碼將各所述語音信息寫入文件后存儲至數據庫中，其中，各條語音信息的唯一標識碼體現出各條語音信息在時間上的流水信息。

2.根據權利要求1所述的分布式監管方法，其特征在于，所述分布式監管系統還包括監聽客戶端，所述監聽客戶端安裝有瀏覽器，所述方法還包括：

所述監聽客戶端通過安裝于所述瀏覽器中的插件向所述隊列服務器發起監聽請求；

所述隊列服務器根據所述監聽請求中攜帶的組別編碼從記錄的消息隊列中提取多條語音信息，并按提取出的各所述語音信息各自的唯一標識碼將各所述語音信息反饋至所述監聽客戶端。

3.根據權利要求2所述的分布式監管方法，其特征在于，所述分布式監管系統還包括監聽服務器，所述監聽客戶端通過安裝于所述瀏覽器中的插件向所述隊列服務器發起監聽請求的步驟，包括：

所述監聽客戶端通過安裝于所述瀏覽器中的插件將監聽請求發送至所述監聽服務器，通過所述監聽服務器向所述隊列服務器發起監聽請求。

4.根據權利要求3所述的分布式監管方法，其特征在于，所述監聽服務器包括多個，所述分布式監管系統還包括網關設備，所述監聽客戶端通過安裝于所述瀏覽器中的插件將監聽請求發送至所述監聽服務器的步驟，包括：

所述監聽客戶端通過安裝于所述瀏覽器中的插件向所述網關設備發起監聽請求；

所述網關設備在接收到所述監聽請求后，從多個所述監聽服務器中確定出當前用于處理該監聽請求的監聽服務器，并將所述監聽請求發送至該監聽服務器。

5.根據權利要求2所述的分布式監管方法，其特征在于，所述分布式監管系統還包括與所述監聽客戶端連接的音頻設備，所述方法還包括：

所述監聽客戶端將接收到的語音信息實時發送至所述音頻設備；

所述音頻設備將接收到的語音信息進行播放。

6.根據權利要求1所述的分布式監管方法，其特征在于，所述分布式監管系統還包括注冊服務器，所述方法還包括：

所述注冊服務器接收所述傳輸層服務器發送的注冊信息，對所述傳輸層服務器的注冊信息進行驗證，將驗證通過的傳輸層服務器的設備信息進行記錄；

所述注冊服務器接收各所述隊列服務器發送的注冊信息，對各所述隊列服務器的注冊信息進行驗證，將驗證通過的隊列服務器的設備信息進行記錄。

7.一種分布式監管系統，其特征在于，所述分布式監管系統包括呼叫服務器、傳輸層服務器以及多個隊列服務器；

所述呼叫服務器用于在接收到呼叫發起端發送的呼叫請求時，將獲得的語音信息發送至所述傳輸層服務器；

所述傳輸層服務器用于對所述語音信息進行解析，將解析后的語音信息發送至所述多個隊列服務器中的其中一個隊列服務器；

所述隊列服務器用于在接收到所述語音信息后，獲取所述語音信息攜帶的該語音信息所屬組別的組別編碼以及該語音信息的唯一標識碼，按所述組別編碼以及唯一標識碼將所述語音信息存入消息隊列中，并將所述消息隊列同步至所述多個隊列服務器中的其他隊列服務器；

其中，所述傳輸層服務器包括TCP服務器以及UDP服務器，所述語音信息包括信令數據包和語音數據，所述TCP服務器用于在接收到所述呼叫服務器發送的表征語音監管開始的信令數據包時，將該信令數據包發送至所述多個隊列服務器中的其中一個隊列服務器以觸發語音監管過程；

所述UDP服務器用于接收在語音監管過程中所述呼叫服務器發送的語音數據，解析所述語音數據并將解析后的語音數據發送至所述其中一個隊列服務器；

所述TCP服務器還用于在接收到所述呼叫服務器發送的表征本次語音監管結束的信令數據包時，將該信令數據包發送至所述其中一個隊列服務器，以結束本次語音監管；

所述分布式監管系統還包括數據處理服務器，所述數據處理服務器用于在結束本次語音監管后，從所述其中一個隊列服務器中讀取本次語音監管過程所存儲的多條語音信息，并獲取各所述語音信息的唯一標識碼；

按讀取到的各所述語音信息的唯一標識碼將各所述語音信息寫入文件后存儲至數據庫中，其中，各條語音信息的唯一標識碼體現出各條語音信息在時間上的流水信息。