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-14 21:15:46 +08:00
parent d970f3f177
commit 553b013180
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -36,7 +36,7 @@ public class MessageConsumerService implements RocketMQListener<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);