[發明專利]一種短消息重試處理方法及裝置、系統

有效

• 申請號: 201610474139.9
• 申請日: 2016-06-24
• 公開（公告）號: CN107548039B
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 林學任;張斌
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: H04W4/14
• 分類號: H04W4/14;H04L29/08
• 代理公司: 深圳鼎合誠知識產權代理有限公司 44281
• 代理人: 江婷;李發兵

本發明實施例提供了一種短消息重試處理方法及其裝置、系統，通過對各定時數據按照過期時間順序進行切片處理，生成定時數據分片，并對各分片進行存儲，存儲的每個分片對應一個鍵?值數據對，根據當前掃描時間確定對應的分片，查找該分片中對應的定時數據，如果當前掃描時間中存在定時數據，則將該定時數據從該分片中刪除，并執行定時數據的重試，同時按照預設規則更新當前掃描時間，直至執行完所有分片中的定時數據的重試；通過定時數據對短消息控制，避免了在對數據掃描時出現數據丟失，同時也保證了對短消息重試處理的正常執行，通過分片的掃描提高系統對短消息重試處理的處理效率。

技術領域

本發明涉及計算機技術領域，尤其涉及一種算消息重試處理方法及裝置、系統。

背景技術

隨著通信領域云化NFV(Network Function Virtualization，網絡功能虛擬化)平臺架構的建設，短信控制中心也在往適應NFV平臺架構的方向進行改造，在網絡功能虛擬化技術中，要求業務節點可以進行動態的伸縮，這對傳統的短消息控制中心的適應改造就會比較難。短消息的定時重試功能是短消息控制中心的一項基本功能，然而傳統的短息控制中心要在NFV架構下實現業務節點的動態伸縮的過程中，必須要保證新消息的正常重試，以及舊消息的定時重試信息不會丟失。為了滿足上述的需求，短消息控制中心引入了分布式存儲系統，所有業務節點的重試信息都存儲于該分布式存儲系統中，但是，分布式存儲系統對于短消息重試的實現方式與存儲于設備內存上的不相同，使得在業務節點伸縮時會出現數據丟失，重試功能執行不正常的現象。

發明內容

本發明實施例提供了一種短消息重試處理方法及裝置，以解決現有技術中短消息控制中心在控制短消息進行定時重試過程中，可能會出現短消息的數據丟失，導致短消息無法實現重試處理的技術問題。

為解決上述技術問題，本發明實施例提供一種短消息重試處理方法，包括：

對定時數據進行存儲處理：對各定時數據按照其過期時間順序進行切片處理，生成定時數據分片，存儲各分片；每個分片對應一個鍵-值數據對，其中鍵包括分片的開始時間，值包括在預設時長范圍內的所有定時數據；

對分片進行掃描處理：根據當前掃描時間確定對應的分片，查找所述分片中對應的定時數據；將所述定時數據從所述分片中刪除，并執行所述定時數據的重試；按照預設規則更新當前掃描時間，直至執行完所有分片中的定時數據的重試。

一方面，本發明實施例還提供一種短消息重試處理裝置，包括：切片模塊、存儲模塊和定時處理模塊；

所述切片模塊用于對各定時數據按照其過期時間順序進行切片處理，生成定時數據分片，每個分片對應一個鍵-值數據對，其中鍵包括分片的開始時間，值包括在預設時長范圍內的所有定時數據；

所述存儲模塊用于存儲所述切片模塊進行切片處理得到的分片；

所述定時處理模塊用于根據當前掃描時間確定對應的分片，查找所述分片中對應的定時數據，將所述定時數據從所述分片中刪除，并執行所述定時數據的重試，按照預設規則更新當前掃描時間，直至執行完所有分片中的定時數據的重試。

另一方面，本發明實施例還提供一種短消息重試處理系統，包括：業務處理子系統和儲存子系統；

所述業務處理子系統，用于對各定時數據按照其過期時間順序進行切片處理，生成定時數據分片，并將各定時數據分片存儲到所述存儲子系統中；

所述業務處理子系統，還用于根據當前掃描時間查詢并確定所述存儲子系統中對應的分片，并查找所述分片中對應的定時數據；將分片中對應定時數據從所述存儲子系統中刪除，并執行所述定時數據的重試；按照預設規則更新當前掃描時間，直至執行完所有分片中的定時數據的重試；

所述每個分片對應一個鍵-值數據對，其中鍵包括分片的開始時間，值包括在預設時長范圍內的所有定時數據。