Flutter Chanel通信流程

目录介绍

01.flutter和原生之间交互
02.MethodChanel流程
03.MethodChanel使用流程
04.MethodChanel代码实践
05.EventChannel流程
06.EventChannel基本流程
07.EventChannel代码实现
08.BasicMessageChannel流程
09.BasicMessageChannel基本流程
10.BasicMessageChannel代码实现
11.Channel编解码器说明
12.Channel通信可以子线程吗
13.Channel通信传递稳定性
14.onActivityResult如何实现

02.MethodChannel流程

其中最常用的是MethodChanel，MethodChanel的使用与在Android的JNI调用非常类似，但是MethodChanel更加简单，而且相对于JNI的同步调用MethodChanel的调用是异步的：
- Flutter Chanel通信流程
从flutter架构图上可以看到，flutter与native的通信发生在Framework和Engine之间，framewrok内部会将MethodChannel以BinaryMessage的形式与Engine进行数据交换。

3.1 flutter调用native

flutter调用native步骤
- [native] 使用MethodChannel#setMethodCallHandler注册回调
- [flutter] 通过MethodChannel#invokeMethod发起异步调用
- [native] 调用native方法通过Result#success返回Result，出错时返回error
- [flutter] 收到native返回的Result
如图所示
- Flutter Chanel通信流程

3.2 native调用flutter

native调用flutter
- 与flutter调用native的顺序完全一致，只是[native]与[flutter]角色反调
- Flutter Chanel通信流程
NA端使用MethodChannel
- 首先定义Channel名称，需要保证是唯一的，在Flutter端需要使用同样的名称来创建MethodChannel。如果名称不一样，则会导致匹配不上……
- 第一个参数：是messenger，类型是BinaryMessenger，是一个接口，代表消息信使，是消息发送与接收的工具；
- 第二个参数：是name，就是Channel名称，和flutter定义的要一样；
- 第三个参数：是codec，类型是MethodCodec，代表消息的编解码器，如果没有传该参数，默认使用StandardMethodCodec。

4.1 native调用flutter

定义好了MethodChannel之后调用setMethodCallHandler()方法设置消息处理回调，参数是MethodHandler类型，需要实现它的onMethodCall()方法。onMethodCall()方法有两个参数methodCall和result，methodCall记录了调用的方法信息，包括方法名和参数，result用于方法的返回值，可以通过result.success()方法返回信息给Flutter端。

private void createChannel() {
    nativeChannel = new MethodChannel(binaryMessenger, METHOD_CHANNEL, StandardMethodCodec.INSTANCE);
    // 注册Handler实现
    nativeChannel.setMethodCallHandler(new MethodChannel.MethodCallHandler() {
        @Override
        public void onMethodCall(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
            if ("android".equals(methodCall.method)) {
                //接收来自flutter的指令
                String flutter = methodCall.argument("flutter");
                //返回给flutter的参数
                result.success("Na收到指令");
            } 
        }
    });
}

可以通过invokeMethod方法让NA执行调用flutter方法。那么执行了flutter方法后需要回传数据，这个时候就需要用到Result接口呢，代码如下所示：

HashMap<String , String> map = new HashMap<>();
map.put("invokeKey","你好，这个是从NA传递过来的数据");
//nativeChannel.resizeChannelBuffer(100);
nativeChannel.invokeMethod("getFlutterResult", map , new MethodChannel.Result() {
    @SuppressLint("SetTextI18n")
    @Override
    public void success(@Nullable Object result) {
        tvContent.setText("测试内容："+result);
    }

    @SuppressLint("SetTextI18n")
    @Override
    public void error(String errorCode, @Nullable String errorMessage, @Nullable Object errorDetails) {
        tvContent.setText("测试内容：flutter传递给na数据传递错误");
    }

    @Override
    public void notImplemented() {

    }
});

事件接收处理端
- 接收处理回调时onMethodCall(MethodCall call, MethodChannel.Result result)通过methodCall接收事件发送者传递回来的信息，通过Result把处理完的结果发送给事件发送方。
- 通过methodCall.method：来区分不同函数名（方法）名以执行不同的业务逻辑，
- 通过methodCall.hasArgument（"key"）：判断是否有某个key对应的value
- 通过methodCall.argument（"key"）：获取key对应的value值
- 通过result.success(object)：把处理完的结果返回给事件发送方
事件发送端
- 处理事件发送方通过methodChannel.invokeMethod("方法名","要传递的参数")把需要传递的参数传递给事件监听者。其中
- 方法名:不能为空
- 要传递的参数:可以为空，若不为空则必须为可Json序列化的对象。
- callback：可以为空，若不为空则表示执行了flutter方法后的回调监听状态

