首页 > 其他分享 >RocketMQ

RocketMQ

时间:2023-05-20 22:12:43浏览次数:39  
标签:Producer 宕机 Broker NameServer Consumer RocketMQ

RocketMQ背景是阿里巴巴,经历双11考验,Java语言编写,非常好完整体系

1、支持事务消息(实现解决分页式事务的问题)

2、支持高并发顺序消息处理(采用内存队列+多线程处理)

3、消费者支持tag过滤,减少我们带宽传输

RocketMQ关键核心名称:

NameServer: 存放生产者、消费者、topic信息。去中心化,不需要选举。

Broker负责存储和转发我们的消息

Producer生产者

Consumer消费者

Producer 统计消息给Broker,Broker转发给Consumer进行消费;Producer 需要拿到Broker的地址,(若Broker宕机,在Producer 需要重新连接其它Broker。)所以有了注册中心NameServer。如下图:

 

Broker里多主多备,备同步主节点的数据,当主宕机后,可以从备变为主从而保证高可用。

标签:Producer,宕机,Broker,NameServer,Consumer,RocketMQ
From: https://www.cnblogs.com/liuchunxiao83/p/17417896.html

相关文章

  • RocketMQ 5.0 如何配置TLS加密传输?
    本文作者:李伟,社区里大家叫小伟,ApacheRocketMQCommitter,RocketMQPython客户端项目Owner,ApacheDorisContributor,腾讯云RocketMQ开发工程师。01传输架构图Namesrv:5.1.0Broker:5.1.0Dashboard:1.0.1-SNAPSHOT02准备Namesrv、Broker、Client的ca证书、密钥以下全部操作在......
  • 开源之夏 2023|欢迎报名 Apache RocketMQ 社区项目!
    开源之夏是由中科院软件所“开源软件供应链点亮计划”发起并长期支持的一项暑期开源活动,旨在鼓励在校学生积极参与开源软件的开发维护,培养和发掘更多优秀的开发者,促进优秀开源软件社区的蓬勃发展,助力开源软件供应链建设。参与学生通过远程线上协作方式,配有资深导师指导,参与到开源......
  • RocketMQ源码(三):服务端NameSrv启动流程
    有关Namesrv的概念及功能,详见RocketMQ(三):架构设计中技术架构组成namesrv,这里不再赘述。RocketMQ中Namesrv启动入口:org.apache.rocketmq.namesrv.NamesrvStartup。Namesrv启动,NamesrvStartup#main0()核心伪代码:1publicstaticNamesrvControllermain0(String[......
  • RocketMQ之消息持久化存储源码分析
    一、原理1.1消息存在哪了?消息持久化的地方其实是磁盘上,在如下目录里的commitlog文件夹里。/root/store/commitlog源码如下://{@linkorg.apache.rocketmq.store.config.MessageStoreConfig}//数据存储根目录privateStringstorePathRootDir=System.getProperty("use......
  • docker 部署 RocketMQ
    1.安装nameServer1.搜索镜像dockersearchrocketmq2.拉取镜像dockerpullrocketmqinc/rocketmq 3.创建数据目录mkdir-p/usr/local/software/rocketmq/nameserver/logs/usr/local/software/rocketmq/nameserver/store4.运行docker命令dockerrun-d--r......
  • RocketMQ 在小米的多场景灾备实践案例
    本文作者:邓志文、王帆01为什么要容灾?在小米内部,我们使用RocketMQ来为各种在线业务提供消息队列服务,比如商城订单、短信通知甚至用来收集IoT设备的上报数据,可以说RocketMQ的可用性就是这些在线服务的生命线。作为软件开发者,我们通常希望服务可以按照理想状态去运行:在没有B......
  • Centos环境下部分中间件“rabbitmq、rocketmq、clickhouse”部署
    部分中间件部署目录部分中间件部署docker部署rabbitmqdocker部署rocketmq单机部署clickhousedocker部署rabbitmq#拉镜像dockerpullrabbitmq:3.8-management#启动dockerrun\-eRABBITMQ_DEFAULT_USER=guest\-eRABBITMQ_DEFAULT_PASS=guest\-v/data/rabbitmq/ra......
  • linux之docker安装RocketMQ
    一、创建namesrv容器dockerpullrocketmqinc/rocketmqmkdir-p/docker/rocketmq/data/namesrv/logs/docker/rocketmq/data/namesrv/storedockerrun-d\--restart=always\--namermqnamesrv\-p9876:9876\-v/docker/rocketmq/data/namesrv/logs:/root/lo......
  • 最高等级!Apache RocketMQ 入选可信开源项目星云象限领导型象限
    2023 年4月21日,由中国信通院主办的OSCAR开源生态建设论坛在北京成功召开。本次论坛,中国信通院发布了可信开源项目星云象限。星云象限依托于可信开源项目指数中流行度、参与度、响应度、安全能力和法律合规五个指标,从项目可持续性与可信性两个维度,将可信开源共同体项目分为......
  • RocketMQ源码(一):源码环境搭建
    一、源码地址下载RocketMQ官网下载地址:https://github.com/apache/rocketmq/tags。 当前搭建的是4.8.0版本的rocketmq,下载zip压缩包至本地,并解压。当解压后的RocketMQ源码导入IDEA。   二、源码环境搭建1、启动NameServer1、NameServer启动源码入口......