JoJo的个人博客

记录精彩的程序人生

目录
Flutter与Android端通信
/  

Flutter与Android端通信

概述

注:本篇文章参考了Flutter从入门到进阶实战视频的教程文档,视频讲的很好,感谢老师带我入门了flutter

Flutter定义了三种不同类型的Channel

  • BasicMessageChannel:用于传递字符串和半结构化的信息,持续通信,收到消息后可以回复此次消息,如:Native将遍历到的文件信息陆续传递到Dart,在比如:Flutter将从服务端陆陆续获取到信息交个Native加工,Native处理完返回等;
  • MethodChannel:用于传递方法调用(method invocation)一次性通信:如Flutter调用Native拍照;
  • EventChannel: 用于数据流(event streams)的通信,持续通信,收到消息后无法回复此次消息,通过长用于NativeDart的通信,如:手机电量变化,网络连接变化,陀螺仪,传感器等;

这三种类型的类型的Channel都是全双工通信,即A <=> BDart可以主动发送消息给platform端,并且platform接收到消息后可以做出回应,同样,platform端可以主动发送消息给Dart端,dart端接收数后返回给platform端。

参考GitHub代码flutter_demo

初始化Flutter时Native向Dart传递数据

FlutterAPI中提供了Native在初始化Dart页面时传递数据给Dart的方式,这种传递数据的方式比下文中所讲的其他几种传递数据的方式发生的时机都早。

AndroidFlutter传递初始化数据initialRoute

Flutter允许我们在初始化Flutter页面时向Flutter传递一个String类型的initialRoute参数。

findViewById(R.id.jump).setOnClickListener(new View.OnClickListener() {
    @Override
    public void onClick(View view) {
        String inputParams = paramInput.getText().toString().trim();
        startActivity(
            FlutterActivity
                .withNewEngine()
                .initialRoute("route1")
                .build(MainActivity.this)
        );
    }
});

然后在Flutter module通过如下方式获取:

import 'dart:ui';//要使用window对象必须引入

String initParams = window.defaultRouteName;
//序列化成Dart obj 敢你想干的
...

MethodChannel用法

Native端:

构造方法原型

//会构造一个StandardMethodCodec.INSTANCE类型的MethodCodec
MethodChannel(BinaryMessenger messenger, String name)
//或
MethodChannel(BinaryMessenger messenger, String name, MethodCodec codec)
  • BinaryMessenger messenger - 消息信使,是消息的发送与接收的工具;
  • String name - Channel的名字,也是其唯一标识符;
  • MethodCodec codec - 用作MethodChannel的编解码器;

setMethodCallHandler方法原型

setMethodCallHandler(@Nullable MethodChannel.MethodCallHandler handler) 
  • @Nullable MethodChannel.MethodCallHandler handler - 消息处理器,配合BinaryMessenger完成消息的处理;

在创建好MethodChannel后,需要调用它的setMessageHandler方法为其设置一个消息处理器,以便能加收来自Dart的消息。

MethodChannel.MethodCallHandler原型

public interface MethodCallHandler {
    void onMethodCall(MethodCall var1, MethodChannel.Result var2);
}
  • onMethodCall(MethodCall call, MethodChannel.Result result) - 用于接受消息,call是消息内容,它有两个成员变量String类型的call.method表示调用的方法名,Object类型的call.arguments表示调用方法所传递的入参;MethodChannel.Result result是回复此消息的回调函数提供了result.successresult.errorresult.notImplemented方法调用;
public class MethodChannelPlugin implements MethodCallHandler {
    private final Activity activity;

    /**
     * Plugin registration.
     */
    public static void registerWith(BinaryMessenger messenger, Activity activity) {
        MethodChannel channel = new MethodChannel(messenger, "MethodChannelPlugin");
        MethodChannelPlugin instance = new MethodChannelPlugin(activity);
        channel.setMethodCallHandler(instance);
    }

    private MethodChannelPlugin(Activity activity) {
        this.activity = activity;
    }

    @Override
    public void onMethodCall(MethodCall call, Result result) {
        switch (call.method) {//处理来自Dart的方法调用
            case "send":
                showMessage(call.arguments());
                result.success("MethodChannelPlugin收到:" + call.arguments);//返回结果给Dart
                break;
            default:
                result.notImplemented();
        }
    }

    /**
     * 展示来自Dart的数据
     *
     * @param arguments
     */
    private void showMessage(String arguments) {
        if (activity instanceof IShowMessage) {
            ((IShowMessage) activity).onShowMessage(arguments);
        }
        Toast.makeText(activity, arguments, Toast.LENGTH_SHORT).show();
    }
}

Dart端:

构造方法原型

const MethodChannel(this.name, [this.codec = const StandardMethodCodec()])
  • String name - Channel的名字,要和Native端保持一致;
  • MethodCodec codec - 消息的编解码器,默认是StandardMethodCodec,要和Native端保持一致;

