handler/im.go

@@ -362,8 +362,7 @@ func ServerSendMsg(c *gin.Context) {
 			if len(msgs) > 0 {
 				msg := msgs[0]
 				//发送消息
-				msg_str, _ := json.Marshal(msg)
-				_, err := c.Writer.Write([]byte("data: " + string(msg_str) + "\n\n"))
+				_, err := c.Writer.Write([]byte("data: " + msg.Msg + "\n\n"))
 				if err != nil {
 					worker.SetRedisWithExpire("user_"+strconv.Itoa(user_id)+"_status_v2", "0", time.Second*3600)
 					break