[發(fā)明專利]一種數(shù)據(jù)推送的方法、裝置、終端及存儲(chǔ)介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110587408.3
• 申請日: 2021-05-27
• 公開（公告）號(hào): CN113448725A
• 公開（公告）日: 2021-09-28
• 發(fā)明（設(shè)計(jì)）人: 曾堅(jiān);吳閩華;姜坤;衛(wèi)宣安
• 申請（專利權(quán)）人: 深圳震有科技股份有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F9/54
• 代理公司: 深圳市君勝知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44268
• 代理人: 謝松

本發(fā)明公開一種數(shù)據(jù)推送的方法、裝置、終端及存儲(chǔ)介質(zhì)，其中，一種數(shù)據(jù)推送的方法，包括：結(jié)點(diǎn)接收當(dāng)前數(shù)據(jù)并獲取對(duì)應(yīng)所述當(dāng)前數(shù)據(jù)的數(shù)據(jù)來源終端的識(shí)別信息；所述結(jié)點(diǎn)將所述當(dāng)前數(shù)據(jù)放置到對(duì)應(yīng)所述識(shí)別信息的推送列隊(duì)中；推送列隊(duì)將所述當(dāng)前數(shù)據(jù)進(jìn)行推送。通過將當(dāng)前數(shù)據(jù)基于數(shù)據(jù)來源終端進(jìn)行分類以便將同一個(gè)數(shù)據(jù)來源終端的數(shù)據(jù)分配給同一個(gè)推送列進(jìn)行處理，避免數(shù)據(jù)推送亂序。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)推送的方法、裝置、終端及存儲(chǔ)介質(zhì)。

背景技術(shù)

在大數(shù)據(jù)的時(shí)代背景下，隨著城市的飛速發(fā)展，各種數(shù)據(jù)信息層出不窮，在這個(gè)信息爆炸的時(shí)代里，用戶如何能夠快速明了地獲得自己所關(guān)注的各方面的數(shù)據(jù)信息顯得越來越重要。

例如在集群業(yè)務(wù)推送場景中，用戶數(shù)據(jù)來源終端設(shè)備會(huì)定時(shí)向我們的GCS服務(wù)器(GPSCollectingSystem)上報(bào)數(shù)據(jù)信息，然后服務(wù)器會(huì)向監(jiān)控訂閱方推送該些數(shù)據(jù)信息。但是在現(xiàn)有技術(shù)中，由于服務(wù)器屬于集群式服務(wù)，服務(wù)器的數(shù)據(jù)推送處理一般是選擇一個(gè)空閑的二級(jí)推送列隊(duì)將數(shù)據(jù)推送到訂閱方。因此同一個(gè)數(shù)據(jù)來源終端先后上報(bào)的數(shù)據(jù)信息可能會(huì)被不同的推送列隊(duì)處理，導(dǎo)致之前先上報(bào)的數(shù)據(jù)還在排隊(duì)等待處理，后上傳的數(shù)據(jù)以及被推送到訂閱方，造成數(shù)據(jù)推送亂序。

因此，現(xiàn)有技術(shù)還有待提升。

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

為了解決現(xiàn)有技術(shù)中同一個(gè)數(shù)據(jù)來源終端先后上報(bào)的數(shù)據(jù)信息可能會(huì)被不同的推送列隊(duì)處理造成數(shù)據(jù)推送亂序的問題，本發(fā)明提出一種數(shù)據(jù)推送的方法、裝置、終端及存儲(chǔ)介質(zhì)，將數(shù)據(jù)進(jìn)行分類以便將同一個(gè)數(shù)據(jù)來源終端的數(shù)據(jù)分配給同一個(gè)推送列進(jìn)行處理，避免數(shù)據(jù)推送亂序。

本發(fā)明通過以下技術(shù)方案實(shí)現(xiàn)的：

第一方面，本發(fā)明提出一種數(shù)據(jù)推送的方法，包括：

結(jié)點(diǎn)接收當(dāng)前數(shù)據(jù)并獲取對(duì)應(yīng)所述當(dāng)前數(shù)據(jù)的數(shù)據(jù)來源終端的識(shí)別信息；

所述結(jié)點(diǎn)將所述當(dāng)前數(shù)據(jù)放置到對(duì)應(yīng)所述識(shí)別信息的推送列隊(duì)中；

推送列隊(duì)將所述當(dāng)前數(shù)據(jù)進(jìn)行推送。

通過接收所述當(dāng)前數(shù)據(jù)并獲取對(duì)應(yīng)的所述當(dāng)前數(shù)據(jù)的數(shù)據(jù)來源終端的識(shí)別信息，確定數(shù)據(jù)的來源終端設(shè)備，然后將所述當(dāng)前數(shù)據(jù)放入到對(duì)應(yīng)所述識(shí)別信息(數(shù)據(jù)來源終端)的推送列隊(duì)中，也就是保證將來自同一個(gè)數(shù)據(jù)來源終端的數(shù)據(jù)都在一個(gè)推送列隊(duì)中被處理，避免了推送亂序，同時(shí)避免數(shù)據(jù)分配時(shí)選擇空閑的推送列隊(duì)進(jìn)行分配造成有的推送列隊(duì)數(shù)據(jù)擠壓有的推送列隊(duì)空閑且所有的數(shù)據(jù)推送太過雜亂沒有條理、推送列隊(duì)工作不合理的缺陷，保證了數(shù)據(jù)分配的條理性以及推送列隊(duì)處理的合理性同時(shí)保證工作效率。

在本發(fā)明的其中一種實(shí)施方案中，所述結(jié)點(diǎn)將所述當(dāng)前數(shù)據(jù)放置到對(duì)應(yīng)所述識(shí)別信息的推送列隊(duì)中包括：

對(duì)所述識(shí)別信息進(jìn)行哈希計(jì)算并取整數(shù)的哈希值；

計(jì)算所述哈希值與推送列隊(duì)總數(shù)的商得余數(shù)；

將所述當(dāng)前數(shù)據(jù)放置到對(duì)應(yīng)所述余數(shù)的推送列隊(duì)。

通過求取所述識(shí)別信息的哈希值，并且所述哈希值為整數(shù)，便于計(jì)算所述所述哈希值與所述推送列隊(duì)總數(shù)的商的余數(shù)，且通過計(jì)算所述哈希值與推送列隊(duì)總數(shù)的商得余數(shù)后根據(jù)余數(shù)將所述數(shù)據(jù)放置到對(duì)應(yīng)余數(shù)推送列隊(duì)，由于不同的數(shù)據(jù)來源終端的識(shí)別信息是不一樣的，所以對(duì)應(yīng)所述數(shù)據(jù)來源終端的哈希值也是唯一的，通過使用所述推送列隊(duì)總數(shù)為除數(shù)，然后基于余數(shù)推薦保證了所有的推送列隊(duì)都能被分配到來自不同的數(shù)據(jù)來源終端的待推送的數(shù)據(jù)，避免推送列隊(duì)空閑浪費(fèi)或待推送的數(shù)據(jù)積壓，進(jìn)一步保證了數(shù)據(jù)分配的條理性以及推送列隊(duì)處理的合理性同時(shí)保證工作效率以及數(shù)據(jù)推送的有序性。

在本發(fā)明的其中一種實(shí)施方案中，所述將所述當(dāng)前數(shù)據(jù)放置到對(duì)應(yīng)所述余數(shù)的推送列隊(duì)包括：

獲取對(duì)應(yīng)所述結(jié)點(diǎn)的推送列隊(duì)的列隊(duì)編號(hào)；