[發(fā)明專利]基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201711435819.0
• 申請(qǐng)日: 2017-12-26
• 公開(kāi)（公告）號(hào): CN108021701B
• 公開(kāi)（公告）日: 2021-08-10
• 發(fā)明（設(shè)計(jì)）人: 湯奇峰;謝磊
• 申請(qǐng)（專利權(quán)）人: 上海數(shù)據(jù)交易中心有限公司
• 主分類號(hào): G06F16/2458
• 分類號(hào): G06F16/2458;G06F16/2455;G06F16/2453
• 代理公司: 上海翰信知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 31270
• 代理人: 張維東

本發(fā)明提供了一種基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法及系統(tǒng)，該方法為：多個(gè)數(shù)據(jù)供給方為數(shù)據(jù)需求方供給數(shù)據(jù)，所述數(shù)據(jù)需求方請(qǐng)求數(shù)據(jù)時(shí)，根據(jù)該次請(qǐng)求的數(shù)據(jù)量結(jié)合數(shù)據(jù)需求方和數(shù)據(jù)供給方的并發(fā)能力采用數(shù)據(jù)聚合的方式選擇為該次請(qǐng)求提供數(shù)據(jù)的數(shù)據(jù)供給方，并向?yàn)樵摯握?qǐng)求提供數(shù)據(jù)的數(shù)據(jù)供給方發(fā)起請(qǐng)求，本發(fā)明的方法能夠根據(jù)業(yè)務(wù)需求實(shí)時(shí)選擇不同的數(shù)據(jù)供給方配送數(shù)據(jù)，數(shù)據(jù)配送可靠性高，且數(shù)據(jù)配送并發(fā)能力強(qiáng)。

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

本發(fā)明屬于數(shù)據(jù)流通技術(shù)領(lǐng)域，具體涉及一種基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法及系統(tǒng)。

背景技術(shù)

在現(xiàn)有的數(shù)據(jù)流通方法中，往往是單個(gè)的數(shù)據(jù)供給方對(duì)應(yīng)單個(gè)數(shù)據(jù)需求方，然而在數(shù)據(jù)供給方和數(shù)據(jù)需求方的并發(fā)能力不同的情況下，系統(tǒng)需要滿足高并發(fā)、低延時(shí)并且能充分利用數(shù)據(jù)供給方能力的的要求便成了一個(gè)問(wèn)題。在普通的單點(diǎn)對(duì)單點(diǎn)的數(shù)據(jù)配送系統(tǒng)中，數(shù)據(jù)供給方和數(shù)據(jù)需求方的并發(fā)能力不同的情況下(數(shù)據(jù)需求方對(duì)數(shù)據(jù)的并發(fā)要求往往高于數(shù)據(jù)供給方)，存在以下問(wèn)題：

1、由于數(shù)據(jù)供給方和數(shù)據(jù)需求方的并發(fā)能力不同，導(dǎo)致并發(fā)能力高的一方(數(shù)據(jù)需求方)的實(shí)際數(shù)據(jù)并發(fā)配送能力受限于數(shù)據(jù)供給方。

2、普通的數(shù)據(jù)配送系統(tǒng)的并發(fā)能力很難實(shí)現(xiàn)隨著業(yè)務(wù)發(fā)展而擴(kuò)展。

3、由于供方為單點(diǎn)，即僅由一個(gè)確定的數(shù)據(jù)供給方為數(shù)據(jù)需求方提供數(shù)據(jù)，而一旦該數(shù)據(jù)供給方不可用，則會(huì)直接導(dǎo)致數(shù)據(jù)配送無(wú)法進(jìn)行。

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

本發(fā)明是為了解決上述問(wèn)題而進(jìn)行的，目的在于提供一種能夠根據(jù)業(yè)務(wù)需求實(shí)時(shí)選擇不同的數(shù)據(jù)供給方配送數(shù)據(jù)，數(shù)據(jù)配送可靠性高，且能夠提高數(shù)據(jù)配送的并發(fā)能力的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法及系統(tǒng)。

本發(fā)明提供了一種基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法，其特征在于：多個(gè)數(shù)據(jù)供給方為數(shù)據(jù)需求方供給數(shù)據(jù)，所述數(shù)據(jù)需求方請(qǐng)求數(shù)據(jù)時(shí)，根據(jù)該次請(qǐng)求的數(shù)據(jù)量結(jié)合數(shù)據(jù)需求方和數(shù)據(jù)供給方的并發(fā)能力采用數(shù)據(jù)聚合的方式選擇為該次請(qǐng)求提供數(shù)據(jù)的數(shù)據(jù)供給方，并向?yàn)樵摯握?qǐng)求提供數(shù)據(jù)的數(shù)據(jù)供給方發(fā)起請(qǐng)求。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，所述數(shù)據(jù)需求方請(qǐng)求數(shù)據(jù)時(shí)，首先查詢數(shù)據(jù)緩存模塊中是否存儲(chǔ)有請(qǐng)求需要的數(shù)據(jù)，若有，則從所述數(shù)據(jù)緩存模塊中獲取數(shù)據(jù)，若否，則通過(guò)數(shù)據(jù)聚合的方式從數(shù)據(jù)供給方獲得數(shù)據(jù)，并將從數(shù)據(jù)供給方請(qǐng)求的數(shù)據(jù)緩存到所述數(shù)據(jù)緩存模塊中。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，所述數(shù)據(jù)緩存模塊存儲(chǔ)數(shù)據(jù)時(shí)采用分布式緩存。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，對(duì)所述數(shù)據(jù)緩存模塊緩存的數(shù)據(jù)設(shè)置存儲(chǔ)時(shí)間，并對(duì)到達(dá)所述存儲(chǔ)時(shí)間的緩存的數(shù)據(jù)進(jìn)行刪除。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，對(duì)數(shù)據(jù)進(jìn)行緩存時(shí)，對(duì)源數(shù)據(jù)的value值進(jìn)行編碼處理后存入所述數(shù)據(jù)緩存模塊。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，所述數(shù)據(jù)需求方向所述數(shù)據(jù)供給方請(qǐng)求數(shù)據(jù)前，通過(guò)心跳包的方式確定當(dāng)前可用的數(shù)據(jù)供給方。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，所述數(shù)據(jù)聚合的方式包括低價(jià)優(yōu)先策略、質(zhì)高優(yōu)先策略、輪詢策略、以及隨機(jī)選擇策略。

進(jìn)一步，在本發(fā)明提供的基于數(shù)據(jù)并發(fā)能力的數(shù)據(jù)流通方法中，還可以具有這樣的特征：其中，在確定數(shù)據(jù)聚合方式時(shí)，通過(guò)網(wǎng)頁(yè)的形式為數(shù)據(jù)需求方提供選擇數(shù)據(jù)聚合方式的接口，設(shè)定預(yù)定時(shí)間，定時(shí)拉取數(shù)據(jù)需求方選擇的數(shù)據(jù)聚合方式，在所述預(yù)定時(shí)間內(nèi)，數(shù)據(jù)需求方向所述數(shù)據(jù)供給方請(qǐng)求數(shù)據(jù)時(shí)，均按照該次選擇的數(shù)據(jù)聚合方式進(jìn)行數(shù)據(jù)配送。