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

1

Browse Source
This commit is contained in:
cc
2024-12-09 10:23:27 +08:00
parent c59e7c398a
commit 4ffead8554
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -14,6 +14,7 @@ import org.springframework.stereotype.Service;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.Base64; import java.util.Base64;
import static cn.hutool.core.thread.ThreadUtil.sleep;
import static cn.van.business.util.WXUtil.WX_BASE_URL; import static cn.van.business.util.WXUtil.WX_BASE_URL;
/** /**
@@ -29,13 +30,13 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
// create a rate limiter of 1 qps // create a rate limiter of 1 qps
RateLimiter rateLimiter = RateLimiter.create(1.0); RateLimiter rateLimiter = RateLimiter.create(0.5);
@Override @Override
public void onMessage(JSONObject jsonObject) { public void onMessage(JSONObject jsonObject) {
// 处理消息 // 处理消息
try { try {
rateLimiter.acquire(); // 请求许可。如果超过速率，则此方法会阻塞 rateLimiter.acquire(); // 请求许可。如果超过速率，则此方法会阻塞
//logger.info("消费到消息：{}", jsonObject); logger.info("消费到消息：{}", jsonObject);
String body = jsonObject.getString("body"); String body = jsonObject.getString("body");
byte[] decodedBody = Base64.getDecoder().decode(body); byte[] decodedBody = Base64.getDecoder().decode(body);
String decodedBodyStr = new String(decodedBody, StandardCharsets.UTF_8); String decodedBodyStr = new String(decodedBody, StandardCharsets.UTF_8);