Java UDP编程：不可靠传输的优化策略

UDP协议本身不保证数据包的可靠传输，但通过以下策略可在应用层提升可靠性：

1. 序列号机制

为每个数据包添加唯一序列号，接收方按序重组数据：

// 发送端
int sequenceNum = 0;
byte[] data = (sequenceNum + ":" + payload).getBytes();
DatagramPacket packet = new DatagramPacket(data, data.length, address, port);

// 接收端
String received = new String(packet.getData());
int receivedSeq = Integer.parseInt(received.split(":")[0]);
if (receivedSeq > lastSeq) { // 处理新数据包
    lastSeq = receivedSeq;
    // 处理有效载荷
}

2. 确认重传机制（ACK）

• 发送方：启动定时器，超时未收到ACK则重传
• 接收方：收到有效包后返回ACK

// 接收方返回ACK
byte[] ack = ("ACK:" + sequenceNum).getBytes();
socket.send(new DatagramPacket(ack, ack.length, senderAddress, senderPort));

// 发送方处理ACK
if (received.startsWith("ACK")) {
    int ackNum = Integer.parseInt(received.split(":")[1]);
    cancelTimer(ackNum); // 停止对应计时器
}

3. 前向纠错（FEC）

通过冗余数据恢复丢失包，如XOR编码： $$ P_k = D_1 \oplus D_2 \oplus \cdots \oplus D_n $$ 其中$P_k$为校验包，$D_i$为数据包。丢失任一$D_i$可通过其余包与$P_k$异或恢复。

4. 滑动窗口协议

实现流量控制，允许多个数据包在途传输：

// 发送窗口管理
int windowSize = 5; // 窗口大小
int baseSeq = 0;   // 窗口起始序列号
int nextSeq = 0;   // 下一个待发送序列号

while (nextSeq < baseSeq + windowSize) {
    sendPacket(nextSeq++); // 发送窗口内数据包
}

5. 自适应速率控制

根据网络状况动态调整发送速率：

double currentRate = 1024; // 初始速率 1KB/s
double lossThreshold = 0.05; // 丢包率阈值

if (packetLossRate > lossThreshold) {
    currentRate *= 0.8; // 丢包严重时降速20%
} else if (packetLossRate < 0.01) {
    currentRate *= 1.1; // 网络良好时提速10%
}

6. 心跳检测

维持连接状态，检测节点失效：

// 每30秒发送心跳包
scheduledExecutor.scheduleAtFixedRate(() -> {
    sendHeartbeat();
}, 0, 30, TimeUnit.SECONDS);

策略选择建议

1. 实时音视频：优先FEC + 自适应速率控制
2. 文件传输：序列号 + ACK重传 + 滑动窗口
3. 物联网传感数据：心跳检测 + 简易序列号

⚠️ 注意：过度优化可能违背UDP的设计初衷。需根据业务场景权衡可靠性与延迟，例如视频通话中少量丢包优于高延迟。