[發明專利]基于業務的數據處理系統、方法、裝置和服務器

在審

• 申請號: 201710385344.2
• 申請日: 2017-05-26
• 公開（公告）號: CN107249019A
• 公開（公告）日: 2017-10-13
• 發明（設計）人: 李春雨;郭煌建;厲孫德
• 申請（專利權）人: 北京小米移動軟件有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/863
• 代理公司: 北京同立鈞成知識產權代理有限公司11205
• 代理人: 宋揚,劉芳

技術領域

本公開涉及數據傳輸技術領域，尤其涉及基于業務的數據處理系統、方法、裝置和服務器。

背景技術

隨著終端技術的發展，終端通過服務器可以為用戶提供了非常多的業務功能和業務應用。現在，用戶在使用終端的時候，與該終端連接的平臺服務器可以從多個業務方服務器中獲取服務，然后平臺服務器將各服務發送給終端，以提供給用戶。例如，平臺服務器需要有A、B、C三種業務服務需要接入，業務方服務器A、業務方服務器B、業務方服務器C可以分別把數據發送給平臺服務器。

相關技術中，在平臺服務器一側，需對針對每接入一個業務方服務器，就需要針對這個業務方服務器開發出相應的接口。這是因為不同的業務方服務器所提供的數據的格式不同，平臺服務器需要采用與業務方服務器對應的接口，去接收業務方服務器發送的數據；同時，也使得業務方服務器通過與業務方服務器對應的接口去訪問平臺服務器。

然而相關技術中，由于不同的業務方服務器所提供的數據的格式不同，從而在平臺服務器一側，針對每接入一個業務方服務器，就需要針對這個業務方服務器開發出相應的接口。進而隨著平臺服務器需要接入的業務服務的增多，需要開發的接口的個數也增多，進而增加了平臺服務器向終端提供服務的成本，并且平臺服務器的復雜性也增加；并且，只有平臺服務器先準備好對應的接口，業務方服務器才能向平臺服務器發送數據或進行訪問等，一旦接口出錯，則相應的業務服務和訪問就不能正常進行。

發明內容

為克服相關技術中存在的增加了平臺服務器向終端提供服務的成本，并且平臺服務器的復雜性也增加的問題，本公開提供一種基于業務的數據處理系統、方法、裝置和服務器。

根據本公開實施例的第一方面，提供一種基于業務的數據處理系統，包括：

至少一個業務方服務器、以及平臺服務器；

各所述業務方服務器與所述平臺服務器連接；

每一個業務方服務器，對待發送的數據流進行格式轉換，生成日志數據，其中，所述日志數據的格式符合平臺服務器的要求，并將所述日志數據發送給所述平臺服務器，以使所述平臺服務器對所述日志數據進行處理。

進一步地，所述系統，還包括：日志服務器集群；

各所述業務方服務器與所述日志服務器集群連接，所述日志服務器集群與所述平臺服務器連接；

各所述業務方服務器，對待發送的數據流進行格式轉換，生成日志數據，并將所述日志數據發送給所述日志服務器集群；

所述日志服務器集群，對所述日志數據進行預設時間的存儲之后，按照預設規則將所述日志數據通過傳輸接口發送給所述平臺服務器。

進一步地，所述系統，還包括：緩沖隊列服務器；

所述緩沖隊列服務器連接在所述日志服務器集群與所述平臺服務器之間；

所述日志服務器集群，對所述日志數據進行預設時間的存儲之后，按照預設規則將所述日志數據發送給所述緩沖隊列服務器；

所述緩沖隊列服務器，將所述日志數據放入日志緩存隊列中進行緩存，以使所述平臺服務器從所述日志緩存隊列中讀取所述日志數據。

進一步地，所述緩沖隊列服務器為kafka集群，或者，所述緩沖隊列服務器為基于RabbitMQ的服務器。

本公開的實施例提供的技術方案可以包括以下有益效果：通過提供由至少一個業務方服務器、以及平臺服務器構成的基于業務的數據處理系統，各業務方服務器與平臺服務器連接；每一個業務方服務器對待發送的數據流進行格式轉換，生成日志數據，其中，日志數據的格式符合平臺服務器的要求，并將日志數據發送給平臺服務器，以使平臺服務器對日志數據進行處理。由于不同的業務方服務器所提供的數據的格式不同，不符合平臺服務器的要求，各業務方服務器在發送數據流之前將數據流的格式進行轉換，生成格式符合平臺服務器要求的日志數據；從而不再需要平臺服務器針對每接入一個業務方服務器，設置針對這個業務方服務器的接口；進而降低平臺服務器向終端提供服務的成本，并且降低平臺服務器的復雜性；并且，不再需要平臺服務器先準備好對應的接口，業務方服務器可以將格式符合平臺服務器要求的日志數據發送給平臺服務器，可以保證業務服務和訪問的正常進行。

根據本公開實施例的第二方面，提供一種基于業務的數據處理方法，包括：

對待發送的數據流進行格式轉換，生成日志數據，其中，所述日志數據的格式符合平臺服務器的要求；

將所述日志數據發送給所述平臺服務器，以使所述平臺服務器對所述日志數據進行處理。