分布式消息服务RocketMQ

消息队列RocketMQ 是一款高吞吐量、高可扩展性的分布式消息服务。在开源RocketMQ基础上进行优化,具有高可靠、低时延、海量堆积能力,提供监控运维功能。用于系统间解耦,用户只需专注业务,无需部署运维,低成本、更弹性和可靠。

产品优势
  • 堆积并发

    支持亿级消息堆积,在海量堆积下队列性能影响很小,并可通过队列数扩展提升整系统并发能力

  • 灵活及时

    队列处理能力按需自动扩展,及时方便完成系统扩展,消息投递时间可至毫秒级,保证消息及时性

  • 高可靠

    集群节点采用主备模式,且具有主备故障自动切换功能;提供对消息的持久化能力,多副本冗余;提供消息数据自动删除功能

  • 运维管理

    提供多维度指标监控(队列级别);消息查询;消息回溯;消息数据过期自动删除

产品功能
  • 访问接口

    支持通过API调用,创建队列、查询消息监控指标、查询消息内容等。


    管理控制台上进行的操作用于主题的创建、查看、运维监控等管理工作。

    支持通过API调用,创建队列、查询消息监控指标、查询消息内容等。


    管理控制台上进行的操作用于主题的创建、查看、运维监控等管理工作。

  • 队列能力

    队列类型


    支持普通队列(高并发场景)、FIFO有序队列(顺序信息场景)、严格有序队列。


    至少一次


    提供“至少一次”的消息交付功能。

    队列类型


    支持普通队列(高并发场景)、FIFO有序队列(顺序信息场景)、严格有序队列。


    至少一次


    提供“至少一次”的消息交付功能。

  • 消息能力

    消息过滤


    根据消息标签对可消费的消息进行过滤。


    消息复用


    通过指定时间或位置,将一次消息被多种消费场景同时消费,进行多次复用。


    广播消息


    在同一个消费组内对所有消费者投递相同消息。


    消息重试


    消费者可以决定将暂不消费的消息重新投递到队列中,延迟消费,最大支持16个延时级别


    事务消息


    支持事务消息,可用于分布式应用


    消息回溯


    支持根据时间重置消费进度


    消息数据自动删除功能


    在磁盘满后,在保护期外的数据,能自动删除,保证服务可用性


    自动主备切换功能


    集群节点采用主备模式,且具有主备故障自动切换功能,自动主备切换保证服务高可用


    消息过滤


    根据消息标签对可消费的消息进行过滤。


    消息复用


    通过指定时间或位置,将一次消息被多种消费场景同时消费,进行多次复用。


    广播消息


    在同一个消费组内对所有消费者投递相同消息。


    消息重试


    消费者可以决定将暂不消费的消息重新投递到队列中,延迟消费,最大支持16个延时级别


    事务消息


    支持事务消息,可用于分布式应用


    消息回溯


    支持根据时间重置消费进度


    消息数据自动删除功能


    在磁盘满后,在保护期外的数据,能自动删除,保证服务可用性


    自动主备切换功能


    集群节点采用主备模式,且具有主备故障自动切换功能,自动主备切换保证服务高可用


  • 安全防护

    可追溯


    提供云审计进行租户管理操作的记录。

    可追溯


    提供云审计进行租户管理操作的记录。

  • 运维监控

    提供主题、订阅组、生产者、消费者、队列的管理;集群、主题、队列多维度指标监控

    提供主题、订阅组、生产者、消费者、队列的管理;集群、主题、队列多维度指标监控

应用场景
  • 分布式系统异步通信
  • 数据同步和交换
  • 削峰填谷
适用场景
在单体应用中,各服务耦合度紧,单个服务出现问题会导致系统对用户请求响应慢,可以进行系统解耦拆分,并用消息队列作为系统间的异步通信通道,提升整个系统的响应速度。
实现功能

加快系统响应

系统分布式解耦,并行处理,加快系统对用户请求的响应速度。

降低系统耦合

系统间通过消息队列通信,避免相互耦合和影响。

数据缓存

消息队列提供亿级消息堆积能力,帮助系统在峰值情况下从容应对。