最近对系统进行压测，发现发送消息到消息队列的时候出现如下错误：

com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 2  DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 201ms, size of queue: 1

经查询发现RocketMq在4.1版本以后为producer增加了2个配置, 默认配置这两个参数分别是1和false，将他们配置成 64 和true，就能解决问题

#发送消息的最大线程数

sendMessageThreadPoolNums: 64  #large thread numbers

#发送消息是否使用可重入锁

useReentrantLockWhenPutMessage: true

该配置可以在spring配置中设置，也可以在RocketMq集群机器上配置

如果还是会出现此问题，就需要调整RocketMq集群机器配置：

waitTimeMillsInSendQueue  =   #或者更大

然后重启集群

最新文章

1. 从零开始，DIY一个jQuery（2）
2. android之Handler机制
3. QML Image: Cannot open: qrc:///new.pic.png
4. WinForm------给GridControl添加搜索功能
5. ubuntu： qemu+gdb 调试linux kernel 学习笔记
6. Android 播放视频并获取指定时间的帧画面
7. 我的网站终于连续一星期，ip数1000以上了
8. 【LeetCode练习题】Add Two Numbers
9. lPC1788的串口通讯
10. jest for elasticsearch
11. JS字符串和数组常用方法
12. PHPCMS v9.5.6 通杀getshell(前台)
13. 作为程序员必须掌握的Java虚拟机中的22个重难点
14. ssh 使用 sed 替换的时候，替换的字符串有单双引号的时候怎么用
15. Bitmap too larget to be uploaded into a texture的解决方法
16. 统计Mongo数组中相同对象的属性之和
17. 输入控件tagsinput
18. c++ primer plus 第四章 课后题答案
19. R读取excel文件
20. 洛谷P3648 [APIO2014]序列分割（斜率优化）

热门文章

1. 自定义class类的简单使用
2. （二）jdk8学习心得之Lambda表达式
3. TOMCAT原理详解及请求过程（转载）
4. Python openpyxl ： Excel 文档简单操作
5. git常用命令一、git cherry-pick
6. java篇 之 类型转化
7. vue打包静态资源路径不正确的解决办法【转】
8. 多线程threading
9. 常见的概率分布类型（Probability Distribution）
10. Ticwatch2_3G版省电优化