From 888702297f6ecd45e18e055551c7cbc84e437c16 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=B7=E6=AC=A7=EF=BC=88=E6=9E=97=E5=B9=B3=E5=87=A1?= =?UTF-8?q?=EF=BC=89?= Date: Wed, 22 Jan 2025 16:57:39 +0800 Subject: [PATCH] 1 --- .../java/cn/van/business/mq/MessageConsumerService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 516901a..983fa4b 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -45,18 +45,19 @@ public class MessageConsumerService implements RocketMQListener { // 处理消息 try { rateLimiter.acquire(); // 请求许可。如果超过速率，则此方法会阻塞 - logger.info("消费到消息：{}", jsonObject); String body = jsonObject.getString("body"); byte[] decodedBody = Base64.getDecoder().decode(body); String decodedBodyStr = new String(decodedBody, StandardCharsets.UTF_8); JSONObject decodedBodyJson = JSONObject.parseObject(decodedBodyStr); + String jsonStr = JSONUtil.toJsonStr(decodedBodyJson); String responseStr = HttpRequest.post(WX_BASE_URL) - .body(JSONUtil.toJsonStr(decodedBodyJson)) + .body(jsonStr) .execute() .body(); - + logger.info("消费消息：{}", jsonStr); if (ObjectUtil.isNotEmpty(responseStr)) { JSONObject response = JSONObject.parseObject(responseStr); + logger.info("消息成功发送并得到响应：{}", response); if (response.getInteger("code") != 200) { // TODO: 如果需要处理错误，您可以在这里添加逻辑 wxtsUtil.sendNotify("消息发送失败: " + responseStr);