- 【RocketMQ】消息的消费总结
消费者从Broker拉取到消息之后，会将消息提交到线程池中进行消费，RocketMQ消息消费是批量进行的，如果一批消息的个数小于预先设置的批量消费大小，直接构建消费请求ConsumeRequest将消费请求提交到线程池处理，否则需要分批构建进行提交。消息消费在消息被提交到线程池后进行处理时，会调......
- RocketMQ 入门实战(4)--Java 操作 RocketMQ
本文主要介绍使用 Java 来操作RocketMQ，文中所使用到的软件版本：Java1.8.0_341、RocketMQ5.1.3、rocketmq-client-java5.0.5。1、引入依赖<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client-java</artifactId><versio......
- 【RocketMQ】【源码】延迟消息实现原理
RocketMQ设定了延迟级别可以让消息延迟消费，延迟消息会使用SCHEDULE_TOPIC_XXXX这个主题，每个延迟等级对应一个消息队列，并且与普通消息一样，会保存每个消息队列的消费进度（delayOffset.json中的offsetTable）：publicclassMessageStoreConfig{privateStringmessageDelayLevel=......
- springboot整合rocketMQ——消费者
依赖<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/......
- Springboot RocketMQ整合—官方原版
Doker 技术人自己的数码品牌Doker官网：Doker多克一、添加maven依赖：<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>${RELEASE.VERSION}</version></dependen......
- RocketMQ-(7-1)-可观测-Metrics
RocketMQ以Prometheus格式公开以下指标。您可以使用这些指标监视您的集群。服务端Metrics指标生产者Metrics指标消费者Metrics指标版本支持：以下指标Metrics是从5.1.0版本开始支持。Metrics指标详情Metrictypes消息队列RocketMQ版定义的Metrics完全兼容开源Prom......
- RocketMQ教程-(6-2)-运维部署-Admin Tool
执⾏命令⽅法：./mqadmin{command}{args}⼏乎所有命令都需要配置-n表⽰NameServer地址，格式为ip:port⼏乎所有命令都可以通过-h获取帮助如果既有Broker地址（-b）配置项又有clusterName（-c）配置项，则优先以Broker地址执⾏命令，如果不配置Broker地址，则对集群中所有主机执⾏命令......
- RocketMQ教程-(5)-功能特性-消费者分类
ApacheRocketMQ支持PushConsumer、SimpleConsumer以及PullConsumer这三种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这三种类型的消费者。背景信息ApacheRocketMQ面向不同的业务场景提供了不同消费者类型，每种消费者类型的集成方式和......
- RocketMQ-(8-1)-EventBridge-EventBridge 核心概念
RocketMQEventBridge核心概念理解EventBridge中的核心概念，能帮助我们更好的分析和使用EventBridge。本文重点介绍下EventBridge中包含的术语：EventSource：事件源。用于管理发送到EventBridge的事件，所有发送到EventBridge中的事件都必须标注事件源名称信息，对应CloudEvent事件体中的s......
- RocketMQ-(9-1)-MQTT-EventBridge概述
RocketMQMQTT概览传统的消息队列MQ主要应用于服务（端）之间的消息通信，比如电商领域的交易消息、支付消息、物流消息等等。然而在消息这个大类下，还有一个非常重要且常见的消息领域，即IoT类终端设备消息。近些年，我们看到随着智能家居、工业互联而兴起的面向IoT设备类的消息正在呈爆炸式......