1

src/main/java/cn/van/business/mq/MessageConsumerService.java

@@ -4,6 +4,7 @@ import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.http.HttpRequest;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.util.concurrent.RateLimiter;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.slf4j.Logger;
@@ -27,10 +28,13 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
 
     private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
 
+    // create a rate limiter of 1 qps
+    RateLimiter rateLimiter = RateLimiter.create(1.0);
     @Override
     public void onMessage(JSONObject jsonObject) {
         // 处理消息
         try {
+            rateLimiter.acquire(); // 请求许可。如果超过速率，则此方法会阻塞
             logger.info("消费到消息：{}", jsonObject);
             String body = jsonObject.getString("body");
             byte[] decodedBody = Base64.getDecoder().decode(body);