diff --git a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/MsgBody.java b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/MsgBody.java
index 39c2311..24e2893 100644
--- a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/MsgBody.java
+++ b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/MsgBody.java
@@ -23,7 +23,7 @@ public class MsgBody {
     /**
      * 消息内容
      */
-    private Object mContent;
+    private byte[] mContent;
 
     public MsgBody msgType(int msgType) {
         this.mMsgType = msgType;
@@ -35,7 +35,7 @@ public class MsgBody {
         return this;
     }
 
-    public MsgBody content(Object object) {
+    public MsgBody content(byte[] object) {
         this.mContent = object;
         return this;
     }
@@ -52,7 +52,7 @@ public class MsgBody {
         return mMsgId;
     }
 
-    public Object getContent() {
+    public byte[] getContent() {
         return mContent;
     }
 }
diff --git a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
index 324e613..ec07b65 100644
--- a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
+++ b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
@@ -120,7 +120,7 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
     @Override
     public void sendMsg(String appId, int headerType, MsgBody body, IMogoCloudSocketMsgAckListener listener) {
         Logger.d(TAG, "sendMsg  msgId : " + body.getMsgId());
-        final byte[] pb = convertToPBBytes(body.getMsgType(), body.getContent().toString().getBytes());
+        final byte[] pb = convertToPBBytes(body.getMsgType(), body.getContent());
         SocketClient.getInstance().sendData(appId, MogoCommon.Product.mogoBussiness.getNumber(), pb, headerType, true, body.getMsgId());
         mAckListeners.put(body.getMsgId(), listener);
     }
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
index 4c94ef0..0918bde 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
@@ -188,7 +188,7 @@ public class SocketHandler {
         }
         MsgBody msgBody = new MsgBody();
         msgBody.msgType(msgType);
-        msgBody.content(msg);
+        msgBody.content(msg.getBytes());
         SocketManager.getInstance().sendMsg(mAppId, HEADER_TYPE, msgBody, msgId -> {
             for (IMogoCloudOnMsgListener listener : onMsgListenerList) {
                 if (listener != null) {