Redis
- 项目中用到了队列lpush brpop,由于系统使用JDK1.5,为了集中管理,将消息从征信系统推送到RocketMQ的过程需要先将消息推送至Redis,然后再通过应用转到RocketMQ
- 使用subscribe publish作为订阅发布器,主要用作缓存能够在各个应用系统中能够及时更新,当A应用修改了其他应用也会跟着修改。
- 作为分布式的缓存,在应用中有些对实时性和一致性要求比较高的,可以只是作为分布式缓存,如计费的计算过程保存。
RocketMQ
- 生产者消息发布之后,消费者对消息进行处理,有两种模式,参考文档https://www.jianshu.com/p/75badea5ac1e,目前我们生产普通的消息只是使用push模式,监听到有更新,直接消费;计费和异常队列的处理使用pull模式,可以根据消息合并或者更好的控制消费进度和消费时间
网友评论