Flutter-UDP基本编程

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;
上一篇:Java递归方法


下一篇:Oracle21c RAC+DG生产项目实战(RHEL8+Oracle集群+容灾+CDB/PDB)