如何为Dart的RawDatagramSocket设置超时以检测UDP数据流中断？

你的代码里的超时逻辑确实存在问题，主要出在timeout方法的使用方式上，另外UDP事件监听的写法也可以优化：

现存问题 #

• timeout方法误用：RawDatagramSocket的timeout()是给整个流设置一次性全局超时，只会在订阅流之后的timeoutDuration时间内没收到任何事件时触发一次，不会在每次收到UDP包后自动重置计时器。这就导致第一次收到包后，后续的超时判断完全失效。
• 事件监听逻辑不严谨：直接在listen回调里调用receive()，没有判断事件类型（比如RawSocketEvent.read），可能会处理到RawSocketEvent.closed这类非数据事件，多余的receive()调用也可能干扰正常的数据接收流程。

正确实现方式：用独立计时器重置超时 #

要实现「每收到一个包就重置超时计时器，100ms没收到包就触发中断检测」的需求，最可靠的方式是维护一个独立定时器，每次收到UDP数据时就重置这个定时器：

import 'dart:async';
import 'dart:io';

RawDatagramSocket? _udpSocket;
Timer? _timeoutTimer;
// 超时时间设置为100ms
final Duration _timeoutDuration = const Duration(milliseconds: 100);

Future<void> bindSocket(int port) async {
  _udpSocket = await RawDatagramSocket.bind(InternetAddress.anyIPv4, port);
  _startTimeoutTimer();
  _listenToSocket();
}

void _listenToSocket() {
  _udpSocket?.listen((RawSocketEvent event) {
    if (event == RawSocketEvent.read) {
      final Datagram? d = _udpSocket?.receive();
      if (d != null) {
        // 处理收到的数据
        _handleReceivedData(d);
        // 收到数据后重置超时计时器
        _resetTimeoutTimer();
      }
    } else if (event == RawSocketEvent.closed) {
      // 处理socket关闭的情况
      _handleSocketClosed();
    }
  });
}

void _startTimeoutTimer() {
  _timeoutTimer?.cancel();
  _timeoutTimer = Timer(_timeoutDuration, () {
    // 触发超时逻辑，检测到数据流中断
    _handleTimeout();
  });
}

void _resetTimeoutTimer() {
  _startTimeoutTimer();
}

void _handleReceivedData(Datagram d) {
  // 这里写你的数据处理逻辑
}

void _handleTimeout() {
  // 数据流中断的处理逻辑
  print("UDP数据流已中断");
  // 如果需要持续检测，这里可以重新启动计时器
  // _startTimeoutTimer();
}

void _handleSocketClosed() {
  _timeoutTimer?.cancel();
  // 处理socket关闭后的清理逻辑
}

代码说明 #

1. 独立计时器：用Timer维护超时逻辑，每次收到有效UDP包时调用_resetTimeoutTimer()，本质是先取消当前计时器再重新启动一个新的100ms计时器。
2. 事件类型判断：只在RawSocketEvent.read事件时尝试接收数据，避免无效操作。
3. 资源清理：在socket关闭时主动取消计时器，避免内存泄漏。

这样就能准确检测UDP数据流是否中断——只要100ms内没有收到任何包，就会触发超时回调。

内容的提问来源于stack exchange，提问作者aedemirsen