返回
三分钟快速学习RocketMQ核心概念,白话了解RocketMQ基础
后端
2023-09-02 17:00:15
适用场景
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支持队列模型和广播模型,具有高性能、高可靠性、低延迟、可扩展性和易于使用等特性。