[發明專利]消息處理方法及裝置

有效

• 申請號: 201811524910.4
• 申請日: 2018-12-13
• 公開（公告）號: CN109788026B
• 公開（公告）日: 2022-03-08
• 發明（設計）人: 陳欣欣
• 申請（專利權）人: 新華三大數據技術有限公司
• 主分類號: H04L67/566
• 分類號: H04L67/566;H04L67/567
• 代理公司: 北京超凡志成知識產權代理事務所(普通合伙) 11371
• 代理人: 蘇勝

本發明提出一種消息處理方法及裝置，涉及數據處理領域，通過判斷從kafka獲取的消息中包含的序列號與第一全局變量的值是否相同的方式，且只有在消息的序列號與第一全局變量的值相同時，消費該消息。本發明提供的消息處理方法及裝置，能夠確保消費者按照消息正確的生產順序進行消費。

技術領域

本發明涉及數據處理領域，具體而言，涉及一種消息處理方法及裝置。

背景技術

Kafka是一種基于zookeeper協調管理的分布式流平臺的消息系統，能夠允許發布和訂閱流數據，kafka的基本結構中至少包括有產生消息的生產者(producer)和消費消息的消費者(consumer)，生產者負責生產消息，并發送給kafka服務器，消費者則從kafka集群中訂閱消費主題，以使消費者獲得kafka服務器中訂閱的主題下的消息進行消費。

Kafka服務器在接收到生產者發送的消息時，會將一組消息歸納為一個主題(即Topic)，簡單的說，主題就是kafka服務器對消息的分類，kafka服務器會將所有相同類別的消息存儲在同一主題下，消費者通過訂閱主題進行消費，即獲得相應的事件消息。

發明內容

本發明的目的在于提供一種消息處理方法及裝置，能夠確保消費者按照消息正確的生產順序進行消費。

為了實現上述目的，本發明實施例采用的技術方案如下：

第一方面，本發明實施例提供了一種消息處理方法，所述方法包括：

從kafka主題獲取消息，其中，所述消息中包含有序列號，所述序列號用于指示消息生產者在生產所述消息時的順序；

若所述消息的序列號與第一全局變量的值相同，消費所述消息，其中，所述第一全局變量的值用于指示待消費的消息在所述kafka主題中的序列號。

第二方面，本發明實施例提供了一種消息處理裝置，所述裝置包括：

收發模塊，用于從kafka主題獲取消息，其中，所述消息中包含有序列號，所述序列號用于指示消息生產者在生產所述消息時的順序；

處理模塊，用于若所述消息的序列號與第一全局變量的值相同，消費所述消息，其中，所述第一全局變量的值用于指示待消費的消息在所述kafka主題中的序列號。

第三方面，本發明實施例提供了一種電子設備，包括：存儲器，用于存儲一個或多個程序；處理器；當所述一個或多個程序被所述處理器執行時，實現本發明實施例所提供的消息處理方法。

相對于現有技術，本發明實施例所提供的一種消息處理方法及裝置，通過判斷從kafka獲取的消息中包含的序列號與第一全局變量的值是否相同的方式，且只有在消息的序列號與第一全局變量的值相同時，消費該消息，相比于現有技術，使消費者在消費所訂閱的主題下的消息時，不再依據每條消息產生時的時間戳來判斷不同消息間的生產順序，而是依據獲得的消息所包含的序列號與第一全局變量的值是否相同，以確保消費者按照正確的生產順序消費訂閱的主題下的消息。

為使本發明的上述目的、特征和優點能更明顯易懂，下文特舉較佳實施例，并配合所附附圖，作詳細說明如下。

附圖說明

為了更清楚地說明本發明實施例的技術方案，下面將對實施例中所需要使用的附圖作簡單地介紹，應當理解，以下附圖僅示出了本發明的某些實施例，因此不應被看作是對范圍的限定，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其它相關的附圖。

圖1示出了本發明實施例的一種示意性應用場景圖；

圖2示出了本發明實施例所提供的一種電子設備的一種示意性結構圖；

圖3示出了本發明實施例所提供的一種消息處理方法的一種示意性流程圖；