feat: mqtt 消息通过 websocket 发送到不同的组

mqtt/mqtt.py

@@ -8,10 +8,10 @@ from .signals import mqtt_message_received
 from channels.layers import get_channel_layer, channel_layers
 from asgiref.sync import async_to_sync
 
-def send_websocket_message(message):
+def send_websocket_message(message, group_name="chat_mqtt"):
     channel_layer = get_channel_layer()
     async_to_sync(channel_layer.group_send)(
-        "chat_mqtt",
+        group_name,
         {"type": "chat.message", "message": message}
     )
 
@@ -30,7 +30,7 @@ def on_message(mqtt_client, userdata, msg):
     # 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 = msg.payload
+    data = msg.payload.decode('utf-8')
     send_websocket_message(data)