4.2 flutter调用native

Flutter使用MethodChannel
- 在Flutter端同样需要定义一个MethodChannel，使用MethodChannel需要引入services.dart包，Channel名称要和Android端定义的相同。
```
static const method = const MethodChannel('com.ycbjie.android/method');           
```

添加监听NA调用flutter方法的监听，flutter代码是setMethodCallHandler方法实现。return则表示flutter回传给NA的数据操作。

method.setMethodCallHandler(nativeCallHandler);

  // 注册方法，等待被原生通过invokeMethod唤起
  Future<dynamic> nativeCallHandler(MethodCall methodCall) async {
    switch (methodCall.method) {
      case "getFlutterResult":
      //获取参数
        String paramsFromNative = await methodCall.arguments["invokeKey"];
        print("原生android传递过来的参数为------ $paramsFromNative");
        return "你好，这个是从flutter回传给NA的数据";
        break;
    }
  }

flutter是如何给NA发送消息的呢，直接调用invokeMethod方法，代码如下所示

Future<Null> _jumpToNativeWithParams1() async {
    Map<String, String> map = { "flutter": "这是一条来自flutter的参数" };
    String result = await method.invokeMethod('android', map);
    print(result);
  }

EventChannel用于从native向flutter发送通知事件，例如flutter通过其监听Android的重力感应变化等。与MethodChannel不同，EventChannel是native到flutter的单向调用，调用是多播（一对多）的，可以类比成Android的Brodecast广播。

照例先看一下API使用的基本流程：
- [native]EventChannel#setStreamHandler注册Handler实现
- [native]EventChannel初始化结束后，在StreamHandler#onLister回调中获取EventSink引用并保存
- [flutter]EventChannel#receiveBroadcastStream注册listener，建立监听
- [native]使用EventSink#sucess发送通知事件
- [flutter]接受到事件通知
- [native]通知结束时调用endOfStream结束
- Flutter Chanel通信流程

flutter端

创建EventChannel，注册“包名/标识符”的channel名
通过StreamSubscription#listen注册listener，其中cancelOnError参数表示遇到错误时是否自动结束监听

class _MyHomePageState extends State<MyHomePage> {
  static const EventChannel _channel = const EventChannel('com.example.eventchannel/interop');

  StreamSubscription _streamSubscription;
  String _platformMessage;

  void _enableEventReceiver() {
    _streamSubscription = _channel.receiveBroadcastStream().listen(
        (dynamic event) {
          print('Received event: $event');
          setState(() {
            _platformMessage = event;
          });
        },
        onError: (dynamic error) {
          print('Received error: ${error.message}');
        },
        cancelOnError: true);
  }

  void _disableEventReceiver() {
    if (_streamSubscription != null) {
      _streamSubscription.cancel();
      _streamSubscription = null;
    }
  }

  @override
  initState() {
    super.initState();
    _enableEventReceiver();
  }

  @override
  void dispose() {
    super.dispose();
    _disableEventReceiver();
  }

native(android)端

通过EventChannel#setStreamHandler注册Handler实现
初始化完成后，获取eventSink引用并保存
eventSink发送事件通知
通知结束时调用event#endOfStream，此时onCancel会被调用
必要时，可通过evnetSink#error发送错误通知，flutter的StreamSubscription#onError会收到通知

class MainActivity: FlutterActivity() {
    private lateinit var channel: EventChannel
    var eventSink: EventSink? = null