invokeMethod方法原型

Future<T> invokeMethod<T>(String method, [ dynamic arguments ])
  • String method:要调用Native的方法名;
  • [ dynamic arguments ]:调用Native方法传递的参数,可不传;
import 'package:flutter/services.dart';
...
static const MethodChannel _methodChannelPlugin =
      const MethodChannel('MethodChannelPlugin');
...
String response;
    try {
  response = await _methodChannelPlugin.invokeMethod('send', value);
    } on PlatformException catch (e) {
      print(e);
    }
...

BasicMessageChannel用法

Native端:

构造方法原型

BasicMessageChannel(BinaryMessenger messenger, String name, MessageCodec<T> codec)
  • BinaryMessenger messenger - 消息信使,是消息的发送与接收的工具;

  • String name - Channel的名字,也是其唯一标识符;

  • MessageCodec<T> codec
    

    - 消息的编解码器,它有几种不同类型的实现:

    • BinaryCodec - 最为简单的一种Codec,因为其返回值类型和入参的类型相同,均为二进制格式(Android中为ByteBufferiOS中为NSData)。实际上,BinaryCodec在编解码过程中什么都没做,只是原封不动将二进制数据消息返回而已。或许你会因此觉得BinaryCodec没有意义,但是在某些情况下它非常有用,比如使用BinaryCodec可以使传递内存数据块时在编解码阶段免于内存拷贝;
    • StringCodec - 用于字符串与二进制数据之间的编解码,其编码格式为UTF-8
    • JSONMessageCodec - 用于基础数据与二进制数据之间的编解码,其支持基础数据类型以及列表、字典。其在iOS端使用了NSJSONSerialization作为序列化的工具,而在Android端则使用了其自定义的JSONUtilStringCodec作为序列化工具;
    • StandardMessageCodec - 是BasicMessageChannel的默认编解码器,其支持基础数据类型、二进制数据、列表、字典,其工作原理;

setMessageHandler方法原型

void setMessageHandler(BasicMessageChannel.MessageHandler<T> handler)
  • BasicMessageChannel.MessageHandler<T> handler - 消息处理器,配合BinaryMessenger完成消息的处理;

在创建好BasicMessageChannel后,如果要让其接收Dart发来的消息,则需要调用它的setMessageHandler方法为其设置一个消息处理器。

BasicMessageChannel.MessageHandler原型

public interface MessageHandler<T> {
    void onMessage(T var1, BasicMessageChannel.Reply<T> var2);
}
  • onMessage(T var1, BasicMessageChannel.Reply<T> var2) - 用于接受消息,var1是消息内容,var2是回复此消息的回调函数;

send方法原型

void send(T message)
void send(T message, BasicMessageChannel.Reply<T> callback)
  • T message - 要传递给Dart的具体信息;
  • BasicMessageChannel.Reply<T> callback - 消息发出去后,收到Dart的回复的回调函数;

在创建好BasicMessageChannel后,如果要向Dart发送消息,可以调用它的send方法向Dart传递数据。

public class BasicMessageChannelPlugin implements BasicMessageChannel.MessageHandler<String>, BasicMessageChannel.Reply<String> {
    private final Activity activity;
    private final BasicMessageChannel<String> messageChannel;

    static BasicMessageChannelPlugin registerWith(BinaryMessenger messenger, Activity activity) {
        return new BasicMessageChannelPlugin(messenger, activity);
    }

    private BasicMessageChannelPlugin(BinaryMessenger messenger, Activity activity) {
        this.activity = activity;
        this.messageChannel = new BasicMessageChannel<>(messenger, "BasicMessageChannelPlugin", StringCodec.INSTANCE);
        //设置消息处理器,处理来自Dart的消息
        messageChannel.setMessageHandler(this);
    }

    @Override
    public void onMessage(String s, BasicMessageChannel.Reply<String> reply) {//处理Dart发来的消息
        reply.reply("BasicMessageChannel收到:" + s);//可以通过reply进行回复
        if (activity instanceof IShowMessage) {
            ((IShowMessage) activity).onShowMessage(s);
        }
        Toast.makeText(activity, s, Toast.LENGTH_SHORT).show();
    }

    /**
     * 向Dart发送消息,并接受Dart的反馈
     *
     * @param message  要给Dart发送的消息内容
     * @param callback 来自Dart的反馈
     */
    void send(String message, BasicMessageChannel.Reply<String> callback) {
        messageChannel.send(message, callback);
    }

    @Override
    public void reply(String s) {

    }
}

Dart端:

构造方法原型

const BasicMessageChannel(this.name, this.codec);
  • String name - Channel的名字,要和Native端保持一致;
  • MessageCodec<T> codec - 消息的编解码器,要和Native端保持一致,有四种类型的实现具体可以参考Native端的介绍;

