【文章內(nèi)容簡(jiǎn)介】
企業(yè)信息總線服務(wù)器網(wǎng)間互聯(lián)平臺(tái)金融網(wǎng)間網(wǎng)稅務(wù)系統(tǒng)交易應(yīng)用服務(wù)器SKY前置系統(tǒng)基于 M Q基于 M Q商業(yè)銀行系統(tǒng)商業(yè)銀行系統(tǒng)圖 4 應(yīng)用連接結(jié)構(gòu)圖SKY與 TIPS之間的應(yīng)用連接結(jié)構(gòu)如圖 4所示,稅務(wù)總局與人民銀行共同定義一組 XML報(bào)文,以實(shí)現(xiàn) TIPS與稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)的對(duì)接。SKY與 TIPS的通信連接采用 MQ中間件實(shí)現(xiàn),SKY 的前置系統(tǒng)可選擇部署 MQ Server或 MQ Client,如果選擇部署 MQ Server,則選擇對(duì)等模式進(jìn)行通信連接,本模式可以保障性能需求;如果選擇部署 MQ Client,則選擇中心節(jié)點(diǎn)模式進(jìn)行通信連接,本模式可以節(jié)約成本,但在高性能需求方面存在局限性。采用上述何種通信連接模式,建議遵循“以滿足性能需求為前提”這一準(zhǔn)則。在接口隊(duì)列設(shè)計(jì)方面,為保障實(shí)時(shí)類交易的高可靠性和高實(shí)時(shí)響應(yīng)性,做到實(shí)時(shí)類交易和非實(shí)時(shí)類交易相互影響降至最低,我們對(duì)實(shí)時(shí)類交易和非實(shí)時(shí)類交易分別提供一組或多組通信接口隊(duì)列。接口隊(duì)列從業(yè)務(wù)角度上看,分別處理不同類別的交易;但在通信流程上,沒(méi)有本質(zhì)差別。業(yè)務(wù)處理與隊(duì)列通道的對(duì)應(yīng)可由配置進(jìn)行調(diào)整。因此,現(xiàn)以實(shí)時(shí)類交易為例,對(duì)中心節(jié)點(diǎn)模式和對(duì)等模式兩種通信連接模式的通信流13 / 40程分別加以說(shuō)明:? 中心節(jié)點(diǎn)模式(CS 模式)國(guó) 庫(kù) 信 息 處 理 系 統(tǒng)M Q S e r v e r Q u e u e s M a n a g e r R e g i o n接收 Q u e u e ( L o c a l )發(fā)送 Q u e u e ( R e m o t e )征 收 機(jī) 關(guān)MQIMQI 實(shí)時(shí)類交易接口隊(duì)列接收 Q u e u e ( L o c a l )發(fā)送 Q u e u e ( R e m o t e )MQIMQI 非實(shí)時(shí)類交易接口隊(duì)列Q 1Q 2 Q 1 39。 Q 2 39。M Q C l i e n t R e g i o n發(fā) 送程 序接 收程 序發(fā) 送程 序接 收程 序圖 5 中心節(jié)點(diǎn)模式中間件數(shù)據(jù)傳輸圖 說(shuō)明:如圖 5所示,TIPS 和稅務(wù)機(jī)關(guān)前置系統(tǒng)間的通信連接采用中間件 MQ Client TO MQ Server的方式(即中心節(jié)點(diǎn)模式) 。(1)聯(lián)網(wǎng)中心配置 MQ Server。通過(guò) MQ manager為 SKY系統(tǒng)創(chuàng)建接收隊(duì)列(Q1)和發(fā)送隊(duì)列(Q2) 。接收隊(duì)列(Q1 )用于接收稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)向 TIPS輸入的數(shù)據(jù),發(fā)送隊(duì)列用于發(fā)送 TIPS向稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)輸出的數(shù)據(jù)。(2)SKY 系統(tǒng)與 TIPS建立通信連接后,SKY 系統(tǒng)調(diào)用 MQ Client API(即 MQI)將請(qǐng)求消息寫(xiě)入遠(yuǎn)程的 TIPS分配的接收隊(duì)列( Q1)中。(3)TIPS 接收請(qǐng)求消息并處理完成后,將返回結(jié)果寫(xiě)到對(duì)應(yīng) SKY的發(fā)送隊(duì)列(Q2)中,聯(lián)網(wǎng)機(jī)構(gòu)調(diào)用 MQ Client API(即 MQI)從對(duì)應(yīng)的發(fā)送隊(duì)列(Q2)中輪詢接收處理結(jié)果。? 對(duì)等模式(S To S 模式)14 / 40發(fā)送 Q u e u e ( R e m o t e )T I P SM Q S e r v e r Q u e u e s M a n a g e r R e g i o n接收 Q u e u e ( L o c a l )發(fā)送 Q u e u e ( R e m o t e )S K YM Q S e r v e r Q u e u e s M a n a g e r R e g i o n接收 Q u e u e ( L o c a l )ChannelChannel 實(shí)時(shí)類交易接口隊(duì)列發(fā)送 Q u e u e ( R e m o t e )接收 Q u e u e ( L o c a l )發(fā)送 Q u e u e ( R e m o t e )接收 Q u e u e ( L o c a l )ChannelChannel 非實(shí)時(shí)類交易接口隊(duì)列Q 1Q 2Q 3 Q 4Q 1 39。Q 3 39。Q 2 39。Q 4 39。圖 6 對(duì)等模式中間件數(shù)據(jù)傳輸圖說(shuō)明:如圖 6所示,SKY 和 TIPS系統(tǒng)間的通信連接采用中間件 MQ Server TO MQ Server的方式(即對(duì)等模式) 。(1)SKY 通過(guò)自身的 MQ manager為接入的 TIPS系統(tǒng)分別創(chuàng)建發(fā)送隊(duì)列(Q1)和接收隊(duì)列(Q2) ,發(fā)送隊(duì)列用于發(fā)送稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)向 TIPS輸出的數(shù)據(jù),接收隊(duì)列用于接收 TIPS向稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)輸入的數(shù)據(jù)。(2)TIPS 系統(tǒng)通過(guò)自身的 MQ manager創(chuàng)建自己的接收隊(duì)列(Q3)和發(fā)送隊(duì)列(Q4) 。發(fā)送隊(duì)列用于發(fā)送 TIPS向稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)輸出的數(shù)據(jù),接收隊(duì)列用于接收稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)向 TIPS輸出的數(shù)據(jù)。當(dāng)稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)與 TIPS建立連接以后,會(huì)創(chuàng)建從稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)到 TIPS之間的通道( channel) ,通道兩端隊(duì)列的對(duì)應(yīng)關(guān)系見(jiàn)上圖。(3)稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)通過(guò)調(diào)用 MQ API將請(qǐng)求消息寫(xiě)入本地 MQ Server的發(fā)送隊(duì)列(Q1)中,消息經(jīng)通道傳輸至 TIPS為該業(yè)務(wù)系統(tǒng)分配的接收隊(duì)列(Q3)中,TIPS 處理完成后,將返回結(jié)果寫(xiě)到對(duì)應(yīng)為該業(yè)務(wù)系統(tǒng)分配的發(fā)送隊(duì)列(Q4)中,消息經(jīng)通道傳輸至稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)。15 / 40 應(yīng)用連接配置SKY與 TIPS系統(tǒng)的通信鏈路,通過(guò)配置 MQ Server的 Channel實(shí)現(xiàn)。在配置 MQ Channel及其它 MQ 對(duì)象時(shí),需要接口雙方向?qū)Ψ教峁╆?duì)列管理器名稱、服務(wù)器連接通道名稱、主機(jī)名或 IP地址、偵聽(tīng)端口、發(fā)送通道名稱、接收通道名稱、發(fā)送隊(duì)列名稱、接收隊(duì)列名稱、字符集等配置項(xiàng),稅務(wù)機(jī)關(guān)連接可參考人民銀行公布的《MQ 配置部署指引》 ??紤]到系統(tǒng)中處理的業(yè)務(wù)主要有兩種,即實(shí)時(shí)通信業(yè)務(wù)和異步業(yè)務(wù)。兩類業(yè)務(wù)的處理特點(diǎn)差異較大。實(shí)時(shí)通信業(yè)務(wù)通常報(bào)文較小,要求及時(shí)傳輸和處理;異步業(yè)務(wù)通常報(bào)文較大,不需要實(shí)時(shí)進(jìn)行傳輸和處理。為了保證實(shí)時(shí)業(yè)務(wù)的處理效率,SKY 系統(tǒng)將異步業(yè)務(wù)和實(shí)時(shí)通信業(yè)務(wù)放在不同的消息隊(duì)列中處理,系統(tǒng)設(shè)置實(shí)時(shí)隊(duì)列和異步(非實(shí)時(shí))隊(duì)列,其中實(shí)時(shí)隊(duì)列(包括一個(gè)實(shí)時(shí)發(fā)送隊(duì)列和一個(gè)實(shí)時(shí)接收隊(duì)列)將設(shè)置消息缺省屬性為非持久,異步(非實(shí)時(shí))隊(duì)列(包括一個(gè)批量發(fā)送隊(duì)列和一個(gè)批量接收隊(duì)列)將設(shè)置消息缺省屬性為持久。具體哪些交易和報(bào)文通過(guò)何種隊(duì)列傳輸見(jiàn) 。說(shuō)明:缺省情況下,放入非持久隊(duì)列中的消息具有非持久屬性,不記錄消息日志,優(yōu)點(diǎn)是消息傳輸?shù)男矢撸秉c(diǎn)是一旦出現(xiàn)隊(duì)列管理器異常、服務(wù)器掉電、關(guān)機(jī)等情況,隊(duì)列中的消息將丟失;放入持久隊(duì)列中的消息具有持久屬性,會(huì)記錄消息日志,優(yōu)點(diǎn)是在隊(duì)列管理器異常、服務(wù)器掉電、關(guān)機(jī)等情況下,消息不會(huì)丟失,缺點(diǎn)是效率較低。但是,非持久隊(duì)列中也可以傳輸持久消息,持久隊(duì)列中也可以傳輸非持久消息,不過(guò)需要應(yīng)用程序發(fā)送每條消息前對(duì)消息的屬性進(jìn)行明確的設(shè)置。 應(yīng)用連接信息包壓縮為了提高報(bào)文在網(wǎng)絡(luò)上的傳輸效率,各聯(lián)網(wǎng)機(jī)構(gòu)發(fā)送的報(bào)文須進(jìn)行壓縮處理,接收的報(bào)文要進(jìn)行解壓縮處理。對(duì)消息的壓縮處理和解壓縮處理可通過(guò) MQ的出口函數(shù)實(shí)現(xiàn),具體實(shí)現(xiàn)方法和算法應(yīng)參考《MQ 配置部署指引》 。 應(yīng)用連接批量報(bào)文的限制為了保證網(wǎng)絡(luò)傳輸?shù)目焖佟⒓皶r(shí)、高效,系統(tǒng)限定聯(lián)網(wǎng)單位發(fā)起的批量包封裝的業(yè)務(wù)在 1千筆以內(nèi)(小于一千筆) 。TIPS發(fā)起的與綜合征管系統(tǒng)信息核對(duì)、入庫(kù)明細(xì)、報(bào)表明細(xì)筆數(shù)如果超過(guò)了一千筆,進(jìn)行分包發(fā)送,并在信息包的匯總信息中列出總筆數(shù)以及當(dāng)前包在總包里的序號(hào)。對(duì)于批16 / 40量扣稅業(yè)務(wù),SKY 系統(tǒng)負(fù)責(zé)進(jìn)行包的組裝;對(duì)于批量扣稅回執(zhí)和核對(duì)通知業(yè)務(wù),TIPS 負(fù)責(zé)進(jìn)行包的組裝。 應(yīng)用連接接口處理模式SKY系統(tǒng)與 TIPS之間的聯(lián)機(jī)交易模式包括五種,具體如下: SKY 發(fā)送同步請(qǐng)求處理模式S K Y T I P S21圖 7稅務(wù)機(jī)關(guān)發(fā)起同步處理模式說(shuō)明:1.SKY 系統(tǒng)通過(guò) MQ發(fā)送信息給 TIPS;2.TIPS 系統(tǒng)接收后,及時(shí)處理,在處理結(jié)束后立即給 SKY系統(tǒng)同步的應(yīng)答。此種模式適用于綜合征管系統(tǒng)發(fā)起的:業(yè)務(wù)應(yīng)答含義序號(hào) 業(yè)務(wù)請(qǐng)求名稱收妥 業(yè)務(wù)處理1 實(shí)時(shí)扣稅 ★ ★2 沖正(即撤消倒扣) ★ ★3 自繳核銷(正劃) ★4 撤消自繳核銷(撤消正劃) ★ ★5 退庫(kù)請(qǐng)求 ★6 撤消退庫(kù) ★ ★7 更正請(qǐng)求 ★8 撤消更正 ★ ★9 免抵調(diào)請(qǐng)求 ★10 撤消免抵調(diào) ★ ★11 三方協(xié)議認(rèn)證(稅發(fā)起) ★ ★12 連接測(cè)試 ★ ★13 包和交易狀態(tài)查詢 ★ ★14 登錄 ★ ★15 簽退 ★ ★征管發(fā)送業(yè)務(wù)信息給國(guó)庫(kù)信息處理系統(tǒng),國(guó)庫(kù)信息處理系統(tǒng)接收后,立即進(jìn)行處理,17 / 40并在處理結(jié)束后同步返回處理結(jié)果回執(zhí)報(bào)文給稅務(wù)機(jī)關(guān),不同的業(yè)務(wù),應(yīng)答含義有所不同。如使用異步通信隊(duì)列實(shí)現(xiàn)模式一中的同步業(yè)務(wù),必須滿足實(shí)時(shí)性要求。 SKY 異步業(yè)務(wù)處理模式S K Y T I P S21圖 8稅務(wù)機(jī)關(guān)發(fā)起異步處理模式說(shuō)明: MQ發(fā)送業(yè)務(wù)請(qǐng)求信息給 TIPS;,通過(guò) MQ發(fā)送異步處理回執(zhí)給稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)。此種模式主要適用于:業(yè)務(wù)處理含義序 業(yè)務(wù)名稱 寫(xiě)發(fā)送異步隊(duì)列 異步隊(duì)列接收通知/處理回執(zhí)1 發(fā)送批量扣稅 →(注①)2 批量扣稅回執(zhí) ←3 自繳核銷業(yè)務(wù)應(yīng)答 ←4 退庫(kù)業(yè)務(wù)回執(zhí) ←5 更正業(yè)務(wù)回執(zhí) ←6 免抵調(diào)業(yè)務(wù)回執(zhí) ←7 止付 →8 止付應(yīng)答 ←9 下載入庫(kù)流水憑證請(qǐng)求 →10 下載入庫(kù)流水憑證響應(yīng) ←11 下載報(bào)表請(qǐng)求 →12 下載報(bào)表響應(yīng) ←注①:“→”代表模式當(dāng)中的第 1步;“←”代表模式當(dāng)中的第 2步。18 / 40 SKY 發(fā)送信息處理模式S K Y T I P S1圖 9 SKY發(fā)送信息處理模式說(shuō)明:1. SKY系統(tǒng)通過(guò) MQ發(fā)送業(yè)務(wù)信息到 TIPS 此種模式適用于:業(yè)務(wù)處理含義序號(hào) 業(yè)務(wù)名稱寫(xiě)異步隊(duì)列 說(shuō)明1 自由格式報(bào)文 →2 通用結(jié)果處理通知 → 注①3 申請(qǐng)重發(fā)核對(duì)包請(qǐng)求 →注①:收到 TIPS的異步通知(如各核對(duì)通知、公共數(shù)據(jù)更新)時(shí),出現(xiàn)異常,發(fā)送該通知。 TIPS 發(fā)送同步請(qǐng)求處理模式S K Y T I P S12圖 10 稅務(wù)機(jī)關(guān)接收同步處理模式說(shuō)明:1. 國(guó)庫(kù)信息處理系統(tǒng)通過(guò) MQ發(fā)送業(yè)務(wù)信息給稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng);2. 稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)在接收到國(guó)庫(kù)信息處理系統(tǒng)發(fā)送過(guò)來(lái)的業(yè)務(wù)信息后,立即19 / 40處理,處理結(jié)束后同步通過(guò) MQ發(fā)送回執(zhí)給 TIPS。此種模式適用于 TIPS發(fā)起的連接測(cè)試請(qǐng)求,銀行端繳款,銀行端查詢繳款等業(yè)務(wù)。業(yè)務(wù)處理含義序號(hào) 業(yè)務(wù)名稱收妥 處理1 連接測(cè)試請(qǐng)求 ★ ★2 三方協(xié)議認(rèn)證(TIPS 發(fā)起) ★3 銀行端繳款業(yè)務(wù) ★ ★4 銀行端查詢繳款 ★ ★ TIPS 發(fā)送信息處理模式S K Y T I P S1圖 11 SKY接收信息處理模式說(shuō)明:1. 稅務(wù)機(jī)關(guān)業(yè)務(wù)系統(tǒng)通過(guò) MQ接收 TIPS的業(yè)務(wù)信息此種模式適用于:業(yè)務(wù)處理含義序號(hào) 業(yè)務(wù)名稱寫(xiě)異步隊(duì)列 通知/處理回執(zhí)1 稅票信息核對(duì)消息通知 ★ ←2 退庫(kù)業(yè)務(wù)核對(duì)消息通知 ★ ←3 更正業(yè)務(wù)核對(duì)消息通知 ★ ←4 免抵調(diào)業(yè)務(wù)核對(duì)消息通知 ★ ←5 公共數(shù)據(jù)更新通知 ★ ←6 自由格式報(bào)文 ★ ←7 停運(yùn)通知 ★ ←8 故障通知 ★ ←9 運(yùn)行參數(shù)通知 ★ ←原則上是單向的通信交易,接收方不必再發(fā)送收妥通知,但如果發(fā)生“報(bào)文解析不全”等錯(cuò)誤,則接收方需要根據(jù)報(bào)文參考號(hào)按照模式三發(fā)送“申請(qǐng)重發(fā)核對(duì)包請(qǐng)求” 。 應(yīng)用連接中報(bào)文的匹配為了方便發(fā)起方的業(yè)務(wù)處理,系統(tǒng)提供三個(gè)層次(三種方式)的報(bào)文和交易的匹配機(jī)20 / 40制。 MQ消息 ID的消息匹配機(jī)制無(wú)論 SKY還是 TIPS系統(tǒng),都同時(shí)具備雙重身份,既可能是交易的發(fā)起請(qǐng)求方,又可能是交易的服務(wù)響應(yīng)方。如:在實(shí)時(shí)扣款交易中,稅務(wù)機(jī)關(guān)作為交易的發(fā)起請(qǐng)求方,而 TIPS對(duì)綜合征管系統(tǒng)而言作為交易的服務(wù)響應(yīng)方;在三方協(xié)議認(rèn)證交易中,TIPS(商業(yè)銀行)作為交易的發(fā)起請(qǐng)求方,而 SKY作為交易的服務(wù)響應(yīng)方。在圖 12中,交易的發(fā)起請(qǐng)求方,設(shè)計(jì)交易請(qǐng)求服務(wù);作為交易的服務(wù)響應(yīng)方,則設(shè)計(jì)交易響應(yīng)服務(wù)。下面結(jié)合圖 12,說(shuō)明接口雙方應(yīng)用開(kāi)發(fā)中需要遵循的技術(shù)規(guī)范。接收 Q u e u e發(fā)送 Q u e u e交易響應(yīng)服務(wù)交易請(qǐng)求服務(wù) 1 . 發(fā)起請(qǐng)求報(bào)文2.按CorrelId匹配接收回執(zhí)報(bào)文1. 實(shí)時(shí)接收請(qǐng)求報(bào)文2. 設(shè)置CorrelId=MsgId后,實(shí)時(shí)發(fā)送回執(zhí)報(bào)文M s g 1 2 3 ( R E Q )M s g I d = 39。 1 2 3 39。C o r r e l I d = 39。 R E Q 39。X M L . M s g = 39。請(qǐng)求信息 39。征收機(jī)關(guān)