当前位置: 首页 > article >正文

Rocket架构

NameServer:作为注册中心,提供路由注册、路由踢出、路由发现功能,舍弃强一致,保证高可用,集群中各个节点不会实时通讯,其中一个节点下线之后,会提供另外一个节点保证路由功能。

Rocket mq namesrv源码分析-CSDN博客

Broker:消息中转角色,负责存储消息、转发消息。Broker服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。Broker服务器也存储消息相关的元数据,包括消费者组、消费进度偏移和主题和队列消息等。

Producer:负责生产消息,一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到Broker服务器。RocketMQ提供多种发送方式,同步发送、异步发送、顺序发送、单向发送。同步和异步方式均需要Broker返回确认信息,单向发送不需要。

Consumer:负责消费消息,一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式:拉取式消费、推动式消费。

Topic:表示一类消息的集合,每个Topic包含若干条消息,每条消息只能属于一个Topic,是RocketMQ进行消息订阅的基本单位。一个Topic可以分片在多个Broker集群上,每一个Topic分片包含多个queue


http://www.kler.cn/a/146640.html

相关文章:

  • 迅翼SwiftWing | ROS 固定翼开源仿真平台正式发布!
  • Stein算法
  • JVM之垃圾回收器ZGC概述以及垃圾回收器总结的详细解析
  • 怎么实现Redis的高可用?
  • ip属地是根据手机号还是位置
  • 接口测试Day09-数据库工具类封装
  • C语言--每日选择题--Day24
  • 什么是steam红锁,如何防止steam账号红锁
  • 97、Text2NeRF: Text-Driven 3D Scene Generation with Neural Radiance Fields
  • 3.数据结构
  • React 入门使用 (官方文档向 Part2)
  • 【unity实战】实现一个放置3d物品建造装修系统(附项目源码)
  • 复亚智能交通无人机:智慧交通解决方案大公开
  • 微信小程序内部跳到外部小程序
  • Java EE 进程线程
  • 如何往excel中写子表?
  • 【SA8295P 源码分析】134 - Android 侧 NFS Client 挂载 QNX NFS Server 目录不成功 问题排查方法
  • 鸿蒙开发-ArkTS 语言-循环渲染
  • Golang 设置运行的cpu数与channel管道
  • python生成邀请码,手机验证码
  • uniapp (vue3)生成二维码
  • 这回稳了,4G低功耗摄像头实现全景拍照解决方案来了
  • Linux shell编程学习笔记30:打造彩色的选项菜单
  • 【Proteus仿真】【STM32单片机】感应水龙头设计
  • 枚举 组合数 P3799 妖梦拼木棒
  • MySQL--锁