事件订阅 EventChannel

https://www.bilibili.com/video/BV1zj411d7k4/

前言

上一节我们讲了 Channel 通道，但是如果你是卫星定位业务，原生端主动推消息给 Flutter 这时候就要用到 EventChannel 通道了。

本节会写一个 1~50 的计数器，到 50 后自动关闭原生的消息订阅。

FlutterEventChannel

FlutterEventChannel 的作用是在 Flutter 平台和原生平台之间建立双向通信的桥梁。通过 FlutterEventChannel，Flutter 应用程序可以向原生平台发送事件，同时也可以接收来自原生平台的事件。

FlutterEventChannel 可以用于许多场景，例如：

1. 传感器数据采集：许多应用程序需要从设备的传感器（如加速度计、陀螺仪、磁力计等）中获取数据。Flutter 应用程序可以通过 FlutterEventChannel 发送请求，让原生平台采集传感器数据并返回到 Flutter 应用程序中。
2. 后台任务完成通知：当应用程序在后台运行时，可能需要执行一些长时间运行的任务。Flutter 应用程序可以通过 FlutterEventChannel 向原生平台发送请求，让原生平台在后台任务完成时发送通知到 Flutter 应用程序中。
3. 音频和视频流传输：许多应用程序需要在 Flutter 应用程序和原生平台之间传输音频和视频流。Flutter 应用程序可以通过 FlutterEventChannel 向原生平台发送请求，让原生平台传输音频和视频流并返回到 Flutter 应用程序中。这使得 Flutter 应用程序可以使用原生平台的音频和视频处理功能，以提高应用程序的性能和用户体验。

FlutterEventChannel 执行过程如下：

1. Flutter 应用程序创建一个 FlutterEventChannel 对象，并指定一个唯一的通道名称。
2. Flutter 应用程序调用 FlutterEventChannel 的 receiveBroadcastStream 方法，以获取一个 Stream 对象，以便监听来自原生平台的事件。
3. 原生平台创建一个 EventChannel 对象，并指定与 Flutter 应用程序中通道名称相匹配的字符串。
4. 原生平台调用 EventChannel 的 setStreamHandler 方法，以设置一个 StreamHandler 对象，以便接收来自 Flutter 应用程序的事件并向其发送原生事件。
5. 当 Flutter 应用程序需要向原生平台发送事件时，它会将事件数据发送到 FlutterEventChannel 对象中。
6. FlutterEventChannel 将事件数据传递给原生平台的 EventChannel 对象。
7. EventChannel 对象将事件数据传递给 StreamHandler 对象中的 onListen 方法。
8. 在 onListen 方法中，原生平台可以执行一些操作并发送事件数据到 Stream 对象中。
9. Flutter 应用程序可以通过 Stream 对象监听来自原生平台的事件，并执行相应的操作。

需要注意的是，FlutterEventChannel 中使用的 Stream 对象是异步的，因此在监听来自原生平台的事件时需要使用异步编程的技术。另外，在使用 FlutterEventChannel 时，Flutter 应用程序和原生平台之间需要约定好通道名称和事件数据格式，以便能够正确地交互和处理数据。

原文 https://ducafecat.com/blog/flutter-plugin-event-channel

参考

https://api.flutter.dev/flutter/services/EventChannel-class.html

https://mobikul.com/event-channel-in-flutter/

步骤

Flutter 插件

接口定义

lib/flutter_plugin_add_platform_interface.dart

  Future<bool?> startCounting() {    throw UnimplementedError('startCounting() has not been implemented.');  }

原生调用

lib/flutter_plugin_add_method_channel.dart

 @override  Future<bool?> startCounting() async {    final val = await methodChannel.invokeMethod<bool>('startCounting');    return val;  }

插件调用类

lib/flutter_plugin_add.dart

// 类型定义 - 接收函数typedef TypeOnRecvData = void Function(int value);

  // event channel 定义
  static const eventChannel =
      EventChannel('com.ducafecat.counter/eventChannel');

  // 订阅
  StreamSubscription? _streamSubscription;

  // 接收函数
  TypeOnRecvData? _onRecvData;
  // 开始计数
  Future<void> startCounting(TypeOnRecvData onRecvData) async {
    _onRecvData = onRecvData;
    if (_streamSubscription == null) {
      bool? isStarting =
          await FlutterPluginAddPlatform.instance.startCounting();
      if (isStarting == true) {
        _streamSubscription =
            eventChannel.receiveBroadcastStream().listen(_listenStream);
      }
    }
  }
  // 取消计数
  void cancelCounting() {
    _streamSubscription?.cancel();
    _streamSubscription = null;
    _onRecvData = null;
  }
  // 接收函数
  void _listenStream(value) {
    debugPrint("Received From Native:  $value\n");
    _onRecvData?.call(value);

    if (value == 50) {
      cancelCounting();
    }
  }
  // 释放
  void dispose() {
    cancelCounting();
  }

最后启动