[發明專利]信息處理方法及系統

在審

• 申請號: 201810190114.5
• 申請日: 2018-03-08
• 公開（公告）號: CN110245026A
• 公開（公告）日: 2019-09-17
• 發明（設計）人: 楊來昌
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 呂雁葭

本公開提供了一種信息處理方法，包括：獲取按照預設排序邏輯對位點信息進行排序而構成的消息序列，其中，與消息序列中的位點信息對應的消息包括通過不同線程處理的消息，且消息序列包含至少一個消息序列片段，每個消息序列片段中的位點信息都是按照預設排序邏輯連續排列的；從消息序列包含的至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段；以及提交目標消息序列片段。本公開還提供了一種信息處理系統、一種計算機系統和一種計算機可讀存儲介質。

技術領域

本公開涉及計算機技術領域，更具體地，涉及一種信息處理方法及系統、一種計算機系統和一種計算機可讀存儲介質。

背景技術

消息隊列是應用程序中重要的消息中間件之一，它們大部分都是基于Java消息服務(Java Message Service，簡稱為JMS)規范實現的，例如Apache ActiveMQ消息隊列就是一個消息結合體，可提供跨平臺，高可用，高吞吐的數據服務，目前消息隊列在很多行業都有廣泛的應用。

比如，消息作為一種數據形式，在處理過程中，通常會被暫存在消息隊列中。針對消息隊列中暫存的消息，一些相關技術提供了單線程消息處理方式，而單線程處理方式在面對數據量巨大或者數據洪峰期的應用場景時很容易造成數據積壓。為了克服數據積壓缺陷，另一些相關技術提供了多線程消息處理方式。

然而，在實現本公開構思的過程中，發明人發現相關技術中至少存在如下問題：現有的多線程消息處理方式無法按位點順序反饋已處理的消息對應的位點信息。

發明內容

有鑒于此，本公開提供了一種通過提交與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段以解決現有的多線程消息處理方式無法按位點順序反饋已處理的消息對應的位點信息的缺陷的信息處理方法和系統。

本公開的一個方面提供了一種信息處理方法，該信息處理包括：獲取按照預設排序邏輯對位點信息進行排序而構成的消息序列，其中，與上述消息序列中的位點信息對應的消息包括通過不同線程處理的消息，且上述消息序列包含至少一個消息序列片段，每個上述消息序列片段中的位點信息都是按照上述預設排序邏輯連續排列的；從上述消息序列包含的上述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段；以及提交上述目標消息序列片段。

根據本公開的實施例，從上述消息序列包含的上述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段包括：針對上述至少一個消息序列片段，確定其中每個消息序列片段中處于首位的位點信息；基于確定出的位點信息，確定上述每個消息序列片段中處于首位的位點信息所表示的首位位點；從確定出的所有首位位點中選出排位最靠前的首位位點；以及將與上述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為上述目標消息序列片段。

根據本公開的實施例，上述信息處理方法還包括：在將與上述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為上述目標消息序列片段之前，確定上述之前已提交的消息序列片段中處于末位的位點信息；確定上述處于末位的位點信息所表示的末位位點；判斷上述末位位點與上述排位最靠前的首位位點是否是連續的位點；以及若是，則將與上述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為上述目標消息序列片段。

根據本公開的實施例，上述信息處理方法還包括：按照預設時鐘周期或者在上述消息序列中位點信息的數量達到預設值時，從上述消息序列包含的上述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段，并提交上述目標消息序列片段。

根據本公開的實施例，每個位點信息對應一個消息，上述信息處理方法還包括：接收各位點信息對應的消息；對上述各位點信息對應的消息進行分類處理；以及根據分類處理結果，將不同類別的消息分配到不同的線程中進行消息處理。