首页 > IT职业 > IT生活 > flutter与native通信
我们都知道Flutter开发的app是可以同时在iOS和Android系统上运行的。显然Flutter需要有和Native通信的能力。比如说,你的Flutter app要显示手机的电量,而电量只能通过平台的系统Api获取。这时就需要有个机制使得Flutter可以通过某种方式来调用这个系统Api并且获得返回值。那么Flutter是如何做到的呢?答案是Platform Channels。
消息使用Platform Channels(平台通道)在flutter端和native端进行通信,入下图所示:
上图来自Flutter官网,表明了Platform Channels的架构示意图。有细心的同学就要问了,你不是说Flutter和Native通信是通过Platform Channels吗?怎么架构图里面连接他们的是MethodChannel? 其实呢,MethodChannel是Platform Channels中的一种,顾名思义,MethodChannel用起来应该和方法调用差不多。那么还有别的channel?有的,还有EventChannel,BasicMessageChannel等。如果你需要把数据从Native平台发送给Flutter,推荐你使用EventChannel。Flutter framework也是在用这些通道和Native通信,具体可以参考一下FlutterView.java,在这里能看到Platform Channels的更多用法。
这里需要注意一点,为了保证UI的响应,通过Platform Channels传递的消息都是异步的。
在Platform Channels上传递的消息都是经过编码的,编码的方式也有几种,默认的是用StandardMethodCodec。其他的还有BinaryCodec(二进制的编码,其实啥也没干,直接把入参给返回了), JSONMessageCodec(JSON格式的编码),StringCodec(String格式的编码)。
双方通信传递数据只能是如下类型数据,你不能传递一个自己建立的javabean过去。
flutter端:
构造方法原型:
const BasicMessageChannel(this.name, this.codec);
setMessageHandler方法原型
void setMessageHandler(Future<T> handler(T message))
send方法原型
Future<T> send(T message)
import 'package:flutter/services.dart';//需要导入包
static const BasicMessageChannel _basicMessageChannel =
BasicMessageChannel('BasicMessageChannel', StringCodec());
//使用BasicMessageChannel接收来自native的消息,并向native回复
void _reviceData() {
_basicMessageChannel.setMessageHandler(_handlerMessage);
}
Future<String> _handlerMessage(message) async {
return '收到native的消息${message}';
}
//使用BasicMessageChannel向native发送消息,并接收native的回复
void _sendMessage() async {
//response为native回复的消息
try {
String response = await _basicMessageChannel.send('发送给native的消息');
} on PlatformException catch (e) {
print(e);
}
}
Native端:
构造方法原型
public BasicMessageChannel(BinaryMessenger messenger, String name, MessageCodec<T> codec)
setMessageHandler方法原型
public void setMessageHandler(BasicMessageChannel.MessageHandler<T> handler)
BasicMessageChannel.MessageHandler原型
public interface MessageHandler<T> {
void onMessage(T var1, BasicMessageChannel.Reply<T> var2);
}
send方法原型
public void send(T message)
public void send(T message, BasicMessageChannel.Reply<T> callback)
public class MainActivity extends FlutterActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
GeneratedPluginRegistrant.registerWith(this);
BasicMessageChannel basicMessageChannel = new BasicMessageChannel(getFlutterView(), "BasicMessageChannel", StringCodec.INSTANCE);
basicMessageChannel.setMessageHandler(new BasicMessageChannel.MessageHandler() {
@Override
public void onMessage(Object o, BasicMessageChannel.Reply reply) {//处理dart发来的消息
//第一个参数就是dart端发送过来的消息
reply.reply("basicMessageChannel收到消息");//可以通过reply回复消息
}
});
basicMessageChannel.send("发送给dart端的消息", new BasicMessageChannel.Reply() {
@Override
public void reply(Object o) {//来自dart的反馈
}
});
}
}
flutter端:
构造方法原型
const MethodChannel(this.name, [this.codec = const StandardMethodCodec()]);
invokeMethod方法原型
Future<T> invokeMethod<T>(String method, [dynamic arguments])
import 'package:flutter/services.dart';//需要导入包
static const MethodChannel _methodChannel = MethodChannel('_methodChannel');
void _handleMessage() async {
try{
String respone = await _methodChannel.invokeMethod('方法名称','传递的值');
} on PlatformException catch (e) {
print(e);
}
}
Native端:
构造方法原型
//会构造一个StandardMethodCodec.INSTANCE类型的MethodCodec
public MethodChannel(BinaryMessenger messenger, String name)
public MethodChannel(BinaryMessenger messenger, String name, MethodCodec codec)
setMethodCallHandler方法原型
public void setMethodCallHandler(@Nullable MethodChannel.MethodCallHandler handler)
在创建好MethodChannel后,需要调用它的setMethodCallHandler方法为其设置一个消息处理器,用来接收来自flutter端的消息
MethodChannel.MethodCallHandler原型
public interface MethodCallHandler {
void onMethodCall(MethodCall var1, MethodChannel.Result var2);
}
public class MainActivity extends FlutterActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
GeneratedPluginRegistrant.registerWith(this);
MethodChannel methodChannel = new MethodChannel(getFlutterView(), "MethodChannel");
methodChannel.setMethodCallHandler(new MethodChannel.MethodCallHandler() {
@Override
public void onMethodCall(MethodCall methodCall, MethodChannel.Result result) {
if (methodCall.method.equals("MethodChannel")) {
String message = (String) methodCall.arguments; //获取参数
}
result.success("回复给flutter端的消息");
result.error("","","");//如果失败,回复给flutter端的消息
result.notImplemented();//表示android端没有此方法调用
}
});
}
}
构造方法原型
const EventChannel(this.name, [this.codec = const StandardMethodCodec()]);
方法原型
Stream<dynamic> receiveBroadcastStream([dynamic arguments])
static const EventChannel _eventChannel = EventChannel('EventChannel');
StreamSubscription _streamSubscription;
@override
void initState() {
// TODO: implement initState
super.initState();
_streamSubscription = _eventChannel.receiveBroadcastStream().listen(_onData,
onError: _onError, onDone: _onDone, cancelOnError: false);
}
void _onData(message) {}
void _onError(message) {}
void _onDone() {}
@override
void dispose() {
// TODO: implement dispose
super.dispose();
_streamSubscription.cancel();
}
Native端:
构造方法原型
//会构造一个StandardMethodCodec.INSTANCE类型的MethodCodec
public EventChannel(BinaryMessenger messenger, String name)
public EventChannel(BinaryMessenger messenger, String name, MethodCodec codec)
setStreamHandler方法原型
public void setStreamHandler(EventChannel.StreamHandler handler)
StreamHandler 原型
public interface StreamHandler {
void onListen(Object var1, EventChannel.EventSink var2);
void onCancel(Object var1);
}
public class MainActivity extends FlutterActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
GeneratedPluginRegistrant.registerWith(this);
EventChannel eventChannel = new EventChannel(getFlutterView(), "eventChannel");
eventChannel.setStreamHandler(new EventChannel.StreamHandler() {
@Override
public void onListen(Object o, EventChannel.EventSink eventSink) {
}
@Override
public void onCancel(Object o) {
}
});
}
}
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/2920/viewspace-2822762/ ,如需转载,请注明出处,否则将追究法律责任。