feat: 发送字节流

chat/consumers.py

@@ -76,6 +76,6 @@ class ChatConsumer(AsyncWebsocketConsumer):
 
         # Send message to WebSocket
         # await self.send(text_data=json.dumps({"message": message}))
-        await self.send(text_data=message)
+        await self.send(bytes_data=message)
 
 

mqtt/mqtt.py

@@ -29,7 +29,8 @@ def on_message(mqtt_client, userdata, msg):
     # 接收mqtt消息的代码 
     # mqtt_message_received.send(sender=None, message=msg.payload)
     # print(f'Received message on topic: {msg.topic} with payload: {msg.payload}')
-    data = parse_proto(msg.payload)
+    # data = parse_proto(msg.payload)
+    data = msg.payload
     send_websocket_message(data)