[發(fā)明專利]消息通知方法以及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202010955455.4
• 申請日: 2020-09-11
• 公開（公告）號: CN112256447A
• 公開（公告）日: 2021-01-22
• 發(fā)明（設(shè)計）人: 周曄;穆海潔;姜靖宇;張曉犇
• 申請（專利權(quán)）人: 上海匯付數(shù)據(jù)服務(wù)有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q20/02;G06Q20/32
• 代理公司: 北京德恒律治知識產(chǎn)權(quán)代理有限公司 11409
• 代理人: 章社杲;盧軍峰

1.一種消息通知方法，其特征在于，包括：

在接入第三方支付系統(tǒng)并且在調(diào)用所述第三方支付系統(tǒng)的下單接口之后，所述第三方支付系統(tǒng)接入獨(dú)立于所述第三方支付系統(tǒng)的消息通知系統(tǒng)，并且向所述消息通知系統(tǒng)傳遞與商戶的支付情況相關(guān)聯(lián)的通知信息，所述通知信息包括待通知消息和回調(diào)地址；

所述消息通知系統(tǒng)根據(jù)接收到的所述通知信息獲取所述通知信息在多個集群中所對應(yīng)的集群；

根據(jù)所述集群對應(yīng)的資源，所述消息通知系統(tǒng)將所述待通知消息發(fā)送到消息中間件rocketmq中所述商戶對應(yīng)的消息主題topic中；

所述商戶對應(yīng)的集群從rocketmq中對應(yīng)的topic中獲取所述待通知消息，并通過所述商戶的通知線程持將所述待通知消息發(fā)送給所述商戶；

通過配置rocketmq的topic的重發(fā)次數(shù)和重發(fā)間隔，調(diào)整通知失敗情況下的失敗重試次數(shù)和等待時間。

2.根據(jù)權(quán)利要求1所述的消息通知方法，其特征在于，

每個商戶的線程池相互獨(dú)立，

每個商戶的所述線程池是可分配的，并且

每個商戶的rocketmq資源不同。

3.根據(jù)權(quán)利要求1所述的消息通知方法，其特征在于，還包括：

當(dāng)將所述待通知消息發(fā)送rocketmq失敗時，則將所述待通知消息存入數(shù)據(jù)庫；

定期掃描所述數(shù)據(jù)庫中的所述待通知消息。

4.根據(jù)權(quán)利要求3所述的消息通知方法，其特征在于，

多個集群中的每個集群通過集群號與每個商戶、數(shù)據(jù)庫和rocketmq相互關(guān)聯(lián)對應(yīng)。

5.根據(jù)權(quán)利要求1所述的消息通知方法，其特征在于，

所述第三方支付系統(tǒng)通過rpc協(xié)議接入所述消息通知系統(tǒng)，并將所述通知信息傳遞給所述消息通知系統(tǒng)的rpc接口。

6.一種消息通知系統(tǒng)，其特征在于，所述消息通知系統(tǒng)獨(dú)立于第三方支付系統(tǒng)并用于將來自所述第三方支付系統(tǒng)的待通知消息通知給商戶，其中，所述消息通知系統(tǒng)具有多個集群并且用于：

在接入第三方支付系統(tǒng)并且在調(diào)用所述第三方支付系統(tǒng)的下單接口之后接入所述第三方支付系統(tǒng)，并且接收所述第三方支付系統(tǒng)發(fā)送的與商戶的支付情況相關(guān)聯(lián)的通知信息，所述通知信息包括待通知消息和回調(diào)地址；

根據(jù)接收到的所述通知信息獲取所述通知信息在多個集群中所對應(yīng)的集群；

根據(jù)所述集群對應(yīng)的資源，將所述待通知消息發(fā)送到消息中間件rocketmq中所述商戶對應(yīng)的topic中；

所述商戶對應(yīng)的集群從rocketmq中對應(yīng)的topic中獲取所述待通知消息，并通過所述商戶的通知線程持將所述待通知消息發(fā)送給所述商戶；

通過配置rocketmq的topic的重發(fā)次數(shù)和重發(fā)間隔，調(diào)整通知失敗情況下的失敗重試次數(shù)和等待時間。

7.根據(jù)權(quán)利要求6所述的消息通知系統(tǒng)，其特征在于，

每個商戶的線程池相互獨(dú)立，

每個商戶的所述線程池是可分配的，并且

每個商戶的rocketmq資源不同。

8.根據(jù)權(quán)利要求6所述的消息通知系統(tǒng)，其特征在于，

多個集群中的每個集群通過集群號與每個商戶、數(shù)據(jù)庫和rocketmq相互關(guān)聯(lián)對應(yīng)。