RocketMQ
【RocketMQ】【源码】延迟消息实现原理
RocketMQ设定了延迟级别可以让消息延迟消费，延迟消息会使用SCHEDULE_TOPIC_XXXX这个主题，每个延迟等级对应一个消息队列，并且与普通消息一样，会保存每个消息队列的消费进度（delayOffset.json中的offsetTable）： public class MessageSt ......
springboot整合rocketMQ——消费者
依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi ......
springboot整合rocketMQ——生产者
依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi ......
RocketMQ 系列(五）高可用与负载均衡
RocketMQ 系列(五）高可用与负载均衡 RocketMQ 前面系列文章如下： RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 系列(四) 消息存储 上一篇讲了 RocketMQ 的消息存储 ......
RabbitMQ、RocketMQ和Kafka的不同之处
RabbitMQ、RocketMQ和Kafka是三种常见的消息队列系统，它们在设计和使用方面有一些不同之处： 架构设计： RabbitMQ：RabbitMQ是一个基于AMQP（高级消息队列协议）的开源消息队列系统，采用的是传统的Broker架构模式，其中包括生产者、消费者和中间件（Broker）。 ......
RocketMQ 系列(四) 消息存储
RocketMQ 系列(四) 消息存储 本文是 RocketMQ 系列的第四篇，下面是前面几篇的文章，不清楚的话点击看一下吧。 RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 作为一款优秀的分布 ......
RocketMQ源码(五)：RocketMQ消息存储流程
在RocketMQ源码(四)：RocketMQ生产者发送消息流程中已经对生产者同步发送消息的源码做了分析，下面继续分析，消息发送到Broker做了哪些处理。 一、Broker处理请求消息的入口 在RocketMQ源码(三)：RocketMQ服务端启动流程中提到，在启动BrokerControler流 ......
【RocketMQ】消息的拉取总结
在上一讲中，介绍了消息的存储，生产者向Broker发送消息之后，数据会写入到CommitLog中，这一讲，就来看一下消费者是如何从Broker拉取消息的。 RocketMQ消息的消费以组为单位，有两种消费模式： 广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。 ......
RocketMQ 入门实战(3)--Admin Tool 介绍
本文主要介绍 RocketMQ 管理工具(mqadmin)的使用，文中所使用到的软件版本：RocketMQ 5.1.3、CentOS 7.9.2009。 1、mqadmin 说明 A、执行命令方法：./mqadmin {command} {args}B、几乎所有命令都需要配置 -n 表示 NameS ......
docker安装rocketmq
docker pull rocketmqinc/rocketmq mkdir -p /mydata/rocketmq/data/namesrv/logs /mydata/rocketmq/data/namesrv/store docker run -d \ --restart=always \ -- ......
RocketMQ 系列(三) 集成 SpringBoot
## RocketMQ 系列(三) 集成 SpringBoot 前两篇文章介绍了 RocketMQ 基本概念与搭建，现在以它与 SpringBoot 的结合来介绍其基本的用法。 - [RocketMQ系列(一) 基本介绍 ](https://www.cnblogs.com/CF1314/p/1766 ......
Linux rocketmq单机测试部署
一.环境说明对于 RocketMQ 4.3.0版本，官方要求环境如下，其中 Git 用于从 GitHub 获取源码，没有安装也没关系，可以直接下载推荐的流程是：Linux 系统上安装 Git 工具 、Maven、Java JDKGit 工具用于直接从 GitHub 获取 RocketMQ 项目源码下 ......
rocketmq的转发模型
1.模型 2.消息模型 RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际 部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消 ......
新建rocketmq环境-单机版
1.下载版本 2.解压 unzip 3.配置环境变量 export ROCKETMQ_HOME=/opt/software/rocketmq-all-4.9.1-bin-release export PATH=$PATH:$ROCKETMQ_HOME/bin 4.nameserver服务的创建 修改 ......
RocketMQ 系列(二) 环境搭建
## RocketMQ 系列(二) 环境搭建 上一个章节对于 RocketMQ 作了一些概念上的介绍，如果你对于 RocketMQ 没有概念，不妨先看[RocketMQ系列(一) 基本介绍](https://www.cnblogs.com/CF1314/p/17662969.html)。 这个章节主 ......
在.NET Framework中使用RocketMQ（阿里云版）实战【第二章】
上一章节主要介绍了RocketMQ基本介绍和前期准备，以及如何创建生产者。那这一章节主要介绍一下消费端的实现、如何发布消费端，以及遇到的坑怎么去解决。 ......
Apache RocketMQ 5.0 消息进阶：如何支撑复杂的业务消息场景？
首先来看 RocketMQ 的第一个特性-事务消息，事务消息是 RocketMQ 与一致性相关的特性，也是 RocketMQ 有别于其他消息队列的最具区分度的特性。 ......
RocketMQ系列(一) 基本介绍
## RocketMQ系列(一) 基本介绍 ### 1、MQ 作用 MQ 的应用场景主要包含以下 3 个方面： #### 1.1、异步与解耦 当我们下了一个订单之后，订单服务会进行 RPC 同步调用 支付服务、库存服务、物流服务等，那么服务之间就会有耦合性，耦合性越高的话，容错性就越低，比如我们的支 ......
在.NET Framework中使用RocketMQ（阿里云版）实战【第一章】
在开发某一个需求的时候，领导要求使用RocketMQ(阿里云版) 作为消息队列。生产者主要有WebAPI/MVC/JOB(控制台应用程序)，然后消费者采用的是Windows服务。那[西瓜程序猿]来记录一下如何使用RocketMQ(阿里云版)，给各位小伙伴作为参考防止踩坑。 ......
安装 rocketmq dashboard
安装 rocketmq dashboard 可以帮助查看rocketmq中消息消费情况。 https://github.com/apache/rocketmq-dashboard 下载代码后，进入下载目录 打包： mvn clean package -Dmaven.test.skip=true 运行 ......
Apache Dubbo 和 Apache RocketMQ 邀您参与，ASF 亚洲峰会 5 张门票免费送
今年，CommunityOverCode Asia 2023 将是阿帕奇亚洲大会的首次线下会议，北京，8 月 18 日至 20 日。会议将持续 3 天，设有 17 个论坛方向，共收集到 150 余个议题投稿，其中中文议题约 110 个，英文议题近 40 个。 ......
k8s部署rocketmq
分别部署rocketmqnamesrv、rocketmqbroker、rocketmq-dashboard三个。 1、部署rocketmqnamesrv 部署时，rocketmq的日志存储采用hostPath方式挂载到服务器磁盘上，所以需要指定node节点。 apiVersion: apps/v1 ......
【RocketMQ】消息的存储总结
当Broker收到生产者的消息发送请求时，会对请求进行处理，从请求中解析发送的消息数据，接下来以单个消息的接收为例，看一下消息的接收过程。 ## 数据校验 ### 封装消息 首先Broker会创建一个`MessageExtBrokerInner`对象封装从请求中解析到的消息数据，它会将Topic信息 ......
RocketMQ源码(四)：RocketMQ生产者发送消息流程
RocketMQ通过Producer发送消息，以同步方式发送普通消息为例，分析发送消息的整体流程。Producer的示例代码如下： 1 import org.apache.rocketmq.client.producer.DefaultMQProducer; 2 import org.apache. ......
第七章 Rocketmq--消息驱动
7.1 MQ简介 7.1.1 什么是MQ MQ（Message Queue）是一种跨进程的通信机制，用于传递消息。通俗点说，就是一个先进先出的数据结构。 7.1.2 MQ的应用场景 7.1.2.1 异步解耦 此架构下注册、邮件、短信三个任务全部完成后，才返回注册结果到客户端，用户才能使用账号登录。但 ......
RocketMQ 5.0 架构解析：如何基于云原生架构支撑多元化场景
*作者：隆基* 本文将从技术角度了解 RocketMQ 的云原生架构，了解 RocketMQ 如何基于一套统一的架构支撑多元化的场景。 文章主要包含三部分内容。首先介绍 RocketMQ 5.0 的核心概念和架构概览；然后从集群角度出发，从宏观视角学习 RocketMQ 的管控链路、数据链路、客户端 ......
RocketMQ 介绍
RocketMQ是一种开源的分布式消息中间件，由阿里巴巴集团开发和维护。它是一种高性能、可靠性强的消息队列系统，用于在分布式系统中进行异步通信和解耦。它具有高吞吐量、低延迟、高可靠性和可扩展性的特点，被广泛应用于大规模分布式系统中的消息通信和异步处理场景。 RocketMQ采用了主题（Topic）和 ......
SpringBoot3集成RocketMq
RocketMQ因其架构简单、业务功能丰富、具备极强可扩展性等特点被广泛应用，比如金融业务、互联网、大数据、物联网等领域的业务场景； ......
RocketMQ重置消费位点
>RocketMQ 4.9.4 ### 重置功能 在RocketMQ Dashboard的主题界面，提供了两个功能 - 重置消费位点，按照时间戳重置指定消费者组的消费位点，会按照时间戳找到最接近的消息位点，RocketMQ在存储消息时会记录消息的存入时间。 - 跳过堆积，直接跳到最大消费位点。 ## ......
【RocketMQ】MQ消息发送总结
RocketMQ是通过`DefaultMQProducer`进行消息发送的，它实现了`MQProducer`接口，`MQProducer`接口中定义了消息发送的方法，方法主要分为三大类： 1. `send`同步进行消息发送，向Broker发送消息之后等待响应结果； 2. `send`异步进行消息发送 ......