    override fun configureFlutterEngine(@NonNull flutterEngine: FlutterEngine) {
        GeneratedPluginRegistrant.registerWith(flutterEngine)

        channel = EventChannel(flutterEngine.dartExecutor.binaryMessenger, "com.example.eventchannel/interop")
        channel.setStreamHandler(
                object : StreamHandler {
                    override fun onListen(arguments: Any?, events: EventSink) {
                        eventSink = events
                        Log.d("Android", "EventChannel onListen called")
                        Handler().postDelayed({
                            eventSink?.success("Android")
                            //eventSink?.endOfStream()
                            //eventSink?.error("error code", "error message","error details")
                        }, 500)
                    }
                    override fun onCancel(arguments: Any?) {
                        Log.w("Android", "EventChannel onCancel called")
                    }
                })
    }
}

BasicMessageChannel用于在flutter和native互相发送消息，一方给另一方发送消息，收到消息之后给出回复。

flutter向native发送消息
- [flutter]创建BasicMessageChannel
- [native]通过BasicMessageChannel#MessageHandler注册Handler
- [flutter]通过BasicMessageChannel#send发送消息
- [native]BasicMessageChannel#MessageHandler#onMessage中接收消息，然后reply
- Flutter Chanel通信流程
native向flutter发送消息
- 流程也是一样的，只是将[flutter]与[native]反调
- Flutter Chanel通信流程

10.1flutter端

flutter需要完成以下工作
- 创建BasicMessageChannel
- 通过BasicMessageChannel#send发送消息
相对与其他Channel类型的创建，MessageChannel的创建除了channel名以外，还需要指定编码方式：
```
BasicMessageChannel(String name, MessageCodec<T> codec, {BinaryMessenger binaryMessenger})           
```
发送的消息会以二进制的形式进行处理，所以要针对不同类型的数进行二进制编码
- 编码类型消息格式
- BinaryCodec 发送二进制消息时
- JSONMessageCodec 发送Json格式消息时
- StandardMessageCodec 发送基本型数据时
- StringCodec 发送String类型消息时

代码

class _MyHomePageState extends State<MyHomePage> {
  static const _channel = BasicMessageChannel('com.ycbjie.android/basic', StringCodec());

  String _platformMessage;

  void _sendMessage() async {
    final String reply = await _channel.send('Hello World form Dart');
    print(reply);
  }

  @override
  initState() {
    super.initState();

    // Receive messages from platform
    _channel.setMessageHandler((String message) async {
      print('Received message = $message');
      setState(() => _platformMessage = message);
      return 'Reply from Dart';
    });

    // Send message to platform
    _sendMessage();
  }

10.2 native(android)端

android端完成以下工作：
- 通过setHandler注册MessageHandler
- MessageHandler#onMessage回调中接收到message后，通过reply进行回复

class MainActivity: FlutterActivity() {
    override fun configureFlutterEngine(@NonNull flutterEngine: FlutterEngine) {
        GeneratedPluginRegistrant.registerWith(flutterEngine)

        val channel = BasicMessageChannel(
                flutterEngine.dartExecutor.binaryMessenger,
                "com.ycbjie.android/basic", StringCodec.INSTANCE)

        // Receive messages from Dart
        channel.setMessageHandler { message, reply ->
            Log.d("Android", "Received message = $message")
            reply.reply("Reply from Android")
        }

        // Send message to Dart
        Handler().postDelayed({
            channel.send("Hello World from Android") { reply ->
                Log.d("Android", "$reply")
            }
        }, 500)
    }
}

11.1 什么是消息编解码器

什么是消息编解码器
- 在Flutter和平台间进行相互通信了，但是收发的数据都是二进制的，这就需要开发者考虑更多的细节，如字节顺序(大小端)和怎么表示更高级的消息类型，如字符串，map等。
- 因此，Flutter 还提供了消息编解码器(Codec)，用于高级数据类型（字符串，map等）和二进制数据（byte）之间的转换，即消息的序列化和反序列化。
消息编解码器种类有哪些
- MethodCodec：方法传递的编解码器抽象，接口
- JSONMethodCodec：MethodCodec的实现类，会把数据打包成json结构发送给dart，类
- StandardMethodCodec：MethodCodec的实现类，会把数据打包成默认格式发送给dart，类

11.2 四种消息编解码器类型

BinaryCodec
- MessageCodec的实现类，直接发送二进制数据
- BinaryCodec是最为简单的一种Codec，因为其返回值类型和入参的类型相同，均为二进制格式（Android中为ByteBuffer，iOS中为NSData）。实际上，BinaryCodec在编解码过程中什么都没做，只是原封不动将二进制数据消息返回而已。或许你会因此觉得BinaryCodec没有意义，但是在某些情况下它非常有用，比如使用BinaryCodec可以使传递内存数据块时在编解码阶段免于内存拷贝。
StringCodec
- MessageCodec的实现类，负责解码和编码String类型的消息
- 使用 UTF-8 编码格式对字符串数据进行编解码，在Android平台转换为 java.util.String 类型
JSONMessageCodec
- MessageCodec的实现类，负责解码和编码Json类型的消息
- JSONMessageCodec用于处理 JSON 数据类型（字符串型，数字型，布尔型，null，只包含这些类型的数组，和key为string类型，value为这些类型的map）,在编码过程中，数据会被转换为JSON字符串，然后在使用 UTF-8 格式转换为字节型。
StandardMessageCodec
- MessageCodec的实现类，负责解码和编码默认类型的消息
- StandardMessageCodec 可以认为是 JSONMessageCodec 的升级版，能够处理的数据类型要比 JSONMessageCodec 更普遍一些，且在处理 int 型数据时，会根据 int 数据的大小来转为平台端的32位类型（int）或者是64位类型(long)，StandardMessageCodec 也是 Flutter Platform channel 的默认编解码器

11.3 编码器的源码分析下

首先看下MessageCodec

abstract class MessageCodec<T> {

