从上图可以看出:
传递字符串和半结构化的信息
,持续通信,收到消息后可以回复此次消息,如:Native将遍历到的文件信息陆续传递到dart,在比如:flutter将从服务端陆续获取到的信息交给Native加工,Native处理完返回等。传递方法调用(method invocation)一次性通信
:如flutter调用Native拍照。用于数据流(event stream)的通信,持续通信,收到消息后无法回复此次消息
,通过长用于Nativie向flutter的通信,如:手机电量变化,网络连接变化,陀螺仪,传感器等;
这三种类型的Channel都是全双向通信,即A<=>B,flutter可以主动发送消息给Native端,并且Native接收到消息后可以做出回应,同样,Native端可以主动发送消息给flutter端,flutter端接收数据后给Native端。
在Platform Channels上传递的消息都是经过编码的,编码的方式也有几种,默认的是用StandardMethodCodec。其他的还有BinaryCodec(二进制的编码), JSONMessageCodec(JSON格式的编码),StringCodec(String格式的编码)。
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) {
}
});
}
}
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。