什么是RocketMQ?

是一个低延迟、高并发、高可用、高可靠的分布式消息中间件。RocketMQ既可为分布式应用系统提供异步解耦和削锋填谷的能力，同时也具备互联网所需的海量消息堆积、高吞吐、可靠重试等特性。

核心概念

  • Topic 主题
  • 生产者
  • 消息者
  • 消息
  • 消息属性

  • Group

    应用场景

  • 削峰填谷

秒杀、抢红包等

  • 异步解耦
  • 顺序收发 FIFO
  • 分布式事务一致性

交易系统、支付红包等

  • 大数据分析

与流式计算引擎结合，可以很方便地实现将业务数据实时分析

  • 分布式缓存同步

    消息类型

  • 普通消息

    • 同步发送 一个消息在服务端响应后才发下一条
    • 异步发送 不等服务端响应就可以发下一条，响应结果在回调函数执行
    • 单向发送 只发消息 不等服务器响应也没有回调函数
  • 延时消息 createSheduleProducer
  • 顺序消息
  • 事务消息