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 2ab22342784775c9b8d3cc01102251df3380543e..70dd593f74aa458182ce18c6744e3cebf5a0a148 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;
     }