  ByteData encodeMessage(T message);

  T decodeMessage(ByteData message);
}

11.4 看StandardMessageCodec

StandardMessageCodec稍微复杂
- StandardMessageCodec在写入数据的时候，显示写入这个数据的类型值定义，然后在写入其对应的具体值，什么意思呢？

查看一下如何写入指定类型的值，代码如下所示：

protected void writeValue(ByteArrayOutputStream stream, Object value) {
    if (value == null || value.equals(null)) {
      stream.write(NULL);
    } else if (value == Boolean.TRUE) {
      stream.write(TRUE);
    } else if (value == Boolean.FALSE) {
      stream.write(FALSE);
    } else if (value instanceof Number) {
      if (value instanceof Integer || value instanceof Short || value instanceof Byte) {
        stream.write(INT);
        writeInt(stream, ((Number) value).intValue());
      } else if (value instanceof Long) {
        stream.write(LONG);
        writeLong(stream, (long) value);
      } else if (value instanceof Float || value instanceof Double) {
        stream.write(DOUBLE);
        writeAlignment(stream, 8);
        writeDouble(stream, ((Number) value).doubleValue());
      } else if (value instanceof BigInteger) {
        stream.write(BIGINT);
        writeBytes(stream, ((BigInteger) value).toString(16).getBytes(UTF8));
      } else {
        throw new IllegalArgumentException("Unsupported Number type: " + value.getClass());
      }
    } else if (value instanceof String) {
      stream.write(STRING);
      writeBytes(stream, ((String) value).getBytes(UTF8));
    } else if (value instanceof byte[]) {
      stream.write(BYTE_ARRAY);
      writeBytes(stream, (byte[]) value);
    } else if (value instanceof int[]) {
      stream.write(INT_ARRAY);
      final int[] array = (int[]) value;
      writeSize(stream, array.length);
      writeAlignment(stream, 4);
      for (final int n : array) {
        writeInt(stream, n);
      }
    } else if (value instanceof long[]) {
      stream.write(LONG_ARRAY);
      final long[] array = (long[]) value;
      writeSize(stream, array.length);
      writeAlignment(stream, 8);
      for (final long n : array) {
        writeLong(stream, n);
      }
    } else if (value instanceof double[]) {
      stream.write(DOUBLE_ARRAY);
      final double[] array = (double[]) value;
      writeSize(stream, array.length);
      writeAlignment(stream, 8);
      for (final double d : array) {
        writeDouble(stream, d);
      }
    } else if (value instanceof List) {
      stream.write(LIST);
      final List<?> list = (List) value;
      writeSize(stream, list.size());
      for (final Object o : list) {
        writeValue(stream, o);
      }
    } else if (value instanceof Map) {
      stream.write(MAP);
      final Map<?, ?> map = (Map) value;
      writeSize(stream, map.size());
      for (final Entry<?, ?> entry : map.entrySet()) {
        writeValue(stream, entry.getKey());
        writeValue(stream, entry.getValue());
      }
    } else {
      throw new IllegalArgumentException("Unsupported value: " + value);
    }
  }

查看一下如何读取指定类型的值，代码如下所示：

protected Object readValueOfType(byte type, ByteBuffer buffer) {
    final Object result;
    switch (type) {
      case NULL:
        result = null;
        break;
      case TRUE:
        result = true;
        break;
      case FALSE:
        result = false;
        break;
      case INT:
        result = buffer.getInt();
        break;
      case LONG:
        result = buffer.getLong();
        break;
      case BIGINT:
        {
          final byte[] hex = readBytes(buffer);
          result = new BigInteger(new String(hex, UTF8), 16);
          break;
        }
      case DOUBLE:
        readAlignment(buffer, 8);
        result = buffer.getDouble();
        break;
      case STRING:
        {
          final byte[] bytes = readBytes(buffer);
          result = new String(bytes, UTF8);
          break;
        }
      case BYTE_ARRAY:
        {
          result = readBytes(buffer);
          break;
        }
      case INT_ARRAY:
        {
          final int length = readSize(buffer);
          final int[] array = new int[length];
          readAlignment(buffer, 4);
          buffer.asIntBuffer().get(array);
          result = array;
          buffer.position(buffer.position() + 4 * length);
          break;
        }
      case LONG_ARRAY:
        {
          final int length = readSize(buffer);
          final long[] array = new long[length];
          readAlignment(buffer, 8);
          buffer.asLongBuffer().get(array);
          result = array;
          buffer.position(buffer.position() + 8 * length);
          break;
        }
      case DOUBLE_ARRAY:
        {
          final int length = readSize(buffer);
          final double[] array = new double[length];
          readAlignment(buffer, 8);
          buffer.asDoubleBuffer().get(array);
          result = array;
          buffer.position(buffer.position() + 8 * length);
          break;
        }
      case LIST:
        {
          final int size = readSize(buffer);
          final List<Object> list = new ArrayList<>(size);
          for (int i = 0; i < size; i++) {
            list.add(readValue(buffer));
          }
          result = list;
          break;
        }
      case MAP:
        {
          final int size = readSize(buffer);
          final Map<Object, Object> map = new HashMap<>();
          for (int i = 0; i < size; i++) {
            map.put(readValue(buffer), readValue(buffer));
          }
          result = map;
          break;
        }
      default:
        throw new IllegalArgumentException("Message corrupted");
    }
    return result;
  }

11.5 如何选择合适编解码器

编解码的实现类并不复杂
- 可以先了解一下这个比较能更好的理解数据传递，其实不关java上层使用那种方式，最终传递给底层数据都是固定格式，约定统一的数据格式双方才能识别出来，正常的来说用默认的编解码格式就可以了。

关于四种解码器使用场景

- 暂未找到使用的场景

适用发送单一的字符串数据，数据量单一的情况，比如LifecycleChannel

public void appIsInactive() {
  Log.v(TAG, "Sending AppLifecycleState.inactive message.");
  channel.send("AppLifecycleState.inactive");
}

适用数据量比较复杂的情况，比如有携带多个数据字段的传递，比如KeyEventChannel

public void keyDown(@NonNull FlutterKeyEvent keyEvent) {
  Map<String, Object> message = new HashMap<>();
  message.put("type", "keydown");
  message.put("keymap", "android");
  encodeKeyEvent(keyEvent, message);
 
  channel.send(message);
}

- 默认的数据编解码，绝大多数的情况下使用默认的就可以了。比如：MethodChannel，EventChannel

12.1 Android发送通信信息

首先看一下Android发送通信信息，主要分析入口是：nativeChannel.invokeMethod("setNum", a , null);

public void invokeMethod(String method, @Nullable Object arguments, Result callback) {
messenger.send(
    name,
    codec.encodeMethodCall(new MethodCall(method, arguments)),
    callback == null ? null : new IncomingResultHandler(callback));
}

最终定位找到DartMessenger类的send方法，代码如下所示：

@Override
public void send(
      @NonNull String channel,
      @Nullable ByteBuffer message,
      @Nullable BinaryMessenger.BinaryReply callback) {
    Log.v(TAG, "Sending message with callback over channel '" + channel + "'");
    int replyId = 0;
    if (callback != null) {
      replyId = nextReplyId++;
      pendingReplies.put(replyId, callback);
    }
    if (message == null) {
      flutterJNI.dispatchEmptyPlatformMessage(channel, replyId);
    } else {
      flutterJNI.dispatchPlatformMessage(channel, message, message.position(), replyId);
    }
}

尝试一下子线程发送消息，发现会出现崩溃

new Thread(new Runnable() {
    @Override
    public void run() {
        nativeChannel.invokeMethod("setNum", a , null);
    }
}).start();

崩溃信息如下所示

java.lang.RuntimeException: Methods marked with @UiThread must be executed on the main thread. Current thread: Thread-2574
    at io.flutter.embedding.engine.FlutterJNI.ensureRunningOnMainThread(FlutterJNI.java:992)
    at io.flutter.embedding.engine.FlutterJNI.dispatchPlatformMessage(FlutterJNI.java:736)
    at io.flutter.embedding.engine.dart.DartMessenger.send(DartMessenger.java:72)
    at io.flutter.embedding.engine.dart.DartExecutor$DefaultBinaryMessenger.send(DartExecutor.java:370)
    at io.flutter.plugin.common.MethodChannel.invokeMethod(MethodChannel.java:94)
    at com.ycbjie.ycandroid.channel.MethodChannelActivity.test1000(MethodChannelActivity.java:302)
    at com.ycbjie.ycandroid.channel.MethodChannelActivity.access$000(MethodChannelActivity.java:46)
    at com.ycbjie.ycandroid.channel.MethodChannelActivity$1.run(MethodChannelActivity.java:98)
    at java.lang.Thread.run(Thread.java:818)

12.Flutter给NA发送数据

从method.invokeMethod('android', map);开始分析

@optionalTypeArgs
  Future<T> _invokeMethod<T>(String method, { bool missingOk, dynamic arguments }) async {
    assert(method != null);
    final ByteData result = await binaryMessenger.send(
      name,
      codec.encodeMethodCall(MethodCall(method, arguments)),
    );
    return codec.decodeEnvelope(result) as T;
  }

最后定位到_DefaultBinaryMessenger类中的send方法

Future<ByteData> _sendPlatformMessage(String channel, ByteData message) {
    final Completer<ByteData> completer = Completer<ByteData>();
    // ui.window is accessed directly instead of using ServicesBinding.instance.window
    // because this method might be invoked before any binding is initialized.
    // This issue was reported in #27541. It is not ideal to statically access
    // ui.window because the Window may be dependency injected elsewhere with
    // a different instance. However, static access at this location seems to be
    // the least bad option.
    ui.window.sendPlatformMessage(channel, message, (ByteData reply) {
      try {
        completer.complete(reply);
      } catch (exception, stack) {
        FlutterError.reportError(FlutterErrorDetails(
          exception: exception,
          stack: stack,
          library: 'services library',
          context: ErrorDescription('during a platform message response callback'),
        ));
      }
    });
    return completer.future;
  }

channel传递数据是否会丢失，如何测试呢？可以模拟，Android给flutter发送1000条信息，然后flutter给Android发送1000条信息，接下来看一下如何测试：

13.1 Android给flutter发送数据

Android给flutter发送数据，代码如下所示

int a = 0;
private void test1000() {
    if (nativeChannel!=null){
        for (int i=0 ; i<1000 ; i++){
            a++;
            Log.i("测试数据test1000 ：", a+"");
            nativeChannel.invokeMethod("setNum", a , new MethodChannel.Result() {
                @SuppressLint("SetTextI18n")
                @Override
                public void success(@Nullable Object result) {
                    if (result==null){
                        return;
                    }
                    Log.i("测试数据：",result.toString());
                }

                @SuppressLint("SetTextI18n")
                @Override
                public void error(String errorCode, @Nullable String errorMessage, @Nullable Object errorDetails) {
                    Log.i("测试数据异常：",errorMessage);
                }

                @Override
                public void notImplemented() {

                }
            });
        }
    }
}

flutter接收数据并回传数据给Android

//接受na端传递过来的方法，并做出响应逻辑处理
  method.setMethodCallHandler(nativeCallHandler);

