1.需求

最近使用flutter desktop，开发一个mqtt的桌面工具。

mqtt的发送没有问题，但是订阅的实现有点麻烦。
订阅需要listen监听到消息后，返回给页面，页面刷新收到的消息数据,在页面展示出来。
网上查找，最好实现的方式是event_bus，用起来还真不错。

2.实现

• 先单独实现个eventbus

import 'package:event_bus/event_bus.dart';

class rmsgdata {
  late final String data;
  
  rmsgdata(this.data);
}

EventBus eventBus = EventBus();

• UI页面部分订阅topic后，开始监听eventbus

btnsubscribeMsg(context) async {
    mcc = MqttClient(clientid!);
    mc = await mcc.msgSubscribe(topicname);
    showMaterialDialogSingle(context, "订阅成功");
    eventBus.on<rmsgdata>().listen((event) {
      if (!mounted) return;
      setState(() {
        backMsgList!.add(event.data);
      });
    });
  }

• 发送部分，mqtt监听到消息后，发送eventbus

void onReceivedHandle(client, topic, payload) {
  print("我是处理函数");
  serverMqttSend(client, topic, "success");
  eventBus.fire(rmsgdata(payload));
}

完成了前端页面的刷新。