setMessageHandler方法原型

void setMessageHandler(Future<T> handler(T message))
  • Future<T> handler(T message) - 消息处理器,配合BinaryMessenger完成消息的处理;

在创建好BasicMessageChannel后,如果要让其接收Native发来的消息,则需要调用它的setMessageHandler方法为其设置一个消息处理器。

send方法原型

 Future<T> send(T message)
  • T message - 要传递给Native的具体信息;
  • Future<T> - 消息发出去后,收到Native回复的回调函数;

在创建好BasicMessageChannel后,如果要向Native发送消息,可以调用它的send方法向Native传递数据。

import 'package:flutter/services.dart';
...
static const BasicMessageChannel _basicMessageChannel =
      const BasicMessageChannel('BasicMessageChannelPlugin', StringCodec());
...
//使用BasicMessageChannel接受来自Native的消息,并向Native回复
_basicMessageChannel
    .setMessageHandler((String message) => Future<String>(() {
          setState(() {
            showMessage = message;
          });
          return "收到Native的消息:" + message;
        }));
//使用BasicMessageChannel向Native发送消息,并接受Native的回复
String response;
    try {
       response = await _basicMessageChannel.send(value);
    } on PlatformException catch (e) {
      print(e);
    }
...

EventChannel用法

Native端:

构造方法原型

//会构造一个StandardMethodCodec.INSTANCE类型的MethodCodec
EventChannel(BinaryMessenger messenger, String name)
//或
EventChannel(BinaryMessenger messenger, String name, MethodCodec codec)
  • BinaryMessenger messenger - 消息信使,是消息的发送与接收的工具;
  • String name - Channel的名字,也是其唯一标识符;
  • MethodCodec codec - 用作EventChannel的编解码器;

setStreamHandler方法原型

void setStreamHandler(EventChannel.StreamHandler handler)

EventChannel.StreamHandler handler - 消息处理器,配合BinaryMessenger完成消息的处理; 在创建好EventChannel后,如果要让其接收Dart发来的消息,则需要调用它的setStreamHandler方法为其设置一个消息处理器。

EventChannel.StreamHandler原型

public interface StreamHandler {
    void onListen(Object args, EventChannel.EventSink eventSink);

    void onCancel(Object o);
}
  • void onListen(Object args, EventChannel.EventSink eventSink) - Flutter Native监听事件时调用,Object args是传递的参数,EventChannel.EventSink eventSinkNative回调Dart时的会回调函数,eventSink提供successerrorendOfStream三个回调方法分别对应事件的不同状态;
  • void onCancel(Object o) - Flutter取消监听时调用;
public class EventChannelPlugin implements EventChannel.StreamHandler {
    private EventChannel.EventSink eventSink;

    static EventChannelPlugin registerWith(BinaryMessenger messenger) {
        EventChannelPlugin plugin = new EventChannelPlugin();
        new EventChannel(messenger, "EventChannelPlugin").setStreamHandler(plugin);
        return plugin;
    }

    void send(Object params) {
        if (eventSink != null) {
            eventSink.success(params);
        }
    }

    @Override
    public void onListen(Object args, EventChannel.EventSink eventSink) {
        this.eventSink = eventSink;
    }

    @Override
    public void onCancel(Object o) {
        eventSink = null;
    }
}

Dart端:

构造方法原型

const EventChannel(this.name, [this.codec = const StandardMethodCodec()]);
  • String name - Channel的名字,要和Native端保持一致;
  • MethodCodec codec - 消息的编解码器,默认是StandardMethodCodec,要和Native端保持一致;

receiveBroadcastStream方法原型

Stream<dynamic> receiveBroadcastStream([ dynamic arguments ]) 
  • dynamic arguments - 监听事件时向Native传递的数据;

初始化一个广播流用于从channel中接收数据,它返回一个Stream接下来需要调用Streamlisten方法来完成注册,另外需要在页面销毁时调用Streamcancel方法来取消监听;

import 'package:flutter/services.dart';
...
static const EventChannel _eventChannelPlugin =
      EventChannel('EventChannelPlugin');
StreamSubscription _streamSubscription;
  @override
  void initState() {
    _streamSubscription=_eventChannelPlugin
        .receiveBroadcastStream()
        .listen(_onToDart, onError: _onToDartError);
    super.initState();
  }
  @override
  void dispose() {
    if (_streamSubscription != null) {
      _streamSubscription.cancel();
      _streamSubscription = null;
    }
    super.dispose();
  }
  void _onToDart(message) {
    setState(() {
      showMessage = message;
    }); 
  }
  void _onToDartError(error) {
    print(error);
  }
...

参考文章

Flutter与Android通信开发指南


标题:Flutter与Android端通信
作者:SunnySky
地址:https://www.tianyang.pub/articles/2020/07/03/1593748192235.html

评论