From eccdf12b8ed4560487a0b6995a5bc482f775a6a1 Mon Sep 17 00:00:00 2001 From: Odboy Date: Sat, 21 Feb 2026 21:29:11 +0800 Subject: [PATCH] =?UTF-8?q?fix(redis):=20=E7=A7=BB=E9=99=A4=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E4=B8=AD=E7=9A=84JSON=E5=BA=8F=E5=88=97=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/odboy/framework/redis/DemoMessageSubscriber.java | 2 +- .../java/cn/odboy/framework/websocket/WsMessageSubscriber.java | 2 +- .../java/cn/odboy/framework/redis/DemoMessageSubscriber.java | 2 +- .../java/cn/odboy/framework/websocket/WsMessageSubscriber.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java index e9a8646e..1c0c6663 100644 --- a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java +++ b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java @@ -29,6 +29,6 @@ import org.springframework.stereotype.Component; public class DemoMessageSubscriber { public void onMessage(String message, String channel) { - log.info("收到来自redis消息队列的message={}, channel={}", JSON.toJSONString(message), channel); + log.info("收到来自redis消息队列的message={}, channel={}", message, channel); } } diff --git a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java index 6f755ed8..a476c586 100644 --- a/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java +++ b/cutejava-springboot3/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java @@ -44,7 +44,7 @@ public class WsMessageSubscriber { // } public void onMessage(String message, String channel) { - log.info("收到来自redis消息队列的message={}, channel={}", JSON.toJSONString(message), channel); + log.info("收到来自redis消息队列的message={}, channel={}", message, channel); KitWsMessage wsMessage = JSON.parseObject(message, KitWsMessage.class); kitWsServer.sendMessage(wsMessage.getData().getMessage(), wsMessage.getData().getToUser()); } diff --git a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java index e9a8646e..1c0c6663 100644 --- a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java +++ b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/redis/DemoMessageSubscriber.java @@ -29,6 +29,6 @@ import org.springframework.stereotype.Component; public class DemoMessageSubscriber { public void onMessage(String message, String channel) { - log.info("收到来自redis消息队列的message={}, channel={}", JSON.toJSONString(message), channel); + log.info("收到来自redis消息队列的message={}, channel={}", message, channel); } } diff --git a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java index 6f755ed8..a476c586 100644 --- a/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java +++ b/cutejava/cutejava-framework/src/main/java/cn/odboy/framework/websocket/WsMessageSubscriber.java @@ -44,7 +44,7 @@ public class WsMessageSubscriber { // } public void onMessage(String message, String channel) { - log.info("收到来自redis消息队列的message={}, channel={}", JSON.toJSONString(message), channel); + log.info("收到来自redis消息队列的message={}, channel={}", message, channel); KitWsMessage wsMessage = JSON.parseObject(message, KitWsMessage.class); kitWsServer.sendMessage(wsMessage.getData().getMessage(), wsMessage.getData().getToUser()); }