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