[發明專利]一種消息隊列的消息插入時間的方法及攔截器

在審

• 申請號: 201710340844.4
• 申請日: 2017-05-15
• 公開（公告）號: CN107133115A
• 公開（公告）日: 2017-09-05
• 發明（設計）人: 楊振庚
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 濟南信達專利事務所有限公司37100
• 代理人: 李世喆

1.一種消息隊列的消息插入時間的方法，其特征在于，包括：

獲取待加入消息；

解析所述待加入消息的消息頭，其中，所述消息頭包括至少一個參數信息；

根據所述至少一個參數信息，確定所述待加入消息是否需要插入時間戳；

當確定所述待加入消息需要插入時間戳時，在所述待加入消息的消息頭中插入時間戳，將插入時間戳的所述待加入消息加入消息隊列。

2.根據權利要求1所述的方法，其特征在于，

所述根據所述至少一個參數信息，確定所述待加入消息是否需要插入時間戳，包括：

確定每一個所述參數信息對應的類型；

根據各個所述類型，確定所述待加入消息是否需要插入時間戳。

3.根據權利要求1所述的方法，其特征在于，

所述在所述待加入消息的消息頭中插入時間戳，將插入時間戳的所述待加入消息加入消息隊列，包括：

確定將所述待加入消息加入消息隊列的時間；

利用確定的所述時間生成時間戳；

在所述待加入消息的消息頭中插入生成的時間戳，將插入時間戳的所述待加入消息加入消息隊列。

4.根據權利要求1所述的方法，其特征在于，

所述將插入時間戳的所述待加入消息加入消息隊列，包括：

確定所述消息對列中至少一個加入位置；

在所述至少一個加入位置中，確定目標加入位置；

將插入時間戳的所述待加入消息加入所述目標加入位置中。

5.根據權利要求1至4任一所述的方法，其特征在于，

進一步包括：

當確定所述待加入消息不需要插入時間戳時，將所述待加入消息加入消息隊列。

6.根據權利要求1至4任一所述的方法，其特征在于，

所述消息隊列，包括：ActiveMQ、RabbitMQ、Redis、ZeroMQ以及Kafka中的任意一種；

和/或，

所述時間戳的格式，包括：年-月-日、年-月-日-小時-分鐘-秒、小時-分鐘-秒中的任意一種。

7.一種消息隊列的消息插入時間的攔截器，其特征在于，包括：

獲取單元，用于獲取待加入消息；

解析單元，用于解析所述獲取單元獲取的所述待加入消息的消息頭，其中，所述消息頭包括至少一個參數信息；

確定單元，用于根據所述解析單元解析的所述至少一個參數信息，確定所述待加入消息是否需要插入時間戳；

第一加入單元，用于當所述確定單元確定所述待加入消息需要插入時間戳時，在所述待加入消息的消息頭中插入時間戳，將插入時間戳的所述待加入消息加入消息隊列。

8.根據權利要求1所述的攔截器，其特征在于，

所述確定單元，包括：類型確定子單元和確定子單元；

所述類型確定子單元，用于確定每一個所述參數信息對應的類型；

所述確定子單元，用于根據所述類型確定子單元確定的各個所述類型，確定所述待加入消息是否需要插入時間戳。

9.根據權利要求1所述的攔截器，其特征在于，

所述第一加入單元，包括：時間確定子單元、生成子單元、加入子單元；

所述時間確定子單元，用于確定將所述待加入消息加入消息隊列的時間；

所述生成子單元，用于利用所述時間確定子單元確定的所述時間生成時間戳；

所述加入子單元，用于在所述待加入消息的消息頭中插入所述生成單元生成的時間戳，將插入時間戳的所述待加入消息加入消息隊列；

和/或，

所述第一加入單元，用于確定所述消息對列中至少一個加入位置；在所述至少一個加入位置中，確定目標加入位置；將插入時間戳的所述待加入消息加入所述目標加入位置中。

10.根據權利要求7至9任一所述的攔截器，其特征在于，

進一步包括：第二加入子單元；

所述第二加入子單元，用于當確定所述待加入消息不需要插入時間戳時，將所述待加入消息加入消息隊列。