返回

三分钟快速学习RocketMQ核心概念,白话了解RocketMQ基础

后端

适用场景

RocketMQ是一款高性能、高可靠的消息队列,适用于以下场景:

  • 电商交易 :订单生成、支付成功、发货通知等。
  • 物流系统 :订单状态更新、发货通知、物流信息查询等。
  • 金融系统 :转账通知、支付成功通知等。
  • 社交系统 :消息推送、点赞提醒、评论通知等。
  • 游戏系统 :游戏状态更新、游戏道具交易等。

基本概念

  • 生产者 :发送消息的应用程序或服务。
  • 消费者 :接收消息的应用程序或服务。
  • Broker :存储和转发消息的服务器。
  • Topic :消息的主题,用于对消息进行分类。
  • Message :要发送的消息内容。
  • Pull :消费者主动从Broker拉取消息。
  • Push :Broker主动将消息推送给消费者。

RocketMQ架构

RocketMQ采用主从架构,由Name Server、Broker、Producer和Consumer组成。

  • Name Server :负责管理Broker的地址信息,提供Broker的注册和发现服务。
  • Broker :负责存储和转发消息,提供消息的持久化、可靠性和高可用性。
  • Producer :发送消息的应用程序或服务,将消息发送到Broker。
  • Consumer :接收消息的应用程序或服务,从Broker拉取消息或接收Broker推送的消息。

RocketMQ消息模型

RocketMQ支持两种消息模型:

  • 队列模型 :每条消息只能被一个消费者消费一次。
  • 广播模型 :每条消息可以被多个消费者消费。

RocketMQ特性

RocketMQ具有以下特性:

  • 高性能 :RocketMQ可以处理数百万条消息/秒。
  • 高可靠性 :RocketMQ采用主从架构,保证消息的可靠性。
  • 低延迟 :RocketMQ的消息延迟非常低,通常在毫秒级。
  • 可扩展性 :RocketMQ可以轻松扩展,满足业务的增长需求。
  • 易于使用 :RocketMQ提供友好的API,方便开发者使用。

总结

RocketMQ是一款高性能、高可靠、低延迟、可扩展的消息队列,适用于电商交易、物流系统、金融系统、社交系统、游戏系统等场景。RocketMQ采用主从架构,由Name Server、Broker、Producer和Consumer组成。RocketMQ支持队列模型和广播模型,具有高性能、高可靠性、低延迟、可扩展性和易于使用等特性。