使用第三方库是 mqtt_client 。
发送数据:
调用的是 MqttClientPayloadBuilder 的 addString 函数,
/// Add a standard Dart string
void addString(String val) {
addUTF16String(val);
}
可以看到采用的是 utf16 编码,所以使用 utf8 编码解析不正确,换成 addUTF8String 函数即可。
接收数据:
调用的是 MqttPublishPayload 的 bytesToStringAsString,换成 Utf8Decoder().convert 即可。
String pt = MqttPublishPayload.bytesToStringAsString(recMess.payload.message);
///换成
String pt = Utf8Decoder().convert(recMess.payload.message);