哈喽,大家好,本来最近在策划写一篇从Native到Dart的通信原理的文章,但是在文章规划的过程中突然想起了一个问题,而且是我一直以来感觉有疑问的事情,那就是到底EventChannel到底是不是全双工通信的呢,所以干脆引申出了这篇文章来好好的给大家讨论下这个问题,以及讨论下网络对于一些观点不假思索不断传播的问题
众所周知从Native到Dart端有三种通信方式也就是三种Channel,如下:
- BasicMessageChannel:用于传递字符串和半结构化的信息。
- MethodChannel:用于传递方法调用(method invocation)。
- EventChannel: 用于数据流(event streams)的通信。
我们先来看看网络对于这三种Channel的描述,截图如下:
截图出处来自于某一篇博客,再例如:
上面截图是某些博客的内容,这个不是针对某些人,而是我觉得很奇怪为什么大部分博客都有这个结论呢?
类似上面的截图如果你细看的话论坛上还有很多,很多人都认为这三种都是全双工通信的,我们先来看看全双工的定义,这个概念来自于嵌入式(我以前做过1年多的Linux嵌入式所以有些了解,当时全是凭爱好自学的)
全双工传输英文写法是:Full-Duplex Transmissions
是指当数据的发送和接收分流,分别由两根不同的传输线传送时,通信双方都能在同一时刻进行发送和接收操作,这样的传送方式就是全双工制。
简单来讲也就是数据可以同时收发,那我们展开来看看为什么EventChannel是单向的呢,我们来看看Android端他的使用:
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;
}
}
使用很简单,除了初始化方法,剩下的是send发生方法,一个onListen监听方法,还有一个onCancel取消方法,在监听中首先onListen会把this.eventSink初始化,eventSink就是对外的通信手段,下面我们简单的来看看他的方法:
public interface EventSink {
/**
* Consumes a successful event.
*
* @param event the event, possibly null.
*/
void success(Object event);
/**
* Consumes an error event.
*
* @param errorCode an error code String.
* @param errorMessage a human-readable error message String, possibly null.
* @param errorDetails error details, possibly null
*/
void error(String errorCode, String errorMessage, Object errorDetails);
/**
* Consumes end of stream. Ensuing calls to {@link #success(Object)} or {@link #error(String,
* String, Object)}, if any, are ignored.
*/
void endOfStream();
}
大家可以看看这个接口里面只有success去发送一个事件,并没有一个接口回调去注册一个监听,再来看看他在Dart(Flutter)端的使用:
@override
void initState() {
_streamSubscription = _eventChannelPlugin
.receiveBroadcastStream('123')
.listen(_onToDart, onError: _onToDartError);
super.initState();
}
void _onToDart(message) {
setState(() {
showMessage = 'EventChannel:'+message;
});
}
void _onToDartError(error) {
print(error);
}
大家可以看看他的Dart(Flutter)端的使用,initState函数里面就包括了两个监听函数,并且_onToDart这里只有监听的步骤却没有发送的方法在里面,足可以说明这个EventChannel并不是全双工的,半双工都谈不上,充其量只是单工而已
这个时候肯定有人会反驳我说你看EventChannel他的receiveBroadcastStream方法里面也是用了MethodChannel来进行通信所以他也算全双工
Dart部分代码:
Stream<dynamic> receiveBroadcastStream([ dynamic arguments ]) {
final MethodChannel methodChannel = MethodChannel(name, codec);
late StreamController<dynamic> controller;
controller = StreamController<dynamic>.broadcast(onListen: () async {
binaryMessenger.setMessageHandler(name, (ByteData? reply) async {
if (reply == null) {
controller.close();
} else {
try {
controller.add(codec.decodeEnvelope(reply));
} on PlatformException catch (e) {
controller.addError(e);
}
}
return null;
});
try {
await methodChannel.invokeMethod<void>('listen', arguments);
} catch (exception, stack) {
FlutterError.reportError(FlutterErrorDetails(
exception: exception,
stack: stack,
library: 'services library',
context: ErrorDescription('while activating platform stream on channel $name'),
));
}
}, onCancel: () async {
binaryMessenger.setMessageHandler(name, null);
try {
await methodChannel.invokeMethod<void>('cancel', arguments);
} catch (exception, stack) {
FlutterError.reportError(FlutterErrorDetails(
exception: exception,
stack: stack,
library: 'services library',
context: ErrorDescription('while de-activating platform stream on channel $name'),
));
}
});
return controller.stream;
}
要我说这些就属于硬扛了,首先他的receiveBroadcastStream中的MethodChannel并没有暴露出来只是在这个方法里面使用,而且只是用来通知对方PlatForm(Native)端可以进行listen监听了或者cancel了,并没有做额外的发送动作,其次最重要的是Dart端EventChannel并没有暴露可以发送的方法出来,所以这种说法不成立
相信大家看到这里也应该清楚了,我写这篇文章没有任何针对的意思,主要是一开始少部分人搞不清楚概念就算了,但是这种观点愈演愈烈我就感觉不太对了想指出来一下,由此也可见网络上很多文章观点大家都没有仔细论证过就复用了,然后不断地拷贝传播就成了今天这个样子,希望大家以后还是要分别的仔细的去对待一些概念以及结论
好了,我是耗子 如有你有任何疑问可以给我提出来,好了今天这篇简短的文章就到这里了,欢迎大家关注我的账号,有问题给我留言,我们下期见···