RocketMQ高级特性

消息存储

• 存储介质

  • 关系型数据库

  ActiveMQ（默认采用的KahaDB做消息存储）可选用JDBC的方式来做消息持久化，通过简单的xml配置信息即可实现JDBC消息存储。由于，普通关系型数据库（如Mysql）在单表数据量达到千万级别的情况下，其IO读写性能往往会出现瓶颈。在可靠性方面，该种方案非常依赖DB，如果一旦DB出现故障，则MQ的消息就无法落盘存储会导致线上故障。

  • 文件

  目前业界较为常用的几款产品（RocketMQ/Kafka/RabbitMQ）均采用的是消息刷盘至所部署虚拟机/物理机的文件系统来做持久化（刷盘一般可以分为异步刷盘和同步刷盘两种模式）。消息刷盘为消息存储提供了一种高效率、高可靠性和高性能的数据持久化方式。除非部署MQ机器本身或是本地磁盘损坏，否则一般是不会出现无法持久化的故障问题。

• 性能对比

  文件系统 > 关系型数据库DB

实时效果反馈

1.关于消息存储说法错误的是？

A RocketMQ采用磁盘文件存储消息

B 在性能上文件存储方式高于数据库

C 消息有同步刷盘和异步刷盘

D 同步刷盘性能高于异步刷盘

答案

1=>D