ROCKETMQ [TIMEOUT_CLEAN_QUEUE]b

ROCKETMQ MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy

解决方案:

sendMessageThreadPoolNums=128

useReentrantLockWhenPutMessage=true

以上两种任意一个方式都可以

如果你需要使用大量的线程来处理发送消息,你最好使用useReentrantLockWhenPutMessage = true

useReentrantLockWhenPutMessage默认使用自旋锁  当等于true的时候 使用重入锁ReentrantLock 

rocketmq 4.1.x sendMessageThreadPoolNums默认是1 如果开了多线程来发送消息就会出现broker busy 单个线程怎么发都没事