Android VPNService代理开发：IPv4报文解析异常问题求助

核心问题定位 #

你的解析异常主要来自三个关键错误：字节序不匹配、ByteBuffer操作错误、位操作方法调用错误。

1. 网络字节序与ByteBuffer默认字节序不匹配 #

IPv4报文采用大端序（网络字节序），但Java/Kotlin的ByteBuffer默认是小端序，直接读取short/int会导致数值完全错乱（比如totalLength变成1、protocol变成0）。

2. ByteBuffer初始化错误 #

你直接通过input.read(buffer.array())写入缓冲区后，仅设置了limit(read)，但未重置position到0，导致后续buffer.get()等读取操作从错误的位置开始，解析出随机值。

3. 位操作方法调用类型不匹配 #

你将buffer.get()得到的Byte转成UByte后直接调用split()，但split()是UShort的扩展方法，自动装箱会破坏IPv4首字节的版本+头部长度结构。

修复方案 #

第一步：修正ByteBuffer的字节序与初始化逻辑 #

修改receivePackets方法，确保ByteBuffer使用大端序，且读取前重置position：

fun receivePackets(input: FileInputStream, output: FileOutputStream, buffer: ByteBuffer) {
    val read = input.read(buffer.array())

    if (read > 0) {
        buffer.clear() // 重置position为0，limit为capacity
        buffer.limit(read)
        buffer.order(ByteOrder.BIG_ENDIAN) // 强制使用网络字节序

        val packet = IpDatagram(buffer)

        Log.d(Tag, "Received packet: $packet which is " +
                if (packet.valid) "valid" else "invalid"
        )
    }
}

第二步：修正位操作方法的类型适配 #

给UByte添加对应的扩展方法，避免类型转换错误：

// 新增UByte的split方法，替换原UShort的split（或保留UShort版本，新增UByte版本）
fun UByte.split(): Pair<UByte, UByte> {
    return Pair((this.toInt() shr 4).toUByte(), (this.toInt() and 0x0F).toUByte())
}

// 新增UByte的extract方法，用于DSCP/ECN提取
fun UByte.extract(count: Int): Pair<UByte, UByte> {
    return Pair((this.toInt() shr count).toUByte(), (this.toInt() and ((1 shl count) - 1)).toUByte())
}

第三步：修正IPv4解析逻辑中的读取方式 #

避免直接操作buffer.array()，改用ByteBuffer的相对读取方法，同时修正options和data的提取：

// IPv4报文解析代码修正
val firstByte = buffer.get().toUByte()
val (version, internetHeaderLength) = firstByte.split()

// Differentiated Services Code Point, Explicit Congestion Notification (TOS)
val tosByte = buffer.get().toUByte()
val (dscp, ecn) = tosByte.extract(2)

val totalLength = buffer.short.toUShort()
val identification = buffer.short.toUShort()
val flagsAndOffset = buffer.short.toUShort()
val (flags, fragmentOffset) = flagsAndOffset.extract(3)
val timeToLive = buffer.get().toUByte()
val protocol = buffer.get().toUByte()
val headerChecksum = buffer.short.toUShort()
val sourceAddress = buffer.int
val destinationAddress = buffer.int

// 读取options
val optionsLength = (internetHeaderLength.toInt() * 4) - 20
val options = if (optionsLength > 0) {
    val optionsBytes = ByteArray(optionsLength)
    buffer.get(optionsBytes)
    optionsBytes
} else {
    byteArrayOf()
}

// 读取payload数据
val payloadLength = totalLength.toInt() - (internetHeaderLength.toInt() * 4)
val data = if (payloadLength > 0) {
    val payloadBytes = ByteArray(payloadLength)
    buffer.get(payloadBytes)
    payloadBytes
} else {
    byteArrayOf()
}

第四步：验证版本字段的合法性 #

在解析后添加版本校验，过滤无效报文：

val valid = version == 4.toUByte() && internetHeaderLength >= 5.toUByte()

额外注意事项 #

• VPNService接收的报文可能包含IPv6报文，建议先判断版本字段，再选择对应的解析逻辑
• 处理分片报文时，需要根据flags和fragmentOffset进行重组
• 直接操作buffer.array()会暴露整个缓冲区的原始数据，容易引入脏数据，建议始终使用ByteBuffer的get()方法读取

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