【RocketMQ】消息积压判断及解决

2023年5月29日下午10:31 • Java • 阅读 197

一. 定位问题

1. Console入口

&#x4E3B;&#x9898;-->Topic-->Consumer&#x7BA1;&#x7406;-->&#x8BA2;&#x9605;&#x7EC4;

2. 延迟数量（Delay）

&#x6D88;&#x606F;&#x79EF;&#x538B;&#x6570;&#x91CF;&#xFF0C;&#x5373;&#x5F53;&#x524D;Topic&#x8FD8;&#x5269;&#x4E0B;&#x591A;&#x5C11;&#x6D88;&#x606F;&#x672A;&#x5904;&#x7406;&#xFF0C;&#x8BE5;&#x503C;&#x8D8A;&#x5927;&#xFF0C;&#x8868;&#x793A;&#x79EF;&#x538B;&#x7684;&#x6D88;&#x606F;&#x8D8A;&#x591A;

3. 最后消费时间（LastConsumeTime）

&#x5F53;&#x524D;Topic&#x6D88;&#x606F;&#x6700;&#x540E;&#x88AB;&#x6D88;&#x8D39;&#x7684;&#x65F6;&#x95F4;&#xFF0C;&#x8BE5;&#x503C;&#x8868;&#x793A;&#x6D88;&#x8D39;&#x7AEF;&#x6709;&#x591A;&#x957F;&#x65F6;&#x95F4;&#x672A;&#x62C9;&#x53D6;&#x6D88;&#x606F;&#x8FDB;&#x884C;&#x6D88;&#x8D39;

二. 分析问题

1. 查看rocketmq_client.log日志

grep "do flow control" rocketmq_client.log

&#x5982;&#x679C;&#x51FA;&#x73B0; so do flow control &#x8FD9;&#x6837;&#x7684;&#x65E5;&#x5FD7;&#xFF0C;&#x8BF4;&#x660E;&#x89E6;&#x53D1;&#x4E86;&#x6D88;&#x8D39;&#x9650;&#x6D41;&#xFF0C;&#x539F;&#x56E0;&#x662F;&#xFF1A;&#x6D88;&#x8D39;&#x7AEF;&#x79EF;&#x538B;&#x4E86;&#x6D88;&#x606F;&#xFF0C;&#x5373;&#x6D88;&#x8D39;&#x7AEF;&#x65E0;&#x6CD5;&#x6D88;&#x8D39;&#x5DF2;&#x62C9;&#x53D6;&#x7684;&#x6D88;&#x606F;&#xFF0C;&#x6D88;&#x8D39;&#x7AEF;&#x5728;&#x6CA1;&#x6709;&#x5C06;&#x6D88;&#x606F;&#x5904;&#x7406;&#x5B8C;&#x6210;&#x524D;&#xFF0C;&#x4E0D;&#x4F1A;&#x518D;&#x5411;&#x670D;&#x52A1;&#x7AEF;&#x62C9;&#x53D6;&#x6D88;&#x606F;&#xFF0C;&#x5E76;&#x6253;&#x5370;&#x65E5;&#x5FD7;&#x3002;

2. 消费端业务逻辑

1. &#x6267;&#x884C;&#x4E86;&#x957F;&#x8017;&#x65F6;&#x7684;&#x903B;&#x8F91;&#xFF0C;&#x5BFC;&#x81F4;&#x6D88;&#x606F;&#x5904;&#x7406;&#x5F88;&#x6162;
2. &#x7B2C;&#x4E09;&#x65B9;&#x63A5;&#x53E3;&#x8C03;&#x7528;&#x5F88;&#x6162;&#x6216;&#x8D85;&#x65F6;

三. 解决问题

1. 消费端解决

1. &#x589E;&#x52A0;&#x6D88;&#x8D39;&#x7AEF;&#x7684;&#x6D88;&#x8D39;&#x7EBF;&#x7A0B;&#x6570;&#x6216;&#x589E;&#x52A0;&#x6D88;&#x8D39;&#x8005;&#x6570;&#x91CF;&#xFF0C;&#x63D0;&#x5347;&#x6D88;&#x8D39;&#x80FD;&#x529B;
2. &#x4F18;&#x5316;&#x4EE3;&#x7801;&#x903B;&#x8F91;&#xFF0C;&#x964D;&#x4F4E;&#x6267;&#x884C;&#x65F6;&#x95F4;
3. &#x8C03;&#x7528;&#x7B2C;&#x4E09;&#x65B9;&#x63A5;&#x53E3;&#x65F6;&#xFF0C;&#x8BBE;&#x7F6E;&#x8F83;&#x77ED;&#x7684;&#x8D85;&#x65F6;&#x65F6;&#x95F4;&#xFF0C;&#x907F;&#x514D;&#x957F;&#x65F6;&#x95F4;&#x7B49;&#x5F85;&#xFF0C;&#x5FEB;&#x901F;&#x8FD4;&#x56DE;&#x9519;&#x8BEF;&#x4FE1;&#x606F;&#x5E76;&#x544A;&#x8B66;

Original: https://www.cnblogs.com/gossip/p/15325738.html
Author: 扯
Title: 【RocketMQ】消息积压判断及解决

