From 75e48644008e6150d91a8e646bfa737599fa38b7 Mon Sep 17 00:00:00 2001 From: iisky1121 Date: Fri, 29 Apr 2022 14:05:21 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=AD=E6=96=87=E4=B9=B1=E7=A0=81=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/github/quickmsg/common/message/HeapMqttMessage.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/smqtt-common/src/main/java/io/github/quickmsg/common/message/HeapMqttMessage.java b/smqtt-common/src/main/java/io/github/quickmsg/common/message/HeapMqttMessage.java index 2ab22342..70dd593f 100644 --- a/smqtt-common/src/main/java/io/github/quickmsg/common/message/HeapMqttMessage.java +++ b/smqtt-common/src/main/java/io/github/quickmsg/common/message/HeapMqttMessage.java @@ -8,6 +8,7 @@ import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; +import java.nio.charset.Charset; import java.util.HashMap; import java.util.Map; @@ -41,7 +42,7 @@ public class HeapMqttMessage { keys.put("topic", this.topic); keys.put("qos", this.qos); keys.put("retain", this.retain); - keys.put("msg", getJsonObject(new String(message))); + keys.put("msg", getJsonObject(new String(message, Charset.forName("GBK")))); return keys; } -- Gitee