Flutter-UDP基本编程

前言

本文将介绍基于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, onError: 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<int> 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;