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`异步进行消息发送 ......