diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 67ea2af..1cb1b05 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -30,9 +30,9 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL; public class MessageConsumerService implements RocketMQListener { private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); - private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS - 1, // 预热期 5 秒 - TimeUnit.SECONDS); + //private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS + // 1, // 预热期 5 秒 + // TimeUnit.SECONDS); private final WxtsUtil wxtsUtil; @@ -47,7 +47,7 @@ public class MessageConsumerService implements RocketMQListener { try { logger.info("消费消息:{}", message); //logger.info("[RateLimiter] 开始处理消息,当前时间:{}", System.currentTimeMillis()); - rateLimiter.acquire(); + //rateLimiter.acquire(); //logger.info("[RateLimiter] 获得令牌,当前时间:{}", System.currentTimeMillis());