统计美化
This commit is contained in:
@@ -5,7 +5,6 @@ import cn.hutool.http.HttpRequest;
|
||||
import cn.van.business.util.WxtsUtil;
|
||||
import com.alibaba.fastjson2.JSONObject;
|
||||
import com.google.common.util.concurrent.RateLimiter;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.apache.rocketmq.spring.annotation.ConsumeMode;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
import org.apache.rocketmq.spring.core.RocketMQListener;
|
||||
@@ -45,6 +44,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
|
||||
@Override
|
||||
public void onMessage(JSONObject message) {
|
||||
try {
|
||||
logger.debug("消费消息:{}", message);
|
||||
//logger.info("[RateLimiter] 开始处理消息,当前时间:{}", System.currentTimeMillis());
|
||||
rateLimiter.acquire();
|
||||
//logger.info("[RateLimiter] 获得令牌,当前时间:{}", System.currentTimeMillis());
|
||||
|
||||
Reference in New Issue
Block a user