[發(fā)明專利]基于業(yè)務(wù)的數(shù)據(jù)處理系統(tǒng)、方法、裝置和服務(wù)器

在審

• 申請?zhí)枺?/td>: 201710385344.2
• 申請日: 2017-05-26
• 公開（公告）號: CN107249019A
• 公開（公告）日: 2017-10-13
• 發(fā)明（設(shè)計(jì)）人: 李春雨;郭煌建;厲孫德
• 申請（專利權(quán)）人: 北京小米移動軟件有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/863
• 代理公司: 北京同立鈞成知識產(chǎn)權(quán)代理有限公司11205
• 代理人: 宋揚(yáng),劉芳

1.一種基于業(yè)務(wù)的數(shù)據(jù)處理系統(tǒng)，其特征在于，包括：

至少一個(gè)業(yè)務(wù)方服務(wù)器、以及平臺服務(wù)器；

各所述業(yè)務(wù)方服務(wù)器與所述平臺服務(wù)器連接；

每一個(gè)業(yè)務(wù)方服務(wù)器，對待發(fā)送的數(shù)據(jù)流進(jìn)行格式轉(zhuǎn)換，生成日志數(shù)據(jù)，其中，所述日志數(shù)據(jù)的格式符合平臺服務(wù)器的要求，并將所述日志數(shù)據(jù)發(fā)送給所述平臺服務(wù)器，以使所述平臺服務(wù)器對所述日志數(shù)據(jù)進(jìn)行處理。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述系統(tǒng)，還包括：日志服務(wù)器集群；

各所述業(yè)務(wù)方服務(wù)器與所述日志服務(wù)器集群連接，所述日志服務(wù)器集群與所述平臺服務(wù)器連接；

各所述業(yè)務(wù)方服務(wù)器，對待發(fā)送的數(shù)據(jù)流進(jìn)行格式轉(zhuǎn)換，生成日志數(shù)據(jù)，并將所述日志數(shù)據(jù)發(fā)送給所述日志服務(wù)器集群；

所述日志服務(wù)器集群，對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后，按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)通過傳輸接口發(fā)送給所述平臺服務(wù)器。

3.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述系統(tǒng)，還包括：緩沖隊(duì)列服務(wù)器；

所述緩沖隊(duì)列服務(wù)器連接在所述日志服務(wù)器集群與所述平臺服務(wù)器之間；

所述日志服務(wù)器集群，對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后，按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)發(fā)送給所述緩沖隊(duì)列服務(wù)器；

所述緩沖隊(duì)列服務(wù)器，將所述日志數(shù)據(jù)放入日志緩存隊(duì)列中進(jìn)行緩存，以使所述平臺服務(wù)器從所述日志緩存隊(duì)列中讀取所述日志數(shù)據(jù)。

4.根據(jù)權(quán)利要求3所述的系統(tǒng)，其特征在于，所述緩沖隊(duì)列服務(wù)器為kafka集群，或者，所述緩沖隊(duì)列服務(wù)器為基于RabbitMQ的服務(wù)器。

5.一種基于業(yè)務(wù)的數(shù)據(jù)處理方法，其特征在于，包括：

對待發(fā)送的數(shù)據(jù)流進(jìn)行格式轉(zhuǎn)換，生成日志數(shù)據(jù)，其中，所述日志數(shù)據(jù)的格式符合平臺服務(wù)器的要求；

將所述日志數(shù)據(jù)發(fā)送給所述平臺服務(wù)器，以使所述平臺服務(wù)器對所述日志數(shù)據(jù)進(jìn)行處理。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述將所述日志數(shù)據(jù)發(fā)送給所述平臺服務(wù)器，以使所述平臺服務(wù)器對所述日志數(shù)據(jù)進(jìn)行處理，包括：

將所述日志數(shù)據(jù)，發(fā)送給日志服務(wù)器集群，其中，所述日志服務(wù)器集群中提供了與平臺服務(wù)器連接的傳輸接口，以使所述日志服務(wù)器集群對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后，按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)通過所述傳輸接口發(fā)送給所述平臺服務(wù)器。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述將所述日志數(shù)據(jù)，發(fā)送給日志服務(wù)器集群，以使所述日志服務(wù)器集群對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間內(nèi)的存儲之后，按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)通過所述傳輸接口發(fā)送給所述平臺服務(wù)器，包括：

將所述日志數(shù)據(jù)，發(fā)送給所述日志服務(wù)器集群，以使所述日志服務(wù)器集群對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)發(fā)送給所述緩沖隊(duì)列服務(wù)器，以使所述緩沖隊(duì)列服務(wù)器將所述日志數(shù)據(jù)放入日志緩存隊(duì)列中進(jìn)行緩存之后，以便所述平臺服務(wù)器從所述日志緩存隊(duì)列中讀取所述日志數(shù)據(jù)。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，所述緩沖隊(duì)列服務(wù)器為kafka集群，或者，所述緩沖隊(duì)列服務(wù)器為基于RabbitMQ的服務(wù)器。

9.一種基于業(yè)務(wù)的數(shù)據(jù)處理裝置，其特征在于，包括：

轉(zhuǎn)換模塊，被配置為對待發(fā)送的數(shù)據(jù)流進(jìn)行格式轉(zhuǎn)換，生成日志數(shù)據(jù)，其中，所述日志數(shù)據(jù)的格式符合平臺服務(wù)器的要求；

發(fā)送模塊，被配置為將所述日志數(shù)據(jù)發(fā)送給所述平臺服務(wù)器，以使所述平臺服務(wù)器對所述日志數(shù)據(jù)進(jìn)行處理。

10.根據(jù)權(quán)利要求9所述的裝置，其特征在于，所述發(fā)送模塊，被具體配置為：

將所述日志數(shù)據(jù)，發(fā)送給日志服務(wù)器集群，其中，所述日志服務(wù)器集群中提供了與平臺服務(wù)器連接的傳輸接口，以使所述日志服務(wù)器集群對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后，按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)通過所述傳輸接口發(fā)送給所述平臺服務(wù)器。

11.根據(jù)權(quán)利要求10所述的裝置，其特征在于，所述發(fā)送模塊，被具體配置為：

將所述日志數(shù)據(jù)，發(fā)送給所述日志服務(wù)器集群，以使所述日志服務(wù)器集群對所述日志數(shù)據(jù)進(jìn)行預(yù)設(shè)時(shí)間的存儲之后按照預(yù)設(shè)規(guī)則將所述日志數(shù)據(jù)發(fā)送給所述緩沖隊(duì)列服務(wù)器，以使所述緩沖隊(duì)列服務(wù)器將所述日志數(shù)據(jù)放入日志緩存隊(duì)列中進(jìn)行緩存之后，以便所述平臺服務(wù)器從所述日志緩存隊(duì)列中讀取所述日志數(shù)據(jù)。