Flutter-UDP基本编程
星野米奥2021年1月14日FLUTTER, 笔记
链接: https://www.mengmei.moe/note/1968.html.
前言
本文将介绍基于dart:io的Socket,进行TCP基本编程,实现双方的监听、连接、数据收发。
示例代码:[https://gitee.com/tilongzs/flutter_study_demo/tree/master/socket_udp_test]
使用插件:
wifi_ip: ^0.0.1
创建socket
bind
通过RawDatagramSocket.bind()来创建一个RawDatagramSocket,参数指定为要bind的IP、端口。
_bindSocket = await RawDatagramSocket.bind(IP, port);
listen
通过_bindSocket.listen()来绑定onData、Error、Close事件处理函数。
_bindSocket.listen(onSocketEvent, one rror: onSocketError, onDone:
onSocketClose);
onSocketEvent()处理read、write、readClosed、closed事件,这几个事件在RawSocketEvent里定义。
在RawSocketEvent.read事件触发时,调用_bindSocket.receive()读取收到的数据。示例代码里假定接收到的是UTF8数据。
在RawSocketEvent.write事件触发时,可以使用_bindSocket.send()进行发送数据,该事件只触发一次。
在RawSocketEvent.closed事件触发时,表面_bindSocket被关闭了,接着Close事件也会触发。
void onSocketEvent(RawSocketEvent e){
switch(e){
case RawSocketEvent.read:
{
Datagram dg = _bindSocket.receive();
var decoder = Utf8Decoder();
String msg = decoder.convert(dg.data); // 将UTF8数据解码
printLog('收到来自${dg.address.toString()}:${dg.port}的数据:${dg.data.length}字节数据 内容:$msg');
}
break;
case RawSocketEvent.write:
{
printLog('RawSocketEvent.write');
}
break;
case RawSocketEvent.readClosed:
{
printLog('RawSocketEvent.readClosed');
}
break;
case RawSocketEvent.closed:
{
printLog('RawSocketEvent.closed');
}
break;
}
}
发送数据
使用_bindSocket.send(List buffer, InternetAddress address, int port)发送数据。
onBtnSendMsg()示例发送UTF8数据。
void onBtnSendMsg() async {
if (_sendMsgController.text.isNotEmpty) {
if (_bindSocket != null) {
var encoder = Utf8Encoder(); // 创建UTF8转换器,以支持发送中文
_bindSocket.send(encoder.convert(_sendMsgController.text), InternetAddress.tryParse(_IPTxtController.text), int.tryParse(_portTxtController.text)); // 发送
}
_sendMsgController.text = '';
setState(() {});
}
}
关闭socket
_bindSocket.close();
_bindSocket = null;