Flutter 与 OpenHarmony 通信：Flutter Channel 使用指南-洪萨配资

Flutter 与 OpenHarmony 通信：Flutter Channel 使用指南

欢迎大家加入跨平台社区
本文介绍在 Flutter OpenHarmony 化工程中，如何利用 Flutter Channel 实现 Dart 代码与 OpenHarmony 原生端（ETS）之间的通信。Flutter Channel 提供了灵活的消息传递机制，支持方法调用、基础消息通信和事件流三种常用模式。以下将分别说明其使用方法，并附上关键代码示例。

完整示例可参考 channel_demo。

1. MethodChannel（方法调用）

MethodChannel 用于调用平台提供的特定方法，并支持异步返回结果。

Dart 端代码

// 创建 MethodChannel 实例final_platform=constMethodChannel('samples.flutter.dev/battery');// 调用原生端方法 getBatteryLevelfinalresult=await_platform.invokeMethod<int>('getBatteryLevel');

ETS 端代码

onAttachedToEngine(binding:FlutterPluginBinding):void{letthat=this;// 创建 MethodChannel 实例this.channel=newMethodChannel(binding.getBinaryMessenger(),"samples.flutter.dev/battery");// 设置方法调用处理器this.channel.setMethodCallHandler({onMethodCall(call:MethodCall,result:MethodResult){switch(call.method){case"getBatteryLevel":that.api.getBatteryLevel(result);break;default:result.notImplemented();break;}}});}

2. BasicMessageChannel（基础消息通信）

BasicMessageChannel 用于简单的数据传递，支持双向异步消息收发。

Dart 端代码

int count=0;// 创建 BasicMessageChannel 实例final_basicChannel=constBasicMessageChannel("samples.flutter.dev/basic_channel",StandardMessageCodec());// 发送消息并接收回复Stringresult=await_basicChannel.send(++count)asString;

ETS 端代码

onAttachedToEngine(binding:FlutterPluginBinding):void{// 创建 BasicMessageChannel 实例this.basicChannel=newBasicMessageChannel(binding.getBinaryMessenger(),"samples.flutter.dev/basic_channel",newStandardMessageCodec());// 设置消息处理器this.basicChannel.setMessageHandler({onMessage(message:Any,reply:Reply<Any>){Log.i(TAG,"message="+message);if(message%2==0){reply.reply("run with if case.");}else{reply.reply("run with else case");}}});}

3. EventChannel（事件流通信）

EventChannel 用于从原生端向 Dart 端发送连续的事件流，适用于状态监听、实时数据推送等场景。

Dart 端代码

// 创建 EventChannel 实例final_eventChannel=constEventChannel('samples.flutter.dev/event_channel');// 监听事件流_eventChannel.receiveBroadcastStream().listen((event){setState((){message="EventChannel event=$event";});});

ETS 端代码

privateeventSink?:EventSink;onAttachedToEngine(binding:FlutterPluginBinding):void{letthat=this;// 创建 EventChannel 实例this.eventChannel=newEventChannel(binding.getBinaryMessenger(),"samples.flutter.dev/event_channel");// 设置流处理器this.eventChannel.setStreamHandler({onListen(args:Any,events:EventSink):void{that.eventSink=events;Log.i(TAG,"onListen: "+args);},onCancel(args:Any):void{that.eventSink=undefined;Log.i(TAG,"onCancel: "+args);}});}// 通过 EventSink 发送事件到 Dart 端that.eventSink?.success("Success at "+newDate());