RocketMQ共0篇 第2页
RocketMQ
排序
22.RocketMQ之NameServer启动流程
NameServerController启动流程总览 启动类：org.apache.rocketmq.namesrv.NamesrvStartup#main public static void main(String[] args) { main0(args); } public static NamesrvController mai...
2年前RocketMQ 5.1.0 源码详解 | Producer 启动流程
初始化DefaultMQProducer实例 初始化一个 DefaultMQProducer 对象的代码如下 // 返回一个producer对象 DefaultMQProducer producer = new DefaultMQProducer(); // 设置组名 producer.setProduc...
2年前20.消息积压与处理消息积压
业务场景： 在一个系统中，由生产者系统和消费者系统两个环节组成，生产者系统不停的把消息写入RocketMQ里去，然后消费者系统就负责从RocketMQ里消费消息。 该系统在生产环境的高峰期内，大概有...
2年前
6.RocketMQ-同步消费与异步消费
落花人独立, 微雨燕双飞 一、前言 上篇文档主要给大家介绍了下RocketMQ消费者相关内容，其中提到过消费者底层和Broker进行通信的时候，有两种模式，分别是同步消费和异步消费，不知道大家有没有...
2年前39.Dledger是如何实现主从自动切换的
本文摘自: Dledger是如何实现主从自动切换的 前言 Broker的主从切换是可以基于Dledger实现自动切换的，那么小伙伴们是不是很好奇它究竟是如何实现的呢？今天我们就来聊一聊这个话题。 首先我们...
2年前
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
DefaultMQPushConsumerImpl拉取消息 首先，DefaultMQPushConsumerImpl 是一个实现了 RocketMQ 的消费者客户端接口的类。该类的主要作用是从 RocketMQ 的 Broker 获取消息并进行消费。 主要可以...
2年前
消息队列黄金三剑客：RabbitMQ、RocketMQ和Kafka全面对决，谁是最佳选择？
1、应用场景 1.RabbitMQ： 适用于易用性和灵活性要求较高的场景 异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，...
2年前
23.RocketMQ之NameServer处理Broker心跳包,更新本地路由信息
NameServer处理Broker心跳包,更新本地路由信息 DefaultRequestProcessor继承自NettyRequestProcessor:处理各种客户端的请求，如果请求类型是为REGISTER_BROKER，则将请求转发到RouteInfoManager...
2年前
一次线上事故，我顿悟了异步的精髓
在高并发的场景下，异步是一个极其重要的优化方向。 前段时间，生产环境发生一次事故，笔者认为事故的场景非常具备典型性 。 写这篇文章，笔者想和大家深入探讨该场景的架构优化方案。希望大家...
2年前
【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具
环境准备：Linux安装Java环境（OracleJDK） 在当今分布式架构的开发中，消息队列成为了一种常见的解决方案。RocketMQ是阿里巴巴开源的分布式消息中间件，具有高吞吐量、高可用性和强大的扩展性...
2年前
27.RocketMQ之消费者启动源码
消费者启动 消费者启动示例代码 package com.itheima.mq.rocketmq.base.producer; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client....
2年前19.RocketMQ之消息丢失的场景以及解决方案
如果我们的项目中引入了MQ，势必要面对的一个问题，就是消息丢失问题，今天我们就来聊聊消息是怎么丢失的。 现在假设我们的业务是这样的，用户通过订单系统下了一个订单，订单系统完成支付扣减...
2年前
30.RocketMQ之消费者拉取消息源码
消息拉取概述 消息消费模式有两种模式：广播模式与集群模式。 广播模式比较简单，每一个消费者需要拉取订阅主题下所有队列的消息。本文重点讲解集群模式。 在集群模式下，同一个消费者组内有多...
2年前24.RocketMQ之动态增减NameServer
动态增减NameServer 一个消息队列集群由多台机器组成，持续稳定地提供服务，因为业务需求或硬件故障，经常需要增加或减少各个角色的机器，本节介绍如何在不影响服务稳定性的情况下动态地增减机...
2年前
25.RocketMQ之生产者的启动流程
生产者DefaultMQProducer启动 消息生产者的代码都在client模块中，相对于RocketMQ来讲，消息生产者既是客户端，也是消息的提供者。 下面来看下DefaultMQProducer相关的方法和属性。 DefaultMQPr...
2年前
【Spring Cloud Alibaba】RocketMQ的基础使用，如何发送消息和消费消息
在现代分布式架构的开发中，消息队列扮演着至关重要的角色，用于解耦系统组件、保障可靠性以及实现异步通信。RocketMQ作为一款开源的分布式消息中间件，凭借其高性能、高可用性和良好的扩展性，...
2年前31.RocketMQ之消息拉取长轮询机制分析
消息拉取长轮询机制分析 RocketMQ未真正实现消息推模式，而是消费者主动向消息服务器拉取消息，RocketMQ推模式是循环向消息服务端发起消息拉取请求，如果消息消费者向RocketMQ拉取消息时，消息...
2年前
【RocketMQ】消息的存储总结
当Broker收到生产者的消息发送请求时，会对请求进行处理，从请求中解析发送的消息数据，接下来以单个消息的接收为例，看一下消息的接收过程。 数据校验 封装消息 首先Broker会创建一个MessageEx...
2年前28.RocketMQ之消费者的负载均衡源码
消费者负载均衡流程 当一个业务系统部署多台机器时，每台机器都启动了一个Consumer，并且这些Consumer都在同一个ConsumerGroup也就是在同1个消费组中。此时一个消费组中多个Consumer消费一个Top...
2年前
RocketMQ 5.1.0 源码详解 | Producer 发送流程
初始化DefaultMQProducer实例 详细内容见文章 RocketMQ 5.1.0 源码详解 | Producer 启动流程 第一部分 发送流程 DefaultMQProducer#send 只需要执行以下代码即可开始消息的发送流程 try { Messa...
2年前