Flutter中mqtt_client订阅韩文主题及接收消息异常求助

API 探路者

2026-8-22

解决方案：Flutter MQTT韩文主题订阅与消息乱码问题

问题1：订阅韩文主题导致客户端崩溃

原因分析

mqtt_client: ^9.6.8版本对非ASCII（如韩文）主题的UTF-8编码处理存在bug，发送的主题字节不符合MQTT协议规范，触发服务器断开连接，进而引发客户端内部锁资源异常导致崩溃。

解决步骤

升级mqtt_client版本：优先升级到最新稳定版（如^10.0.0及以上），新版本修复了Unicode主题的编码问题。修改pubspec.yaml：

dependencies:
  mqtt_client: ^10.0.0 # 替换为最新稳定版

若无法升级，手动处理主题编码：将韩文主题转换为UTF-8字节后，再传递给订阅方法作为临时 workaround：

for (String topic in _subTopicList) {
  final utf8TopicBytes = utf8.encode(topic);
  final encodedTopic = String.fromCharCodes(utf8TopicBytes);
  client.subscribe(encodedTopic, MqttQos.exactlyOnce);
}

问题2：接收韩文消息显示乱码

原因分析

MqttPublishPayload.bytesToStringAsString方法默认使用Latin1编码解码消息字节，而韩文采用UTF-8编码，导致解码错误出现乱码。

解决步骤

直接使用Dart标准库的utf8.decode方法解码消息字节：

client.updates!.listen((List<MqttReceivedMessage<MqttMessage?>>? c) {
  final recMess = c![0].payload as MqttPublishMessage;
  // 替换原解码方法，用UTF-8解析消息字节
  final pt = utf8.decode(recMess.payload.message);

  context.read<SubTopic>().newTopic(c[0].topic);
  context.read<SubMessage>().newMessage(pt);

  print('Notification: topic is <${c[0].topic}>, payload is <$pt>');
});