[發(fā)明專利]一種提供實時數(shù)據(jù)接口服務的方法、裝置、設備及介質(zhì)

有效

• 申請?zhí)枺?/td>: 202110181116.X
• 申請日: 2021-02-09
• 公開（公告）號: CN112910763B
• 公開（公告）日: 2023-03-24
• 發(fā)明（設計）人: 陳磊;周茂;羅亞飛;王大昌;朱順生;侯立冬;孟寶權(quán);傅強;蔡琳;梁彧;田野;王杰;楊滿智;金紅;陳曉光
• 申請（專利權(quán)）人: 恒安嘉新（北京）科技股份公司
• 主分類號: H04L51/066
• 分類號: H04L51/066;H04L67/565
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發(fā)明實施例公開了一種提供實時數(shù)據(jù)接口服務的方法、裝置、設備及介質(zhì)。該方法通過消息譯碼器以及消息路由器執(zhí)行，所述消息路由器包括的業(yè)務組件基于配置文件構(gòu)成消息通道，所述配置文件包括滿足業(yè)務場景要求的配置信息，所述方法包括：通過所述消息譯碼器對第一消息端點產(chǎn)生的數(shù)據(jù)進行格式調(diào)整，傳輸調(diào)整后得到的第一消息給所述消息路由器；通過所述消息路由器采用滿足設定條件的消息通道對所述第一消息進行處理得到第二消息，分發(fā)所述第二消息至第二消息端點，實現(xiàn)新增業(yè)務場景時，修改配置文件即可符合業(yè)務場景要求，從而，根據(jù)配置文件中的配置信息對消息進行定制化的處理，以滿足多樣化的業(yè)務場景的性能要求。

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

本發(fā)明實施例涉及通信技術(shù)，尤其涉及一種提供實時數(shù)據(jù)接口服務的方法、裝置、設備及介質(zhì)。

背景技術(shù)

通常情況下，實時數(shù)據(jù)接口服務需要滿足分布式、高可用、高性能和可定制的要求。

目前，常用的實時數(shù)據(jù)接口服務有Flume，它是一個高可用、高可靠、分布式的海量日志采集、聚合和傳輸系統(tǒng)，它支持定制各類數(shù)據(jù)發(fā)送方，用于收集數(shù)據(jù)；同時，提供對數(shù)據(jù)的簡單處理，并寫到各類接收方的能力。

然而，F(xiàn)lume只是一個簡單的數(shù)據(jù)通道，它專注于把數(shù)據(jù)從一側(cè)移動到另一側(cè)，并不能提供復雜路由的能力，而且出于高可靠這一特性的要求，性能并不能達到某些業(yè)務場景的處理需要。

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

本發(fā)明實施例提供一種提供實時數(shù)據(jù)接口服務的方法、裝置、設備及介質(zhì)，可以滿足多樣化的業(yè)務場景的性能要求。

第一方面，本發(fā)明實施例提供了一種提供實時數(shù)據(jù)接口服務的方法，通過消息譯碼器以及消息路由器執(zhí)行，所述消息路由器包括的業(yè)務組件基于配置文件構(gòu)成消息通道，所述配置文件包括滿足業(yè)務場景要求的配置信息，所述方法包括：

通過所述消息譯碼器對第一消息端點產(chǎn)生的數(shù)據(jù)進行格式調(diào)整，傳輸調(diào)整后得到的第一消息給所述消息路由器；

通過所述消息路由器采用滿足設定條件的消息通道對所述第一消息進行處理得到第二消息，分發(fā)所述第二消息至第二消息端點。

第二方面，本發(fā)明實施例還提供了一種提供實時數(shù)據(jù)接口服務的裝置，該裝置包括消息譯碼器以及消息路由器，所述消息路由器包括的業(yè)務組件基于配置文件構(gòu)成消息通道，所述配置文件包括滿足業(yè)務場景要求的配置信息，其中：

所述消息譯碼器，用于對第一消息端點產(chǎn)生的數(shù)據(jù)進行格式調(diào)整，傳輸調(diào)整后得到的第一消息給所述消息路由器；

所述消息路由器，用于采用滿足設定條件的消息通道對所述第一消息進行處理得到第二消息，分發(fā)所述第二消息至第二消息端點。

第三方面，本發(fā)明實施例還提供了一種計算機設備，所述計算機設備包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序；

當所述一個或多個程序被所述一個或多個處理器執(zhí)行，使得所述一個或多個處理器實現(xiàn)如本發(fā)明任意實施例所述的提供實時數(shù)據(jù)接口服務的方法。

第四方面，本發(fā)明實施例還提供了一種包含計算機可執(zhí)行指令的存儲介質(zhì)，其特征在于，所述計算機可執(zhí)行指令在由計算機處理器執(zhí)行時用于執(zhí)行如本發(fā)明任意實施例所述的提供實時數(shù)據(jù)接口服務的方法。