現(xiàn)對(duì)此典型的流數(shù)據(jù)處理系統(tǒng)設(shè)計(jì)思路進(jìn)行簡(jiǎn)要介紹

1)客戶通過POS等渠道進(jìn)行交易。

2)流數(shù)據(jù)處理系統(tǒng)引入大內(nèi)存、分布式計(jì)算等技術(shù)實(shí)現(xiàn)交易數(shù)據(jù)的快速處理。

3)流數(shù)據(jù)處理系統(tǒng)準(zhǔn)實(shí)時(shí)推送服務(wù)，廣泛應(yīng)用于余額提醒、事件式營銷、風(fēng)險(xiǎn)防控等交易場(chǎng)景。

4)客戶經(jīng)理、業(yè)務(wù)人員及時(shí)對(duì)客戶進(jìn)行營銷、提醒等服務(wù)。

流數(shù)據(jù)處理系統(tǒng)主要作為交易系統(tǒng)的延伸，通過對(duì)交易數(shù)據(jù)的采集、存儲(chǔ)、計(jì)算、分發(fā)、持久化等環(huán)節(jié)的快速處理，承擔(dān)交易過程中涉及的風(fēng)險(xiǎn)控制、增值類數(shù)據(jù)加工處理服務(wù)，為客戶營銷、風(fēng)險(xiǎn)監(jiān)控、客戶服務(wù)等業(yè)務(wù)系統(tǒng)提供異步準(zhǔn)實(shí)時(shí)交易信息處理和推送服務(wù)。

通常流數(shù)據(jù)處理系統(tǒng)提供兩種不同的服務(wù)方式，一種是逐筆對(duì)交易信息進(jìn)行處理的“流式”服務(wù)模式，另一種是一次性對(duì)一批交易信息進(jìn)行處理的準(zhǔn)實(shí)時(shí)批量服務(wù)模式。兩種服務(wù)模式具體的處理模式、技術(shù)特點(diǎn)、時(shí)效、設(shè)備資源和服務(wù)領(lǐng)域見表12.1。

(1)“流式”服務(wù)模式這種模式需要逐筆對(duì)交易報(bào)文進(jìn)行處理，經(jīng)過規(guī)則計(jì)算，并以聯(lián)機(jī)報(bào)文的方式對(duì)外提供服務(wù)。此類服務(wù)模式適用于對(duì)時(shí)效要求非常高（秒級(jí)響應(yīng)）的業(yè)務(wù)功能，典型的應(yīng)用場(chǎng)景包括：余額提醒、商戶圈信息推送、信用卡交易監(jiān)控（反欺詐）信息篩選、柜面客戶大額資金變動(dòng)后的觸點(diǎn)式營銷等。

(2)準(zhǔn)實(shí)時(shí)批量服務(wù)模式這種模式是對(duì)一段時(shí)間內(nèi)發(fā)生的一批交易報(bào)文進(jìn)行統(tǒng)一的處理，通過Spark將存儲(chǔ)在HDFS中的信息抽取出來進(jìn)行統(tǒng)一計(jì)算，主要以批量文件的方式對(duì)外提供服務(wù)。此類服務(wù)模式適用于分鐘級(jí)響應(yīng)的業(yè)務(wù)功能，典型的場(chǎng)景包括：客戶購買理財(cái)產(chǎn)品后營銷信息推送、大額資金流轉(zhuǎn)至第三方存管的營銷、風(fēng)險(xiǎn)監(jiān)控（分鐘級(jí)時(shí)效）、交易監(jiān)控統(tǒng)計(jì)、分行特色銷售統(tǒng)計(jì)等。

表12-1  兩種服務(wù)模式的比較