[發(fā)明專利]一種不同任務(wù)拓?fù)溟g共享數(shù)據(jù)流的方法、裝置及集群

在審

• 申請(qǐng)?zhí)枺?/td>: 201410253785.3
• 申請(qǐng)日: 2014-06-09
• 公開（公告）號(hào): CN104052804A
• 公開（公告）日: 2014-09-17
• 發(fā)明（設(shè)計(jì)）人: 趙東輝;范小朋;沈慧;須成忠
• 申請(qǐng)（專利權(quán)）人: 深圳先進(jìn)技術(shù)研究院
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;G06F17/30
• 代理公司: 深圳中一專利商標(biāo)事務(wù)所 44237
• 代理人: 張全文

1.一種不同任務(wù)拓?fù)溟g共享數(shù)據(jù)流的方法，其特征在于，所述方法包括：

發(fā)布第一任務(wù)拓?fù)渲良褐校?/p>

獲取所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息；

寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中；

從關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中獲取第二任務(wù)拓?fù)湫枰嗛喌臄?shù)據(jù)流的發(fā)布信息，所述需要訂閱的數(shù)據(jù)流是所述第一任務(wù)拓?fù)渲械囊粭l數(shù)據(jù)流；

發(fā)布所述第二任務(wù)拓?fù)渲良褐?，所述第二任?wù)拓?fù)渥x取所述發(fā)布信息，并根據(jù)所述發(fā)布信息訂閱所述第一任務(wù)拓?fù)渲械南鄳?yīng)數(shù)據(jù)流。

2.如權(quán)利要求1所述的方法，其特征在于，在所述發(fā)布第二任務(wù)拓?fù)渲良褐兄?，還包括：

獲取所述第二任務(wù)拓?fù)渖傻臄?shù)據(jù)流的信息；

寫入所述第二任務(wù)拓?fù)渖傻臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中。

3.如權(quán)利要求1所述的方法，其特征在于，所述數(shù)據(jù)流的信息包括：數(shù)據(jù)流的標(biāo)識(shí)、數(shù)據(jù)流所在的任務(wù)拓?fù)湫畔?、?shù)據(jù)流所在節(jié)點(diǎn)的ip信息、數(shù)據(jù)流所在節(jié)點(diǎn)的端口信息；

所述發(fā)布信息包括：數(shù)據(jù)流所在節(jié)點(diǎn)的ip信息、數(shù)據(jù)流所在節(jié)點(diǎn)的端口信息。

4.如權(quán)利要求1所述的方法，其特征在于，所述寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中包括：

讀取包括關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)的地址信息的配置文件，得到關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)和關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)的地址信息；

ping所述關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)的地址，如果ping通過(guò)，則寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)中；

否則，ping所述關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)的地址，如果ping通過(guò)，則寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)中。

5.一種不同任務(wù)拓?fù)溟g共享數(shù)據(jù)流的裝置，其特征在于，所述裝置包括：

第一拓?fù)浒l(fā)布單元，用于發(fā)布第一任務(wù)拓?fù)渲良褐校?!-- SIPO -->

第一數(shù)據(jù)流信息獲取單元，用于獲取所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息；

第一數(shù)據(jù)流信息寫入單元，用于寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中；

發(fā)布信息獲取單元，用于從關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中獲取第二任務(wù)拓?fù)湫枰嗛喌臄?shù)據(jù)流的發(fā)布信息，所述需要訂閱的數(shù)據(jù)流是所述第一任務(wù)拓?fù)渲械囊粭l數(shù)據(jù)流；

第二拓?fù)浒l(fā)布單元，用于發(fā)布所述第二任務(wù)拓?fù)渲良褐校龅诙蝿?wù)拓?fù)渥x取所述發(fā)布信息，并根據(jù)所述發(fā)布信息訂閱所述第一任務(wù)拓?fù)渲械南鄳?yīng)數(shù)據(jù)流。

6.如權(quán)利要求5所述的裝置，其特征在于，所述裝置還包括：

第二數(shù)據(jù)流信息獲取單元，用于獲取所述第二任務(wù)拓?fù)渖傻臄?shù)據(jù)流的信息；

第二數(shù)據(jù)流信息寫入單元，用于寫入所述第二任務(wù)拓?fù)渖傻臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)中。

7.如權(quán)利要求5所述的裝置，其特征在于，所述數(shù)據(jù)流的信息包括：數(shù)據(jù)流的標(biāo)識(shí)、數(shù)據(jù)流所在的任務(wù)拓?fù)湫畔?、?shù)據(jù)流所在節(jié)點(diǎn)的ip信息、數(shù)據(jù)流所在節(jié)點(diǎn)的端口信息；

所述發(fā)布信息包括：數(shù)據(jù)流所在節(jié)點(diǎn)的ip信息、數(shù)據(jù)流所在節(jié)點(diǎn)的端口信息。

8.如權(quán)利要求5所述的裝置，其特征在于，所述第一數(shù)據(jù)流信息寫入單元包括：

主從節(jié)點(diǎn)地址讀取模塊，用于讀取包括關(guān)系型數(shù)據(jù)庫(kù)管理節(jié)點(diǎn)的地址信息的配置文件，得到關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)和關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)的地址信息；

第一ping模塊，用于ping所述關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)的地址；

第一數(shù)據(jù)流信息寫入模塊，用于如果ping通過(guò)，則寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)中；

第二ping模塊，用于如果無(wú)法ping通過(guò)，則ping所述關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)的地址；

第二數(shù)據(jù)流信息寫入模塊，用于如果ping通過(guò)，則寫入所述第一任務(wù)拓?fù)渲械臄?shù)據(jù)流的信息至關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)中。

9.一種集群，所述集群包括用于運(yùn)行任務(wù)拓?fù)涞闹辽賰膳_(tái)計(jì)算機(jī)，其特征在于，所述集群還包括：關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)和包括如權(quán)利要求5至8任一項(xiàng)所述的不同任務(wù)拓?fù)溟g共享數(shù)據(jù)流的裝置的集群服務(wù)器；

所述集群服務(wù)器連接于各個(gè)計(jì)算機(jī)和所述關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)之間。

10.如權(quán)利要求9所述的集群，其特征在于，所述集群還包括：關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)，所述關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)與所述關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)和所述集群服務(wù)器分別連接，所述關(guān)系型數(shù)據(jù)庫(kù)管理主節(jié)點(diǎn)和所述關(guān)系型數(shù)據(jù)庫(kù)管理從節(jié)點(diǎn)之間通過(guò)Push和增量更新機(jī)制來(lái)保持?jǐn)?shù)據(jù)的同步。