[發(fā)明專(zhuān)利]支付系統(tǒng)消息控制和處理方法、裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710152341.4
• 申請(qǐng)日: 2017-03-15
• 公開(kāi)（公告）號(hào): CN106970846B
• 公開(kāi)（公告）日: 2019-08-16
• 發(fā)明（設(shè)計(jì)）人: 李恒華;周利峰;酈鉑
• 申請(qǐng)（專(zhuān)利權(quán)）人: 銀清科技（北京）有限公司
• 主分類(lèi)號(hào): G06F9/54
• 分類(lèi)號(hào): G06F9/54;G06F9/48;G06F11/14;G06Q20/38
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王濤

本發(fā)明提供了一種支付系統(tǒng)消息控制和處理方法、裝置，涉及銀行支付系統(tǒng)數(shù)據(jù)處理技術(shù)領(lǐng)域。方法包括：從支付系統(tǒng)的消息中間件中輪詢(xún)讀取消息，獲取待處理業(yè)務(wù)報(bào)文；在當(dāng)前線程數(shù)小于最大線程數(shù)閾值時(shí)，讀取待處理業(yè)務(wù)報(bào)文；將待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表；若寫(xiě)入來(lái)報(bào)表未出現(xiàn)異常，啟動(dòng)新線程，對(duì)待處理業(yè)務(wù)報(bào)文進(jìn)行處理；若寫(xiě)入來(lái)報(bào)表出現(xiàn)異常，且異常次數(shù)大于等于預(yù)先設(shè)置的異常次數(shù)閾值，則將待處理業(yè)務(wù)報(bào)文放入錯(cuò)誤隊(duì)列；若寫(xiě)入來(lái)報(bào)表出現(xiàn)異常，且異常次數(shù)小于預(yù)先設(shè)置的異常次數(shù)閾值，將該待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常的次數(shù)增加1，并拋出異常，制造事務(wù)回滾使得待處理業(yè)務(wù)報(bào)文回到消息中間件的消息隊(duì)列中。

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

本發(fā)明涉及銀行支付系統(tǒng)數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種支付系統(tǒng)消息控制和處理方法、裝置。

背景技術(shù)

目前，隨著金融業(yè)的不斷發(fā)展，諸如外幣支付等業(yè)務(wù)也得到了空前的發(fā)展。外幣支付系統(tǒng)(China Foreign Exchange Payment System，簡(jiǎn)稱(chēng)CFXPS)是以業(yè)務(wù)處理中心(簡(jiǎn)稱(chēng)FXCC)為核心，由直接參與機(jī)構(gòu)等單一法人集中接入，由結(jié)算銀行(簡(jiǎn)稱(chēng)FXSI)進(jìn)行銀行間外幣資金結(jié)算的系統(tǒng)。其中，業(yè)務(wù)處理中心主要負(fù)責(zé)外幣支付指令的接收、存儲(chǔ)、清分、轉(zhuǎn)發(fā)，并將參與者的支付指令逐筆實(shí)時(shí)清算后，分幣種分場(chǎng)次將結(jié)算指令提交結(jié)算銀行進(jìn)行結(jié)算。其中，外幣支付系統(tǒng)的直接參與機(jī)構(gòu)分為直接參與者和特許參與者，直接參與者是直接接入業(yè)務(wù)處理中心的銀行業(yè)金融機(jī)構(gòu)，特許參與者是直接接入業(yè)務(wù)處理中心的支付清算組織等法人機(jī)構(gòu)；另外，委托直接參與者辦理外幣支付業(yè)務(wù)的機(jī)構(gòu)為間接參與者。結(jié)算銀行是中國(guó)人民銀行指定或授權(quán)的商業(yè)銀行，可以為直接參與者開(kāi)立外幣結(jié)算賬戶，負(fù)責(zé)參與者之間的外幣資金結(jié)算。

當(dāng)前，外幣支付系統(tǒng)采用分布式應(yīng)用架構(gòu)。在外幣支付系統(tǒng)的分布式應(yīng)用架構(gòu)中，對(duì)外部消息的監(jiān)聽(tīng)、接收、處理是至關(guān)重要的環(huán)節(jié)。目前對(duì)外部消息的監(jiān)聽(tīng)、接收、處理的實(shí)現(xiàn)主要有J2EE體系中的MDB(Message Driven Bean)和Spring體系中的MDP(MessageDriven Pojo)。而目前MDB和MDP這兩種方式在系統(tǒng)環(huán)境上需要依賴(lài)容器，即MDB需要依賴(lài)j2ee容器、MDP需要依賴(lài)spring容器(容器是應(yīng)用服務(wù)器中位于組件和平臺(tái)之間的接口集合)，這樣嚴(yán)重制約了其使用場(chǎng)景，而外幣支付系統(tǒng)中有諸多節(jié)點(diǎn)需要使用并最大程度地減少對(duì)容器的依賴(lài)。可見(jiàn)，現(xiàn)有技術(shù)中在不依賴(lài)容器的情況下，難以進(jìn)行支付系統(tǒng)消息控制和處理。

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

本發(fā)明的實(shí)施例提供一種支付系統(tǒng)消息控制和處理方法、裝置，以解決現(xiàn)有技術(shù)中在不依賴(lài)容器的情況下，難以進(jìn)行支付系統(tǒng)消息控制和處理的問(wèn)題。

為達(dá)到上述目的，本發(fā)明采用如下技術(shù)方案：

一種支付系統(tǒng)消息控制和處理方法，包括：

從支付系統(tǒng)的消息中間件中輪詢(xún)讀取消息，獲取待處理業(yè)務(wù)報(bào)文；

判斷當(dāng)前線程數(shù)是否大于預(yù)先設(shè)置的最大線程數(shù)閾值；

在當(dāng)前線程數(shù)小于所述最大線程數(shù)閾值時(shí)，讀取所述待處理業(yè)務(wù)報(bào)文，并確定待處理業(yè)務(wù)報(bào)文的類(lèi)型；

在待處理業(yè)務(wù)報(bào)文的類(lèi)型滿足預(yù)先設(shè)置的報(bào)文類(lèi)型條件時(shí)，將待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表；

若將待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表未出現(xiàn)異常，啟動(dòng)新線程，對(duì)待處理業(yè)務(wù)報(bào)文進(jìn)行處理；

若將待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常，且同一待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常的次數(shù)大于等于預(yù)先設(shè)置的異常次數(shù)閾值，則將待處理業(yè)務(wù)報(bào)文放入錯(cuò)誤隊(duì)列；

若將待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常，且同一待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常的次數(shù)小于預(yù)先設(shè)置的異常次數(shù)閾值，則將該待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)異常的次數(shù)增加1，并拋出該待處理業(yè)務(wù)報(bào)文寫(xiě)入來(lái)報(bào)表出現(xiàn)的異常，制造事務(wù)回滾使得待處理業(yè)務(wù)報(bào)文回到消息中間件的消息隊(duì)列中。

進(jìn)一步的，所述的支付系統(tǒng)消息控制和處理方法，還包括：