前言 本章基于rocketmq4.6.0分析nameserver的实现。 nameserver的基础概念不再赘述，可以参考官网。 本章将分析以下内容： 借nameserver，分析rocketmq-remoting通讯层通用模块 nameserver的kv...

目录简介开始下载增加环境变量修改启动文件jvm大小修改rocketmq配置文件启动快速测试关闭Dashboard下载Dashboard已编译jar包网盘下载启动命令可能遇到的问题写在最后 简介 请注意，本博客仅供初...

本文正在参加「金石计划 . 瓜分6万现金大奖」  前提概要 大家好，经过了6个月的消失后，终究我还是回来了，带回来了很多干货，接下来第一份礼物干货就是【RocketMQ入门到精通】，但是RocketMQ...

前言 本章基于rocketmq4.6.0，分析两个生产者特性：延迟消息和事务消息。 一、延迟消息 案例 延迟消息的生产和消费，对于Producer和Consumer实例并没有特殊的操作。 仅仅通过设置Message延迟级...

RocketMQ是通过DefaultMQProducer进行消息发送的，它实现了MQProducer接口，MQProducer接口中定义了消息发送的方法，方法主要分为三大类： send同步进行消息发送，向Broker发送消息之后等待响应...

消息重复消费 影响消息正常发送和消费的重要原因是网络的不确定性。 引起重复消费的原因 ACK 正常情况下在consumer真正消费完消息后应该发送ack，通知broker该消息已正常消费，从queue中剔除。...

前言 本章基于rocketmq4.6.0分析普通消息的发送流程，仅涉及producer和broker两个角色。 主要包括： producer侧相关后台任务 producer侧发送消息 broker侧自动创建topic broker侧写消息 broker...

导读 大报文问题，在京东物流内较少出现，但每次出现往往是大事故，甚至导致上下游多个系统故障。大报文的背后，是不同商家业务体量不同，特别是B端业务的采购及销售出库单，一些头部商家对京东...

消息存储文件 rocketMQ的消息持久化在我们在搭建集群时都特意指定的文件存储路径,进入指定的store目录下就可以看到。 下面介绍各文件含义 CommitLog 存储消息的元数据。produce发出的所有消息都...

前言 本章基于rocketmq4.6.0分析普通消息消费。 基于最常见的消费模式： 集群消费：MessageModel.CLUSTERING； Push模式：DefaultMQPushConsumer； 并行（非顺序）消费：MessageListenerConcurr...

前言 RocketMQ目前主要分为4.x和5.x版本，本文基于时间线分析一下每个小版本新增的feature，主要目的： 1）对于RocketMQ的发展有个整体的认知，方便之后源码学习； 2）选个合适的版本进行源码学...

前言 相信用过RocketMq的小伙伴都知道，RocketMq支持延时消息，通过设置指定的延时级别就可以让消息实现不同时效的延时功能，今天带大家了解的就是延时消息的原理~ 如何实现延时？ 在带大家正式...

作者：绍舒 背景 RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能，同时还推出了一种全新的客户端类型：SimpleConsumer。 SimpleConsumer 客户端采用了无状态...

消费消息 PullMessageService负责对消息队列进行消息拉取，从远端服务器拉取消息后将消息存储ProcessQueue消息队列处理队列中，然后调用ConsumeMessageService#submitConsumeRequest方法进行消...

作者：隆基 01 消息场景 RocketMQ 5.0 是消息事件流一体的实时数据处理平台，是业务消息领域的事实标准，很多互联网公司在业务消息场景会使用 RocketMQ。 我们反复提到的“消息、业务消息”，指...

1、消息丢失问题 RabbitMQ解决消息丢失的问题： RabbitMQ通过消息持久化和消息确认机制来确保消息的可靠传递。生产者可以选择将消息标记为持久化，使得即使在消息队列服务器故障后，消息也能被...

rocketmq-console基本使用 作用：rocketmq-console是rocketmq的一款可视化工具，提供了mq的使用详情等功能。 一、安装部署 下载rocketmq组件 rocketmq：下载地址、github地址 下载地址如下图所...

Redis系列1：深刻理解高性能Redis的本质Redis系列2：数据持久化提高可用性Redis系列3：高可用之主从架构Redis系列4：高可用之Sentinel(哨兵模式）Redis系列5：深入分析Cluster 集群模式 追求性...

RocketMQ消息转发模型 消息模型（Message Model） RocketMQ主要由 Producer, Broker, Consumer 三部分组成, 其中Producer 负责生产消息, Consumer 负责消费消息, Broker 负责存储消息. Broker ...