CC/Jarvis_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

去除限流

Browse Source
This commit is contained in:
雷欧（林平凡）
2025-04-22 16:44:34 +08:00
parent f62dbbaaa7
commit afafb15d64
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/cn/van/business/mq/MessageConsumerService.java
View File

@@ -30,9 +30,9 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL;
public class MessageConsumerService implements RocketMQListener<JSONObject> { public class MessageConsumerService implements RocketMQListener<JSONObject> {
private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS //private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS
1, // 预热期 5 秒 // 1, // 预热期 5 秒
TimeUnit.SECONDS); // TimeUnit.SECONDS);
private final WxtsUtil wxtsUtil; private final WxtsUtil wxtsUtil;
@@ -47,7 +47,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
try { try {
logger.info("消费消息：{}", message); logger.info("消费消息：{}", message);
//logger.info("[RateLimiter] 开始处理消息，当前时间：{}", System.currentTimeMillis()); //logger.info("[RateLimiter] 开始处理消息，当前时间：{}", System.currentTimeMillis());
rateLimiter.acquire(); //rateLimiter.acquire();
//logger.info("[RateLimiter] 获得令牌，当前时间：{}", System.currentTimeMillis()); //logger.info("[RateLimiter] 获得令牌，当前时间：{}", System.currentTimeMillis());