原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/539684/

转载文章受原作者版权保护。转载请注明原作者出处！

Java

【自取】最近整理的，有需要可以领取学习：

Linux核心资料大放送~

全栈面试题汇总（持续更新&可下载）

一个提高学习100%效率的工具！

【超详细】深度学习面试题目！

LeetCode Python刷题答案下载！

LeetCode Java版刷题答案下载！

LeetCode C++ 版本，抓紧保存！

LeetCode GO语言刷题答案下载！

Nacos 本地单机版部署步骤和使用

本系列是 Spring Cloud 微服务实战系列教程。之前在《Spring Cloud Eureka 入门（一）服务注册中心详解》聊过 Spring Cloud Eurek…

Java 2023年6月13日
0090
统计项目的java代码总行数

http://www.oschina.net/code/snippet_209431_7358 wc -l $( find . – type f -name ‘*.java’ ) …

Java 2023年5月29日
0064
Genymotion安卓模拟器和VirtualBox虚拟机安装、配置、测试（win7_64bit）

1.概述 VirtualBox是一个优秀的虚拟机软件，它可以在电脑上提供另一个操作系统的运行环境，使多个系统同时运行。VirtualBox支持的操作系统包括Windows、MacO…

Java 2023年5月29日
00220
windows安装mysql8（5分钟）

1、下载 MySQL https://dev.mysql.com/downloads/mysql/下载完成后，解压缩到你的目录里。 2、配置 MySQL 的配置文件创建一个文件，…

Java 2023年6月9日
0079
C9800配置Session timeout和Idle timeout

对客户端会话时间的修改通常发生在客户端会话超时时。一般客户会话超时，在logging中可以看到类似如下的log YYYY/DD/MM HH:MM:SS.xxx {wncd_x_R0…

Java 2023年5月30日
00108
全链路追踪 & 性能监控工具 SkyWalking 实战

Skywalking介绍 Skywalking是一个国产的开源框架，2015年有吴晟个人开源，2017年加入Apache孵化器，国人开源的产品，主要开发人员来自于华为，2019年4…

Java 2023年6月8日
0071
element-ui el-table 悬停/选中行样式，鼠标样式

/* 用来设置当前页&am…

Java 2023年6月9日
0085
我是虚拟机内核我困惑？！

内核，是指的操作系统内核。所有的操作系统都有内核，无论是Windows还是Linux，都管理着三个重要的资源：计算，网络，存储。计算指CPU和内存，网络即网络设备，存储即硬盘之…

Java 2023年5月30日
0053
String.format的使用

String.format()字符串常规类型格式化的两种重载方式 format(String format, Object… args) 新字符串使用本地语言环境，制定…

Java 2023年5月29日
0066
和朱晔一起复习Java并发（一）：线程池

和我之前的Spring系列文章一样，我们会以做一些Demo做实验的方式来复习一些知识点。本文我们先从Java并发中最最常用的线程池开始。从一个线程池实验开始首先我们写一个方法来…

Java 2023年5月29日
0073
240_Springboot整合rabbitmq集群配置详解

引入starter 详细配置 Spring AMQP的主要对象使用引入starter org.springframework.boot spring-boot-starter-…

Java 2023年6月7日
00111
SpringBoot一个服务按多个端口同时启动

为了模拟集群环境，本地项目一个项目按不同端口多启动，如何配置多个端口同时启动。 1、首先，你得有一个springboot项目，然后点击修改运行配置 2、将你的项目配置的右上角的Al…

Java 2023年5月30日
0066
基于mkcert工具实现Spring Boot 项目服务通过Https方式访问

mkcert(Windows环境) 2.选择版本 3.以管理员身份运行`命令提示符 1) cd C:/ #进入工具存放的目录下 2) mkcert-v1.4.4-windows-a…

Java 2023年6月8日
0085
Nginx配置，413 Request Entity Too Large错误解决

今天有同事找我，说图片上传之后，不知道去哪里了。分析了一下问题，找到原因之后做了处理，这里简要记录一下。问题原因： 1.首先后台log并无错误信息； 2.捡查了一下浏览器，发现n…

Java 2023年5月30日
0076
使用URL快捷方式提高效率

阅文时长 | 0.9分钟字数统计 | 1453.6字符主要内容 | 1、引言&背景 2、URL格式基本格式介绍 3、附录：Hotkey详细参数 4、拓展：收藏夹中的URL格…

Java 2023年6月5日
0069
【设计模式】Java设计模式-享元模式

Java设计模式 – 享元模式 😄 不断学习才是王道🔥 继续踏上学习之路，学之分享笔记👊 总有一天我也能像各位大佬一样🏆原创作品，更多关注我CSDN: 一个有梦有戏的人…

Java 2023年6月16日
0098

2024 年 5 月
一	二	三	四	五	六	日
		1	2	3	4	5
6	7	8	9	10	11	12
13	14	15	16	17	18	19
20	21	22	23	24	25	26
27	28	29	30	31

【RocketMQ】消息积压判断及解决

1. Console入口

2. 延迟数量（Delay）

3. 最后消费时间（LastConsumeTime）

1. 查看rocketmq_client.log日志

2. 消费端业务逻辑

1. 消费端解决

大家都在看