[發(fā)明專利]信息處理方法、終端、系統(tǒng)、計(jì)算機(jī)設(shè)備和存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010049302.3
• 申請(qǐng)日: 2020-01-16
• 公開(kāi)（公告）號(hào): CN111274047A
• 公開(kāi)（公告）日: 2020-06-12
• 發(fā)明（設(shè)計(jì)）人: 尹如鵬
• 申請(qǐng)（專利權(quán)）人: 中國(guó)平安財(cái)產(chǎn)保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 深圳市力道知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44507
• 代理人: 何姣

1.一種信息處理方法，其特征在于，包括：

生成待消費(fèi)信息、與所述待消費(fèi)信息對(duì)應(yīng)的確認(rèn)信息以及用于識(shí)別所述待消費(fèi)信息和所述確認(rèn)信息的唯一識(shí)別號(hào)；

將所述待消費(fèi)信息和對(duì)應(yīng)的所述唯一識(shí)別號(hào)發(fā)送至預(yù)備信息隊(duì)列中進(jìn)行緩存；

發(fā)送與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述確認(rèn)信息至RocketMQ服務(wù)組件，以使所述RocketMQ服務(wù)組件將所述預(yù)備信息隊(duì)列中與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述待消費(fèi)信息釋放至第一目標(biāo)終端進(jìn)行消費(fèi)。

2.根據(jù)權(quán)利要求1所述的信息處理方法，其特征在于：在所述RocketMQ服務(wù)組件將所述預(yù)備信息隊(duì)列中與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述待消費(fèi)信息釋放至第一目標(biāo)終端進(jìn)行消費(fèi)之后，還包括：

獲取所述待消費(fèi)信息被釋放時(shí)返回的序列指示信息；

對(duì)所述序列指示信息進(jìn)行解析以得到序列待消費(fèi)信息的唯一識(shí)別號(hào)；

發(fā)送與所述唯一識(shí)別號(hào)對(duì)應(yīng)的確認(rèn)信息至RocketMQ服務(wù)組件，以使所述RocketMQ服務(wù)組件從所述預(yù)備信息隊(duì)列中獲取與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述序列待消費(fèi)信息，并將所述序列待消費(fèi)信息釋放至第二目標(biāo)終端進(jìn)行消費(fèi)。

3.根據(jù)權(quán)利要求1所述的信息處理方法，其特征在于，所述生成用于識(shí)別所述待消費(fèi)信息和所述確認(rèn)信息的唯一識(shí)別號(hào)，包括：

采用分布式鎖生成用于識(shí)別所述待消費(fèi)信息和所述確認(rèn)信息的唯一識(shí)別號(hào)。

4.根據(jù)權(quán)利要求1所述的信息處理方法，其特征在于，所述將所述待消費(fèi)信息和對(duì)應(yīng)的所述唯一識(shí)別號(hào)發(fā)送至預(yù)備信息隊(duì)列中進(jìn)行緩存，包括，

將所述待消費(fèi)信息和對(duì)應(yīng)的所述唯一識(shí)別號(hào)發(fā)送至預(yù)備信息隊(duì)列中進(jìn)行緩存，并啟動(dòng)所述確認(rèn)信息的發(fā)送倒計(jì)時(shí)；

發(fā)送具備所述唯一識(shí)別號(hào)的確認(rèn)信息至RocketMQ服務(wù)組件，以使所述RocketMQ服務(wù)組件將所述預(yù)備信息隊(duì)列中與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述待消費(fèi)信息釋放至第一目標(biāo)終端進(jìn)行消費(fèi)，包括，

在所述確認(rèn)信息的發(fā)送倒計(jì)時(shí)結(jié)束后，發(fā)送具備所述唯一識(shí)別號(hào)的確認(rèn)信息至RocketMQ服務(wù)組件，以使所述RocketMQ服務(wù)組件將所述預(yù)備信息隊(duì)列中與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述待消費(fèi)信息釋放至第一目標(biāo)終端進(jìn)行消費(fèi)。

5.根據(jù)權(quán)利要求1所述的信息處理方法，其特征在于，在所述將所述待消費(fèi)信息和對(duì)應(yīng)的所述唯一識(shí)別號(hào)發(fā)送至預(yù)備信息隊(duì)列中進(jìn)行緩存之后，還包括：

設(shè)置所述待消費(fèi)信息的存活時(shí)間；

若所述待消費(fèi)信息在所述存活時(shí)間內(nèi)未被消費(fèi)，則將所述待消費(fèi)信息轉(zhuǎn)發(fā)至其他預(yù)備信息隊(duì)列。

6.根據(jù)權(quán)利要求1所述的信息處理方法，其特征在于，在所述發(fā)送與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述確認(rèn)信息至RocketMQ服務(wù)組件之后，還包括：

接收從已連接的所述RocketMQ服務(wù)組件的服務(wù)提供節(jié)點(diǎn)的節(jié)點(diǎn)返回信息；

判斷接收到相鄰兩次所述節(jié)點(diǎn)返回信息的時(shí)間間隔是否超過(guò)預(yù)設(shè)時(shí)長(zhǎng)；

若接收到相鄰兩次所述節(jié)點(diǎn)返回信息的時(shí)間間隔超過(guò)預(yù)設(shè)時(shí)長(zhǎng)，則選擇所述RocketMQ服務(wù)組件的其他服務(wù)提供節(jié)點(diǎn)建立連接。

7.一種終端，其特征在于，所述終端包括：

信息生成模塊，用于生成待消費(fèi)信息、與所述待消費(fèi)信息對(duì)應(yīng)的確認(rèn)信息以及用于識(shí)別所述待消費(fèi)信息和所述確認(rèn)信息的唯一識(shí)別號(hào)；

信息發(fā)送模塊，用于將所述待消費(fèi)信息和對(duì)應(yīng)的所述唯一識(shí)別號(hào)發(fā)送至預(yù)備信息隊(duì)列中進(jìn)行緩存；

確認(rèn)發(fā)送模塊，用于發(fā)送具備所述唯一識(shí)別號(hào)的所述確認(rèn)信息至RocketMQ服務(wù)組件，以使所述RocketMQ服務(wù)組件將所述預(yù)備信息隊(duì)列中與所述唯一識(shí)別號(hào)對(duì)應(yīng)的所述待消費(fèi)信息釋放至第一目標(biāo)終端進(jìn)行消費(fèi)。

8.一種信息處理系統(tǒng)，其特征在于，所述信息處理系統(tǒng)包括RocketMQ服務(wù)組件和若干個(gè)如權(quán)利要求7所述的終端。