RocketMQ共0篇
RocketMQ
排序
【RocketMQ】消息的存储总结
当Broker收到生产者的消息发送请求时，会对请求进行处理，从请求中解析发送的消息数据，接下来以单个消息的接收为例，看一下消息的接收过程。 数据校验 封装消息 首先Broker会创建一个MessageEx...
2年前
SpringBoot3集成RocketMq
标签：RocketMq5.Dashboard； 一、简介 RocketMQ因其架构简单、业务功能丰富、具备极强可扩展性等特点被广泛应用，比如金融业务、互联网、大数据、物联网等领域的业务场景； 二、环境部署 1、编...
2年前
【RocketMQ】MQ消息发送总结
RocketMQ是通过DefaultMQProducer进行消息发送的，它实现了MQProducer接口，MQProducer接口中定义了消息发送的方法，方法主要分为三大类： send同步进行消息发送，向Broker发送消息之后等待响应...
2年前
RocketMQ4源码（四）生产者特性
前言 本章基于rocketmq4.6.0，分析两个生产者特性：延迟消息和事务消息。 一、延迟消息 案例 延迟消息的生产和消费，对于Producer和Consumer实例并没有特殊的操作。 仅仅通过设置Message延迟级...
2年前
【Spring Cloud Alibaba】RocketMQ的基础使用，如何发送消息和消费消息
在现代分布式架构的开发中，消息队列扮演着至关重要的角色，用于解耦系统组件、保障可靠性以及实现异步通信。RocketMQ作为一款开源的分布式消息中间件，凭借其高性能、高可用性和良好的扩展性，...
2年前
RocketMQ 5.1.0 源码详解 | Producer 发送流程
初始化DefaultMQProducer实例 详细内容见文章 RocketMQ 5.1.0 源码详解 | Producer 启动流程 第一部分 发送流程 DefaultMQProducer#send 只需要执行以下代码即可开始消息的发送流程 try { Messa...
2年前【RocketMQ】消息的发送
RocketMQ是通过DefaultMQProducer进行消息发送的，它实现了MQProducer接口，MQProducer接口中定义了消息发送的方法，方法主要分为三大类： send同步进行消息发送，向Broker发送消息之后等待响应...
2年前
【Spring Cloud Alibaba】Linux安装RocketMQ以及RocketMQ Dashboard可视化工具
环境准备：Linux安装Java环境（OracleJDK） 在当今分布式架构的开发中，消息队列成为了一种常见的解决方案。RocketMQ是阿里巴巴开源的分布式消息中间件，具有高吞吐量、高可用性和强大的扩展性...
2年前
RocketMQ4源码（三）普通消息消费
前言 本章基于rocketmq4.6.0分析普通消息消费。 基于最常见的消费模式： 集群消费：MessageModel.CLUSTERING； Push模式：DefaultMQPushConsumer； 并行（非顺序）消费：MessageListenerConcurr...
2年前
RocketMQ Linux单机测试：简易快速部署指南及Dashboard控制台部署
目录简介开始下载增加环境变量修改启动文件jvm大小修改rocketmq配置文件启动快速测试关闭Dashboard下载Dashboard已编译jar包网盘下载启动命令可能遇到的问题写在最后 简介 请注意，本博客仅供初...
2年前
【中间件_RocketMQ_01】Spring Boot 集成 RocketMQ 实现简单的消息发送和消费
本文主要有以下内容： 简单消息的发送 顺序消息的发送 RocketMQTemplate的API介绍 环境搭建： RocketMQ的安装教程：在官网上下载bin文件，解压到本地，并配置环境变量，如下图所示： 在 Spring ...
2年前RocketMQ 5.1.0 源码详解 | Producer 启动流程
初始化DefaultMQProducer实例 初始化一个 DefaultMQProducer 对象的代码如下 // 返回一个producer对象 DefaultMQProducer producer = new DefaultMQProducer(); // 设置组名 producer.setProduc...
2年前
RocketMQ 在业务消息场景的优势详解
作者：隆基 01 消息场景 RocketMQ 5.0 是消息事件流一体的实时数据处理平台，是业务消息领域的事实标准，很多互联网公司在业务消息场景会使用 RocketMQ。 我们反复提到的“消息、业务消息”，指...
2年前
RocketMQ4源码（二）普通消息发送
前言 本章基于rocketmq4.6.0分析普通消息的发送流程，仅涉及producer和broker两个角色。 主要包括： producer侧相关后台任务 producer侧发送消息 broker侧自动创建topic broker侧写消息 broker...
2年前
6.RocketMQ-同步消费与异步消费
落花人独立, 微雨燕双飞 一、前言 上篇文档主要给大家介绍了下RocketMQ消费者相关内容，其中提到过消费者底层和Broker进行通信的时候，有两种模式，分别是同步消费和异步消费，不知道大家有没有...
2年前
RocketMQ 5.0 无状态实时性消费详解
作者：绍舒 背景 RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能，同时还推出了一种全新的客户端类型：SimpleConsumer。 SimpleConsumer 客户端采用了无状态...
2年前
RocketMQ4源码（一）NameServer
前言 本章基于rocketmq4.6.0分析nameserver的实现。 nameserver的基础概念不再赘述，可以参考官网。 本章将分析以下内容： 借nameserver，分析rocketmq-remoting通讯层通用模块 nameserver的kv...
2年前
RocketMQ – producer获取Namesrv地址
抛出几个问题。 第一个是producer是怎么在开始的时候获取namesrv的地址； 第二个是producer获取namesrv的方式有几种； 第三个是produce是怎么刷新namesrv地址的； producer获取namesrv地址 在开...
2年前
MQ黄金三剑客：RabbitMQ、RocketMQ和Kafka深入解密常见问题及功能对比指南？
1、消息丢失问题 RabbitMQ解决消息丢失的问题： RabbitMQ通过消息持久化和消息确认机制来确保消息的可靠传递。生产者可以选择将消息标记为持久化，使得即使在消息队列服务器故障后，消息也能被...
2年前
RocketMQ DLedger 初识
前言 众所周知，作为一个出色的分布式消息中间件，RocketMQ 在全球范围内获得了广泛的应用，那么作为一个分布式消息中间件，最重要的是什么？ 协议？持久化？消息分发实现？高可用？高可靠？ 好...
2年前