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