  // 注册方法，等待被原生通过invokeMethod唤起
  Future<dynamic> nativeCallHandler(MethodCall methodCall) async {
    switch (methodCall.method) {
      case "setNum":
      //获取参数
        int message = await methodCall.arguments;
        print("原生android传递过来的参数为------ $message");
        return "flutter回调数据：${message.toString()}";
        break;
    }
  }

13.2 查看数据稳定性和及时性

Android发送消息日志

2021-08-26 11:58:03.837 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 990
2021-08-26 11:58:03.837 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 991
2021-08-26 11:58:03.837 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 992
2021-08-26 11:58:03.837 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 993
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 994
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 995
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 996
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 997
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 998
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 999
2021-08-26 11:58:03.838 23106-23106/com.ycbjie.ychybrid I/测试数据test1000：: 1000

flutter接收Android发送数据

2021-08-26 11:52:39.708 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 992
2021-08-26 11:52:39.709 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 993
2021-08-26 11:52:39.709 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 994
2021-08-26 11:52:39.709 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 995
2021-08-26 11:52:39.709 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 996
2021-08-26 11:52:39.710 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 997
2021-08-26 11:52:39.710 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 998
2021-08-26 11:52:39.710 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 999
2021-08-26 11:52:39.710 23106-23627/com.ycbjie.ychybrid I/flutter: 原生android传递过来的参数为------ 1000

flutter收到消息后，回调给Android数据。Android监听回调数据，打印日志如下

2021-08-26 11:58:03.964 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：600
2021-08-26 11:58:03.964 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：601
2021-08-26 11:58:03.964 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：602
2021-08-26 11:58:03.965 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：603
2021-08-26 11:58:03.965 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：604
2021-08-26 11:58:03.965 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：605
2021-08-26 11:58:03.965 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：606
2021-08-26 11:58:03.966 23106-23106/com.ycbjie.ychybrid I/测试数据：: flutter回调数据：607

然后再看一波打印日志，如下所示

2021-08-26 12:07:09.158 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 1
2021-08-26 12:07:09.237 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：1
2021-08-26 12:07:09.240 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 2
2021-08-26 12:07:09.241 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 3
2021-08-26 12:07:09.241 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：2
2021-08-26 12:07:09.241 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：3
2021-08-26 12:07:09.241 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 4
2021-08-26 12:07:09.241 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：4
2021-08-26 12:07:09.241 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 5
2021-08-26 12:07:09.241 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：5
2021-08-26 12:07:09.242 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 6
2021-08-26 12:07:09.242 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：6
2021-08-26 12:07:09.242 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 7
2021-08-26 12:07:09.242 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：7

2021-08-26 12:07:09.272 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 131
2021-08-26 12:07:09.273 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：131
2021-08-26 12:07:09.273 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 132
2021-08-26 12:07:09.273 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：132
2021-08-26 12:07:09.273 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 133
2021-08-26 12:07:09.273 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：133
2021-08-26 12:07:09.273 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 134
2021-08-26 12:07:09.273 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：134
2021-08-26 12:07:09.273 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 135
2021-08-26 12:07:09.274 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：135
2021-08-26 12:07:09.274 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 136
2021-08-26 12:07:09.274 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：136
2021-08-26 12:07:09.274 24237-24990/com.ycbjie.ychybrid I/flutter: 测试数据，flutter接收NA数据： 137
2021-08-26 12:07:09.274 24237-24237/com.ycbjie.ychybrid I/测试数据，NA接收flutter回调：: flutter回调数据：137

因此查看日志可以得知，传递数据保证了数据的时效性，发送消息和接收消息是一一对应。并没有失败的情况，因此传递数据是稳定的。
重点说明，有小伙伴有疑惑，你这遍历1000次，每次传递都是int值，那实际开发中可能传递大json，数据量大的情况会怎样，这个下面会说到……

先说一个场景
- 在开发中我们经常会遇到关闭当前页面的同时返回给上一个页面数据的场景，在Android中是通过startActivityForResult和onActivityResult()实现的。
- 而纯Flutter页面之间可以通过在Navigator.of(context).pop()方法中添加参数来实现，那么对于Flutter页面和Android原生页面之间如何在返回上一页时传递数据呢，通过MethodChannel就可以实现。

14.1 Flutter页面返回Android原生页面

在Flutter端调用原生的返回方法就可以了，首先在Flutter页面添加一个按钮，点击按钮返回原生页面，代码如下：

new Padding(
    padding: const EdgeInsets.only(
        left: 10.0, top: 10.0, right: 10.0),
    child: new RaisedButton(
        textColor: Colors.black,
        child: new Text('返回上一界面，并携带数据'),
        onPressed: () {
            Map<String, dynamic> map = {'message': '我从Flutter页面回来了'};
            String result = await method.invokeMethod('goBackWithResult', map);
        }),
  ),

Android端依然是通过判断methodCall.method的值来执行指定的代码，通过methodCall.argument()获取Flutter传递的参数。

nativeChannel.setMethodCallHandler(new MethodChannel.MethodCallHandler() {
    @Override
    public void onMethodCall(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
        if ("goBackWithResult".equals(methodCall.method)) {
            // 返回上一页，携带数据
            Intent backIntent = new Intent();
            backIntent.putExtra("message", (String) methodCall.argument("message"));
            setResult(RESULT_OK, backIntent);
            finish();
        }
    }
});

14.2 Android原生页面返回Flutter页面

Android原生页面返回Flutter页面
- 这种情况需要原生来调用Flutter代码，和Flutter调用原生方法的步骤是一样的。首先触发flutter页面按钮，从flutter跳转na页面，然后触发na页面返回操作，返回到Flutter页面，并传递数据。

首先是flutter页面触发跳转到na页面的代码操作逻辑，代码如下所示

//flutter
  new Padding(
    padding: const EdgeInsets.only(left: 10.0, top: 10.0, right: 10.0),
    child: new RaisedButton(
        textColor: Colors.black,
        child: new Text('跳转到原生逗比界面，回调结果：$_methodResult1'),
        onPressed: () {
          _jumpToNative();
        }),
  ),

//na，注意na接收到flutter指令后，na是调用startActivityForResult操作跳转到na的新页面
nativeChannel.setMethodCallHandler(new MethodChannel.MethodCallHandler() {
    @Override
    public void onMethodCall(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
        if ("doubi".equals(methodCall.method)) {
            //接收来自flutter的指令
            //跳转到指定Activity
            Intent intent = new Intent(MethodChannelActivity.this, MethodResultActivity.class);
            startActivityForResult(intent,RESULT_OK2);
            //返回给flutter的参数
            result.success("Na收到指令");
        }
    }
});

然后接下来的一步是，从NA返回到flutter页面，然后再去调用flutter方法。具体操作代码如下所示

//na flutter触发打开na的新的页面
public class MethodResultActivity extends AppCompatActivity {

