RocketMQ--MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy

2023-10-27 22:30
文章标签 code rocketmq queue clean busy broker timeout desc mqbrokerexception

本文主要是介绍RocketMQ--MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

分析业务日志发现：每天4点左右会报少量的”[TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 206ms, size of queue: 5“错误

Broker设置每天自动清理文件的时间是4点中，和Timeout时间比较吻合 ，那么问题可能就是因为清理文件造成IO突增，导致写数据超时；

修改如下配置：

sendMessageThreadPoolNums=64
useReentrantLockWhenPutMessage=true
waitTimeMillsInSendQueue=600

并部署了3:30~4:30之间的nmon监控，后续分析下nmon监控是否有IO、Cpu等资源的突增。

这篇关于RocketMQ--MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/288831。

相关文章

字节面试 | 如何测试RocketMQ、RocketMQ？

字节面试 | 如何测试RocketMQ、RocketMQ？

字节面试：RocketMQ是怎么测试的呢？ 答： 首先保证消息的消费正确、设计逆向用例，在验证消息内容为空等情况时的消费正确性； 推送大批量MQ，通过Admin控制台查看MQ消费的情况，是否出现消费假死、TPS是否正常等等问题。（上述都是临场发挥，但是RocketMQ真正的测试点，还真的需要探讨） 01 先了解RocketMQ 作为测试也是要简单了解RocketMQ。简单来说，就是一个分
阅读更多...
C++——stack、queue的实现及deque的介绍

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现
阅读更多...
ActiveMQ—Queue与Topic区别

ActiveMQ—Queue与Topic区别

Queue与Topic区别 转自：http://blog.csdn.net/qq_21033663/article/details/52458305 队列（Queue）和主题（Topic）是JMS支持的两种消息传递模型：         1、点对点（point-to-point，简称PTP）Queue消息传递模型：         通过该消息传递模型，一个应用程序（即消息生产者）可以
阅读更多...
【Rocketmq入门-基本概念】

【Rocketmq入门-基本概念】

Rocketmq入门-基本概念 名词解释名称服务器(NameServer)消息队列(Message Queue)主题(Topic)标签(Tag)生产者(Producer)消费者(Consumer)拉取模式(Pull)推送模式(Push)消息模型(Message Model) 关键组件Broker消息存储工作流程 名词解释 名称服务器(NameServer) 定义: 名称服务器
阅读更多...
Debugging Lua Project created in Cocos Code IDE creates “Waiting for debugger to connect” in Win-7

Debugging Lua Project created in Cocos Code IDE creates “Waiting for debugger to connect” in Win-7

转自 I Installed Cocos Code IDE and created a new Lua Project. When Debugging the Project(F11) the game window pops up and gives me the message waiting for debugger to connect and then freezes. Also a
阅读更多...
LLVM入门2：如何基于自己的代码生成IR-LLVM IR code generation实例介绍

LLVM入门2：如何基于自己的代码生成IR-LLVM IR code generation实例介绍

概述 本节将通过一个简单的例子来介绍如何生成llvm IR，以Kaleidoscope IR中的例子为例，我们基于LLVM接口构建一个简单的编译器，实现简单的语句解析并转化为LLVM IR，生成对应的LLVM IR部分，代码如下，文件名为toy.cpp，先给出代码，后面会详细介绍每一步分代码： #include "llvm/ADT/APFloat.h"#include "llvm/ADT/S
阅读更多...
centos7 安装rocketmq4.7.0以及RocketMQ-Console-Ng控制台

centos7 安装rocketmq4.7.0以及RocketMQ-Console-Ng控制台

一、前置工作 1.1安装jdk8 https://blog.csdn.net/pang_ping/article/details/80570011 1.2安装maven https://www.cnblogs.com/116970u/p/11211963.html 1.3安装git https://blog.csdn.net/xwj1992930/article/details/964
阅读更多...
VS Code 调试go程序的相关配置说明

VS Code 调试go程序的相关配置说明

用 VS code 调试Go程序需要在.vscode/launch.json文件中增加如下配置：  // launch.json{// Use IntelliSense to learn about possible attributes.// Hover to view descriptions of existing attributes.// For more information,
阅读更多...
Java-数据结构-栈和队列-Stack和Queue (oﾟ▽ﾟ)o

Java-数据结构-栈和队列-Stack和Queue (oﾟ▽ﾟ)o

文本目录： ❄️一、栈(Stack)：     ▶ 1、栈的概念：   ▶ 2、栈的使用和自实现：      ☑ 1）、Stack():       ☑ 2）、push(E e):      ☑ 3）、empty():         ☑ 4）、peek(E e):        ☑ 5）、pop(E e):       ☑ 6）、size(E e):  ▶ 3、栈自实现的总代
阅读更多...
RocketMQ 介绍

RocketMQ 介绍

前言 消息队列在互联网技术存储方面使用如此广泛，几乎所有的后端技术面试官都要在消息队列的使用和原理方面对小伙伴们进行360°的刁难。 作为一个在互联网公司面一次拿一次Offer的面霸，打败了无数竞争对手，每次都只能看到无数落寞的身影失望的离开，略感愧疚（请允许我使用一下夸张的修辞手法）。 于是在一个寂寞难耐的夜晚，我痛定思痛，决定开始写《吊打面试官》系列，希望能帮助各位读者以后面试势如破竹，
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2