From f772e16119450bbd32f36fdeb1ebd6e3243e8af9 Mon Sep 17 00:00:00 2001
From: qmqz <qmqz@he-info.cn>
Date: Tue, 3 Feb 2026 16:58:41 +0800
Subject: [PATCH] =?UTF-8?q?mqtt=E6=96=B0=E5=A2=9E=E4=BA=8C=E8=BF=9B?=
 =?UTF-8?q?=E5=88=B6=E6=95=B0=E6=8D=AE=E5=8F=91=E5=B8=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/base/mqtt/mqtt.dart | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/lib/base/mqtt/mqtt.dart b/lib/base/mqtt/mqtt.dart
index e39e43d..b5b664d 100644
--- a/lib/base/mqtt/mqtt.dart
+++ b/lib/base/mqtt/mqtt.dart
@@ -3,6 +3,7 @@ import 'dart:typed_data';
 
 import 'package:mqtt5_client/mqtt5_client.dart';
 import 'package:mqtt5_client/mqtt5_server_client.dart';
+import 'package:typed_data/src/typed_buffer.dart';
 
 class Mqtt {
   final MqttConfig _config;
@@ -125,6 +126,21 @@ class Mqtt {
       return false;
     }
   }
+
+  Future<bool> publishBuff(String topic, Uint8List data, {int qos = 0}) async {
+    try {
+      var payload = MqttPayloadBuilder();
+      // data.buffer
+      payload.addBuffer(Uint8Buffer()..addAll(data));
+
+      _client?.publishMessage(
+          topic, MqttUtilities.getQosLevel(qos), payload.payload!);
+      return true;
+    } catch (e) {
+      print(e);
+      return false;
+    }
+  }
 }
 
 class MqttConfig {