    @SuppressLint("SetTextI18n")
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_android);
        TextView tv = findViewById(R.id.tv);
        tv.setText("flutter页面打开NA页面，测试Android原生页面返回Flutter页面");
        tv.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                Intent intent = new Intent();
                intent.putExtra("message", "我从原生页面回来了");
                setResult(RESULT_OK2, intent);
                finish();
            }
        });
    }
}

// na flutter承载容器的na的原生页面
@Override
protected void onActivityResult(int requestCode, int resultCode, @Nullable Intent data) {
    super.onActivityResult(requestCode, resultCode, data);
    if (data != null && resultCode==RESULT_OK2) {
        // MethodResultActivity返回的数据
        String message = data.getStringExtra("message");
        Map<String, Object> result = new HashMap<>();
        result.put("message", message);
        // 调用Flutter端定义的方法
        nativeChannel.invokeMethod("onActivityResult", result, new MethodChannel.Result() {
            @SuppressLint("SetTextI18n")
            @Override
            public void success(@Nullable Object result) {
                tvContent.setText("测试内容2："+result);
            }

            @SuppressLint("SetTextI18n")
            @Override
            public void error(String errorCode, @Nullable String errorMessage, @Nullable Object errorDetails) {
                tvContent.setText("测试内容：flutter传递给na数据传递错误2");
            }

            @Override
            public void notImplemented() {

            }
        });
    }
}

