Redis
- 項目中用到了隊列l(wèi)push brpop,由于系統(tǒng)使用JDK1.5,為了集中管理,將消息從征信系統(tǒng)推送到RocketMQ的過程需要先將消息推送至Redis,然后再通過應用轉到RocketMQ
- 使用subscribe publish作為訂閱發(fā)布器,主要用作緩存能夠在各個應用系統(tǒng)中能夠及時更新,當A應用修改了其他應用也會跟著修改。
- 作為分布式的緩存,在應用中有些對實時性和一致性要求比較高的,可以只是作為分布式緩存,如計費的計算過程保存。
RocketMQ
- 生產(chǎn)者消息發(fā)布之后,消費者對消息進行處理,有兩種模式,參考文檔http://www.itdecent.cn/p/75badea5ac1e,目前我們生產(chǎn)普通的消息只是使用push模式,監(jiān)聽到有更新,直接消費;計費和異常隊列的處理使用pull模式,可以根據(jù)消息合并或者更好的控制消費進度和消費時間