[發明專利]消息通知方法以及系統

在審

• 申請號: 202010955455.4
• 申請日: 2020-09-11
• 公開（公告）號: CN112256447A
• 公開（公告）日: 2021-01-22
• 發明（設計）人: 周曄;穆海潔;姜靖宇;張曉犇
• 申請（專利權）人: 上海匯付數據服務有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q20/02;G06Q20/32
• 代理公司: 北京德恒律治知識產權代理有限公司 11409
• 代理人: 章社杲;盧軍峰

本發明公開了一種消息通知方法以及系統，該方法包括：在接入第三方支付系統并且在調用第三方支付系統的下單接口之后，第三方支付系統接入獨立于第三方支付系統的消息通知系統，并且向消息通知系統傳遞與商戶的支付情況相關聯的通知信息，通知信息包括待通知消息和回調地址；消息通知系統根據接收到的通知信息獲取通知信息在多個集群中所對應的集群；根據集群對應的資源，消息通知系統將待通知消息發送到消息中間件rocketmq中商戶對應的topic中；商戶對應的集群從rocketmq中對應的topic中獲取待通知消息，并通過商戶的通知線程持將待通知消息發送給商戶。通過上述技術方案，至少能夠使系統可用性、隔離性得到保證。

技術領域

本發明涉及互聯網技術領域，具體來說，涉及一種消息通知方法以及系統。

背景技術

通常接入第三方支付系統(如微信支付、支付寶等)的時候，都需要在調用第三方支付的統一下單接口的時候，傳遞一個后臺回調的url(uniform resource locator，統一資源定位系統)。該參數是一個外網的可訪問地址，用于后臺接收第三方支付的支付結果回調，一般第三方支付會通過兩個方向通知商戶用戶在他們系統的支付情況，一個是及時的前端回調，還有一個是異步的后臺回調。其中前端回調是用于告知和處理前端的業務跳轉，JSAPI(一種支付方式)回調等，提升前端用戶交互方面的體驗；而后端的異步回調是更加安全和可靠的將結果通知給商戶用戶的方式。除了第三方支付以外，其他所有需要跨公網的異步信息傳遞，都可以使用異步回調的方式來通知對方，以提升整個業務的信息可靠和及時的傳遞。

通常要實現這樣的系統，一般會使用數據庫加定時任務掃描，或者redis的發布訂閱功能。

例如，騰訊及阿里的回調系統一般都是以固定時間間隔通知商戶的回調地址，不能靈活調整，對于異常之后的快速恢復不利。譬如微信支付結果通知，其通知頻率為：15/15/30/180/1800/1800/1800/1800/3600(單位：秒)。以上的時間間隔，雖然可以做到通知失敗后的多次重試，也可以容忍較長時間的通知問題。但是一旦前面幾次通知失敗之后，后面的通知間隔就迅速放大，如果通知多失敗幾次，那么很多通知都會延后很久才能再次發出。

通常現有的系統，都不能兼顧高可用、高并發、易擴展、故障隔離等特性。例如，如果使用redis，則很難保證數據可靠性、擴展性；如果使用數據庫加定時任務觸發，則很難保證靈活的觸發時間。

針對相關技術中的上述問題，目前尚未提出有效的解決方案。

發明內容

針對相關技術中上述的問題，本發明提出一種消息通知方法以及系統，能夠使可用性、隔離性得到保證，又能提高資源利用率，節約硬件成本；同時，故障率降低，運維成本降低。

根據本發明的一個方面，提供了一種消息通知方法，包括以下步驟：

在接入第三方支付系統并且在調用所述第三方支付系統的下單接口之后，所述第三方支付系統接入獨立于所述第三方支付系統的消息通知系統，并且向所述消息通知系統傳遞與商戶的支付情況相關聯的通知信息，所述通知信息包括待通知消息和回調地址；

所述消息通知系統根據接收到的所述通知信息獲取所述通知信息在多個集群中所對應的集群；

根據所述集群對應的資源，所述消息通知系統將所述待通知消息發送到消息中間件rocketmq中所述商戶對應的topic中；

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

通過配置rocketmq的topic的重發次數和重發間隔，調整通知失敗情況下的失敗重試次數和等待時間。

根據本發明的實施例，每個商戶的線程池相互獨立，每個商戶的所述線程池是可分配的，并且每個商戶的rocketmq資源不同。