Before Creating the Bug Report
Runtime platform environment
无
RocketMQ version
5.0 develop分支
JDK Version
No response
Describe the Bug
org.apache.rocketmq.store.timer.TimerMessageStore#isReject
if (RANDOM.nextInt(1000) > 1000 * (congestNum - storeConfig.getTimerCongestNumEachSlot()) / (storeConfig.getTimerCongestNumEachSlot() + 0.1)) {
return true;
}
这里的逻辑是否取反,return true 表示拒绝,
假设左边随机数固定,右边congestNum 越大 总体值不是越大,这样就拦截不了。
Steps to Reproduce
无
What Did You Expect to See?
无
What Did You See Instead?
无
Additional Context
No response