[發(fā)明專利]跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

有效

• 申請?zhí)枺?/td>: 201810145694.6
• 申請日: 2018-02-12
• 公開（公告）號(hào): CN108418874B
• 公開（公告）日: 2021-01-26
• 發(fā)明（設(shè)計(jì)）人: 林林
• 申請（專利權(quán)）人: 平安科技（深圳）有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 深圳市精英專利事務(wù)所 44242
• 代理人: 林燕云

1.一種跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法，其特征在于，包括：

在Hadoop服務(wù)器所調(diào)用的java封裝類中增加管道類，并在管道類中構(gòu)建用于傳入Redis集群對象和密碼的函數(shù)；

管道類同步讀取Hadoop服務(wù)器中的待回導(dǎo)數(shù)據(jù)，得到Redis集群信息；

通過池對象獲取當(dāng)前的Redis集群信息；

若當(dāng)前的Redis集群信息與前一時(shí)刻Redis集群信息不相同，根據(jù)當(dāng)前的Redis集群信息將管道類存儲(chǔ)的待回導(dǎo)數(shù)據(jù)提交至Redis數(shù)據(jù)庫服務(wù)器；

其中，JedisPool對象檢測到Redis集群的實(shí)例列表中有數(shù)據(jù)發(fā)生變更，或是超時(shí)時(shí)間、密碼發(fā)生改變，判定當(dāng)前的Redis集群信息與前一時(shí)刻Redis集群信息不相同；

所述管道類同步讀取Hadoop服務(wù)器中的待回導(dǎo)數(shù)據(jù)，得到Redis集群信息，包括：

對Redis集群對象進(jìn)行實(shí)例化得到實(shí)例化Redis集群對象，并將實(shí)例化Redis集群對象存儲(chǔ)至Redis集群對象的實(shí)例列表；

若檢測到數(shù)據(jù)回導(dǎo)指令，將待回導(dǎo)數(shù)據(jù)通過set操作同步緩存至實(shí)例化Redis集群對象，得到Redis集群信息；

其中，所述函數(shù)中的nodeList用于寫入實(shí)例化Redis集群對象。

2.根據(jù)權(quán)利要求1所述的跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法，其特征在于，所述在Hadoop服務(wù)器所調(diào)用的java封裝類中增加管道類，并在管道類中構(gòu)建用于傳入Redis集群對象和密碼的函數(shù)，包括：

在Hadoop服務(wù)器所調(diào)用的java封裝類中增加JedisClusterPipeline類；

在JedisClusterPipeline類中構(gòu)造至少包括獲取Redis集群對象的實(shí)例列表、超時(shí)時(shí)間、密碼的函數(shù)。

3.根據(jù)權(quán)利要求1所述的跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法，其特征在于，所述通過池對象獲取當(dāng)前的Redis集群信息中，根據(jù)JedisPool對象從pool緩存中獲取當(dāng)前的Redis集群信息。

4.根據(jù)權(quán)利要求3所述的跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法，其特征在于，所述根據(jù)當(dāng)前的Redis集群信息將管道類存儲(chǔ)的待回導(dǎo)數(shù)據(jù)提交至Redis數(shù)據(jù)庫服務(wù)器，包括：

將Redis集群信息更新為當(dāng)前的Redis集群信息；

通過put操作將pool緩存中當(dāng)前的Redis集群信息按預(yù)設(shè)的指定數(shù)據(jù)量提交至Redis數(shù)據(jù)庫服務(wù)器。

5.根據(jù)權(quán)利要求4所述的跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)方法，其特征在于，所述通過put操作將pool緩存中當(dāng)前的Redis集群信息按預(yù)設(shè)的指定數(shù)據(jù)量提交至Redis數(shù)據(jù)庫服務(wù)器，包括：

將當(dāng)前的Redis集群信息進(jìn)行序列化，得到序列化對象；

將指定數(shù)據(jù)量的序列化對象存儲(chǔ)至byte[]數(shù)組；

將byte[]數(shù)組緩存至Redis數(shù)據(jù)庫服務(wù)器。

6.一種跨廣域網(wǎng)數(shù)據(jù)回導(dǎo)裝置，其特征在于，包括：

管道類搭建單元，用于在Hadoop服務(wù)器所調(diào)用的java封裝類中增加管道類，并在管道類中構(gòu)建用于傳入Redis集群對象和密碼的函數(shù)；

數(shù)據(jù)讀取單元，用于管道類同步讀取Hadoop服務(wù)器中的待回導(dǎo)數(shù)據(jù)，得到Redis集群信息；

集群信息獲取單元，用于通過池對象獲取當(dāng)前的Redis集群信息；

數(shù)據(jù)回導(dǎo)單元，用于若當(dāng)前的Redis集群信息與前一時(shí)刻Redis集群信息不相同，根據(jù)當(dāng)前的Redis集群信息將管道類存儲(chǔ)的待回導(dǎo)數(shù)據(jù)提交至Redis數(shù)據(jù)庫服務(wù)器；

其中，JedisPool對象檢測到Redis集群的實(shí)例列表中有數(shù)據(jù)發(fā)生變更，或是超時(shí)時(shí)間、密碼發(fā)生改變，判定當(dāng)前的Redis集群信息與前一時(shí)刻Redis集群信息不相同；

所述數(shù)據(jù)讀取單元包括：

實(shí)例化單元，用于對Redis集群對象進(jìn)行實(shí)例化得到實(shí)例化Redis集群對象，并將實(shí)例化Redis集群對象存儲(chǔ)至Redis集群對象的實(shí)例列表；

同步緩存單元，用于若檢測到數(shù)據(jù)回導(dǎo)指令，將待回導(dǎo)數(shù)據(jù)通過set操作同步緩存至實(shí)例化Redis集群對象，得到Redis集群信息；

其中，所述函數(shù)中的nodeList用于寫入實(shí)例化Redis集群對象。