//flutter
  Future<dynamic> handler(MethodCall call) async {
    switch (call.method) {
      case 'onActivityResult':
        // 获取原生页面传递的参数
        print(call.arguments['message']);
        return "你好，这个是从flutter传递过来的数据";
    }
  }

  flutterChannel.setMethodCallHandler(handler);

Flutter Chanel通信流程

目录介绍

推荐

1.1 交互简单介绍

1.2 核心类重点说明

02.MethodChannel流程

3.1 flutter调用native

3.2 native调用flutter

4.1 native调用flutter

4.2 flutter调用native

10.1flutter端

10.2 native(android)端

11.1 什么是消息编解码器

11.2 四种消息编解码器类型

11.3 编码器的源码分析下

11.4 看StandardMessageCodec

11.5 如何选择合适编解码器

12.1 Android发送通信信息

12.Flutter给NA发送数据

13.1 Android给flutter发送数据

13.2 查看数据稳定性和及时性

14.1 Flutter页面返回Android原生页面

14.2 Android原生页面返回Flutter页面

继续阅读

Flutter 高性能、多功能的全场景滚动容器，一定要看！

Flutter Fish Redux架构演进2.0

初探Flutter在IoT场景下生态和趋势1、IoT系统开发痛点2、Flutter的前世今生

Flutter Boost3.0初探

Flutter如何状态管理

用 Vue.js 构建一个高性能 Flutter 应用

Flutter Chanel通信流程

flutter开发教程之Row使用

Flutter 125: 图解自传 ACE_ICON.ttf 图标库

Flutter 127: 图解基础 Image 小组件

Flutter 121: 图解简易 Slider 滑动条

Flutter 120: Flutter & 腾讯移动通讯 TPNS～

Flutter 流畅度优化实践总结

Flutter三棵树理解

Flutter之测试Http和HttpClient

Flutter之Padding