[發(fā)明專利]一種消息隊(duì)列的消息插入時(shí)間的方法及攔截器

在審

• 申請(qǐng)?zhí)枺?/td>: 201710340844.4
• 申請(qǐng)日: 2017-05-15
• 公開（公告）號(hào): CN107133115A
• 公開（公告）日: 2017-09-05
• 發(fā)明（設(shè)計(jì)）人: 楊振庚
• 申請(qǐng)（專利權(quán)）人: 鄭州云海信息技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 濟(jì)南信達(dá)專利事務(wù)所有限公司37100
• 代理人: 李世喆

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，特別涉及一種消息隊(duì)列的消息插入時(shí)間的方法。

背景技術(shù)

在復(fù)雜的軟件系統(tǒng)中，為了實(shí)現(xiàn)軟件系統(tǒng)的功能，需要軟件系統(tǒng)中各個(gè)模塊之間進(jìn)行頻繁的消息交互。

目前，軟件系統(tǒng)中各個(gè)模塊之間的消息交互通過(guò)消息隊(duì)列來(lái)實(shí)現(xiàn)。在對(duì)進(jìn)入消息隊(duì)列的消息加入時(shí)間戳?xí)r，消息隊(duì)列不能對(duì)加入的消息進(jìn)行不同的操作，要么加入的消息均插入時(shí)間戳，要么加入的消息均不插入時(shí)間戳。

但是，在實(shí)際應(yīng)用中，存在一些模塊需要消息隊(duì)列傳送帶有時(shí)間戳的消息，而另外一些模塊并不需要消息隊(duì)列傳送帶有時(shí)間戳的消息。但是消息隊(duì)列不能對(duì)上述這些模塊需要的消息進(jìn)行不同的插入時(shí)間戳操作，因此，現(xiàn)有的方式，業(yè)務(wù)靈活性較差。

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

本發(fā)明提供了一種消息隊(duì)列的消息插入時(shí)間的方法及攔截器，可以提高業(yè)務(wù)靈活性。

第一方面，本發(fā)明提供了一種消息隊(duì)列的消息插入時(shí)間的方法，該方法包括：

獲取待加入消息；

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

根據(jù)所述至少一個(gè)參數(shù)信息，確定所述待加入消息是否需要插入時(shí)間戳；

當(dāng)確定所述待加入消息需要插入時(shí)間戳?xí)r，在所述待加入消息的消息頭中插入時(shí)間戳，將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列。

優(yōu)選地，

所述根據(jù)所述至少一個(gè)參數(shù)信息，確定所述待加入消息是否需要插入時(shí)間戳，包括：

確定每一個(gè)所述參數(shù)信息對(duì)應(yīng)的類型；

根據(jù)各個(gè)所述類型，確定所述待加入消息是否需要插入時(shí)間戳。

優(yōu)選地，

所述在所述待加入消息的消息頭中插入時(shí)間戳，將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列，包括：

確定將所述待加入消息加入消息隊(duì)列的時(shí)間；

利用確定的所述時(shí)間生成時(shí)間戳；

在所述待加入消息的消息頭中插入生成的時(shí)間戳，將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列。

優(yōu)選地，

所述將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列，包括：

確定所述消息對(duì)列中至少一個(gè)加入位置；

在所述至少一個(gè)加入位置中，確定目標(biāo)加入位置；

將插入時(shí)間戳的所述待加入消息加入所述目標(biāo)加入位置中。

優(yōu)選地，

進(jìn)一步包括：

當(dāng)確定所述待加入消息不需要插入時(shí)間戳?xí)r，將所述待加入消息加入消息隊(duì)列。

優(yōu)選地，

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

優(yōu)選地，

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

第二方面，本發(fā)明提供了一種消息隊(duì)列的消息插入時(shí)間的攔截器，該攔截器包括：

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

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

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

第一加入單元，用于當(dāng)所述確定單元確定所述待加入消息需要插入時(shí)間戳?xí)r，在所述待加入消息的消息頭中插入時(shí)間戳，將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列。

優(yōu)選地，

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

所述類型確定子單元，用于確定每一個(gè)所述參數(shù)信息對(duì)應(yīng)的類型；

所述確定子單元，用于根據(jù)所述類型確定子單元確定的各個(gè)所述類型，確定所述待加入消息是否需要插入時(shí)間戳。

優(yōu)選地，

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

所述時(shí)間確定子單元，用于確定將所述待加入消息加入消息隊(duì)列的時(shí)間；

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

所述加入子單元，用于在所述待加入消息的消息頭中插入所述生成單元生成的時(shí)間戳，將插入時(shí)間戳的所述待加入消息加入消息隊(duì)列。

優(yōu)選地，

所述第一加入單元，用于確定所述消息對(duì)列中至少一個(gè)加入位置；在所述至少一個(gè)加入位置中，確定目標(biāo)加入位置；將插入時(shí)間戳的所述待加入消息加入所述目標(biāo)加入位置中。

優(yōu)選地，

進(jìn)一步包括：第二加入子單元；