Flutter UDP通信插件udp的使用

udp 是一个轻量级的UDP库，适用于Dart语言。它能够帮助开发者在Flutter应用程序中轻松实现UDP协议的网络通信功能。

使用方法

简单用法示例

下面是一个简单的使用例子，展示了如何创建UDP实例、发送数据和接收数据：

import 'package:udp/udp.dart';

void main() async {
  // 创建一个UDP实例并绑定到第一个可用网络接口上的65000端口。
  var sender = await UDP.bind(Endpoint.any(port: Port(65000)));

  // 向广播地址上的65001端口发送一个简单的字符串。
  var dataLength = await sender.send(
      "Hello World!".codeUnits, Endpoint.broadcast(port: Port(65001)));

  print("$dataLength bytes sent.");

  // 创建一个新的UDP实例并绑定到本地地址和65002端口。
  var receiver = await UDP.bind(Endpoint.loopback(port: Port(65002)));

  // 接收\监听数据
  receiver.asStream(timeout: Duration(seconds: 20)).listen((datagram) {
    if (datagram != null) {
      var str = String.fromCharCodes(datagram.data);
      print(str);
    }
  });

  // 关闭UDP实例及其套接字。
  sender.close();
  receiver.close();

  // 多播（Multicast）示例
  var multicastEndpoint =
      Endpoint.multicast(InternetAddress("239.1.2.3"), port: Port(54321));

  var multicastReceiver = await UDP.bind(multicastEndpoint);

  var multicastSender = await UDP.bind(Endpoint.any());

  multicastReceiver.asStream().listen((datagram) {
    if (datagram != null) {
      var str = String.fromCharCodes(datagram?.data);
      print(str);
    }
  });

  await multicastSender.send("Foo".codeUnits, multicastEndpoint);

  await Future.delayed(Duration(seconds: 5));

  multicastSender.close();
  multicastReceiver.close();
}

特性与问题反馈

如果您有特性请求或发现bug，请在issue tracker上提交。

完整的示例Demo

以下是一个更完整的示例，包括了基本的UDP发送和接收，以及多播的使用。为了使代码结构更加清晰，我们将发送者和接收者的逻辑分离，并添加了异常处理以确保程序的健壮性。

发送者代码

import 'package:udp/udp.dart';
import 'dart:async';

Future<void> main() async {
  try {
    // 创建发送者
    var sender = await UDP.bind(Endpoint.any(port: Port(65000)));
    
    // 检查是否成功绑定
    if (!sender.isBound) {
      throw Exception('Failed to bind sender');
    }

    // 发送消息
    var dataLength = await sender.send(
        "Hello from Sender!".codeUnits, Endpoint.broadcast(port: Port(65001)));
    print("$dataLength bytes sent.");

    // 发送多播消息
    var multicastEndpoint =
        Endpoint.multicast(InternetAddress("239.1.2.3"), port: Port(54321));
    await sender.send("Multicast Message".codeUnits, multicastEndpoint);
    print("Multicast message sent.");

    // 关闭发送者
    sender.close();
  } catch (e) {
    print("Error occurred: $e");
  }
}

接收者代码

import 'package:udp/udp.dart';
import 'dart:async';

Future<void> main() async {
  try {
    // 创建接收者
    var receiver = await UDP.bind(Endpoint.loopback(port: Port(65002)));
    
    // 检查是否成功绑定
    if (!receiver.isBound) {
      throw Exception('Failed to bind receiver');
    }

    // 监听消息
    receiver.asStream(timeout: Duration(seconds: 20)).listen((datagram) {
      if (datagram != null) {
        var str = String.fromCharCodes(datagram.data);
        print("Received: $str");
      }
    }, onDone: () {
      print("Listening done.");
    }, onError: (error) {
      print("Error while listening: $error");
    });

    // 创建多播接收者
    var multicastEndpoint =
        Endpoint.multicast(InternetAddress("239.1.2.3"), port: Port(54321));
    var multicastReceiver = await UDP.bind(multicastEndpoint);

    // 监听多播消息
    multicastReceiver.asStream().listen((datagram) {
      if (datagram != null) {
        var str = String.fromCharCodes(datagram.data);
        print("Multicast Received: $str");
      }
    }, onDone: () {
      print("Multicast Listening done.");
    }, onError: (error) {
      print("Error while listening multicast: $error");
    });

    // 等待一段时间后关闭接收者
    await Future.delayed(Duration(seconds: 10));
    receiver.close();
    multicastReceiver.close();
  } catch (e) {
    print("Error occurred: $e");
  }
}

这个完整的示例演示了如何在Flutter应用中使用udp包进行UDP通信，包括普通消息发送接收和多播消息的发送接收。通过将发送者和接收者的逻辑分开，我们可以更好地理解每个部分的工作原理。同时，添加异常处理可以提高程序的稳定性和可靠性。