LDP标签分发协议在建立会话时，双方首先要交换Initialization消息。这个消息里除了存活时间、标签分发方式等参数外，最关键的是一个两字节的Protocol Version字段。如果这个字段协商不一致，后面的标签映射消息根本没有机会被处理。本文用Ruby实现一个最小化的LDP版本协商模块，从二进制报文构造到状态判断全部覆盖。

一、LDP版本协商的触发时机与报文结构

LDP会话建立分为发现阶段和会话建立阶段。发现阶段通过UDP 646端口发送Hello消息，找到邻居后，双方建立TCP连接，然后立即进入初始化阶段。在这个阶段，每一方都要发送一个Initialization消息，消息体中包含Common Session Parameters TLV，而该TLV的第一个字段就是Protocol Version，固定占用两个字节。LDP规定当前协议版本号为1，双方必须完全相同才能继续后续的标签交换。如果版本不一致，接收方会发送Notification消息并关闭TCP连接。

从报文结构上看，LDP PDU头部包含三个字段：Version、PDU Length和LDP Identifier。Version字段本身就是PDU级别的版本声明，它和Initialization消息里的Protocol Version字段是两个不同的概念，但都参与版本协商。PDU头部的Version表示整个PDU的编码版本，而Initialization消息内部的Protocol Version表示LDP协议语义版本。在实际实现中，两者通常保持一致，但解析时要分别处理，不能混为一谈。

为什么LDP的版本协商不做像BGP那样的多版本兼容？因为LDP的协议演进非常保守，从RFC 3036到RFC 5036，协议版本始终是1，没有出现需要向后兼容的复杂场景。因此LDP版本协商的逻辑极其简单：取值相等则继续，不等则拒绝。这种设计降低了实现门槛，但也意味着任何一方使用了非标准扩展版本，都会导致会话直接失败。

二、用Ruby构建LDP PDU和初始化消息

Ruby处理二进制数据非常方便，核心是pack和unpack方法。网络协议字段几乎都采用大端字节序，Ruby的n和N指令分别对应16位和32位网络字节序无符号整数。在构造LDP PDU时，需要先确定消息体的字节长度，再计算PDU Length字段。根据RFC 5036，PDU Length不包括Version和PDU Length本身，只包括LDP Identifier和后面的消息部分，因此它的值等于LDP标识符的6字节加上消息总长度。

下面这段代码展示了如何构建LDP PDU头部和一个简化版的Initialization消息。为了聚焦版本协商，Common Session Parameters TLV只保留了Protocol Version和Keepalive Time两个字段，省略了其他参数，但TLV的封装格式完全遵循标准。

# 构建LDP PDU头部
def build_pdu(ldp_id, message)
  # PDU长度字段的值等于LDP标识符(6字节)加上消息总长度
  pdu_len = 6 + message.bytesize
  [1, pdu_len].pack("n2") + ldp_id + message
end
# 构建简化版Initialization消息
# 消息头: 消息类型(0x0200), 消息长度, 消息ID
# 消息体: Common Session Parameters TLV
# TLV头: 类型(0x0500), 长度
# TLV值: 协议版本(2字节) + 存活时间(2字节)
def build_init_message(version: 1, keepalive: 180)
  tlv_value = [version, keepalive].pack("n2")
  tlv = [0x0500, tlv_value.bytesize].pack("n2") + tlv_value
  msg_id = 1
  # 消息长度字段不包含消息ID本身
  [0x0200, tlv.bytesize, msg_id].pack("n2N") + tlv
end

解析对端数据时，需要严格按照长度字段读取，不能一次读取全部内容，因为TCP是流式协议，可能发生粘包或半包。下面的read_exact方法会循环读取直到拿到指定字节数，read_pdu方法则按照PDU结构依次解析版本、PDU长度、LDP标识符和消息体。

def read_exact(io, length)
  data = io.read(length)
  raise "连接关闭或数据不足" unless data && data.bytesize == length
  data
end
def read_pdu(io)
  version, pdu_len = read_exact(io, 4).unpack("n2")
  ldp_id = read_exact(io, 6)
  message_bytes = read_exact(io, pdu_len - 6)
  [version, ldp_id, message_bytes]
end

这里有一个容易出错的地方：PDU Length字段不包含前4个字节，但包含LDP标识符。因此读取完前4个字节后，需要再读取6字节得到LDP标识符，剩余部分才是消息内容，剩余长度等于pdu_len - 6。很多实现在这里少减了6，导致读取长度错误，随后引发会话异常。

三、实现版本协商判断与通知消息

版本协商的判断流程可以归纳为三步：先检查PDU头部的Version字段是否等于本地支持版本；再检查消息类型是否为Initialization消息；最后从Common Session Parameters TLV中提取Protocol Version字段并与本地版本比较。任何一步不满足，都要向对端发送Notification消息，并关闭连接。Notification消息的类型为0x0001，消息体包含Status TLV，状态码可以选用0x0006 Session Rejected，同时在参数中附带可读的错误原因。

以下代码封装了一个LdpVersionNegotiator类，它负责发送本地初始化消息、解析对端消息并完成版本检查。如果协商成功返回true，失败则返回false并完成通知发送。

class LdpVersionNegotiator
  LOCAL_VERSION = 1
  def negotiate(io)
    local_msg = build_init_message(version: LOCAL_VERSION)
    ldp_id = ["0a0000010000"].pack("H12")
    io.write(build_pdu(ldp_id, local_msg))
    version, _, message_bytes = read_pdu(io)
    if version != LOCAL_VERSION
      send_notification(io, "PDU version not supported")
      return false
    end
    msg_type, msg_len, _ = message_bytes.unpack("n2N")
    if msg_type != 0x0200
      send_notification(io, "Not an initialization message")
      return false
    end
    tlv_type, tlv_len = message_bytes[8, 4].unpack("n2")
    if tlv_type != 0x0500 || tlv_len < 2
      send_notification(io, "Missing common session parameters TLV")
      return false
    end
    remote_version = message_bytes[12, 2].unpack("n").first
    if remote_version != LOCAL_VERSION
      send_notification(io, "Protocol version mismatch")
      return false
    end
    true
  end
  def send_notification(io, reason)
    status_code = 0x0006
    status_value = [status_code, 0, reason.bytesize].pack("n2N") + reason
    tlv = [0x0300, status_value.bytesize].pack("n2") + status_value
    msg_id = 2
    notification = [0x0001, tlv.bytesize, msg_id].pack("n2N") + tlv
    ldp_id = ["0a0000010000"].pack("H12")
    io.write(build_pdu(ldp_id, notification))
  end
end

错误处理在版本协商中不能忽视。除了版本不匹配，还可能遇到TCP连接被重置、消息长度字段异常（比如小于6或大于合理上限）、消息类型未知等情况。Ruby的Socket操作可能抛出Errno::ECONNRESET、EOFError等异常，需要在调用侧进行捕捉。此外，由于LDP使用大端字节序，所有整数都应使用pack("n")或pack("N")转换，使用主机字节序pack("S")或pack("L")会导致跨平台问题。

四、运行测试与抓包验证

为了验证版本协商逻辑，可以编写一个本地测试脚本，用TCPServer模拟一个版本不匹配的对端。对端先读取客户端发来的PDU，然后构造一个版本号为2的PDU回复，预期客户端会拒绝并返回false。这种测试方式不依赖真实网络设备，适合在开发初期快速验证消息格式和判断逻辑。

下面的脚本启动了一个监听在本地端口16460的TCP服务端，模拟对端发送错误版本。客户端连接后调用negotiate方法，最终输出false。

require 'socket'
server = TCPServer.new('127.0.0.1', 16460)
thread = Thread.new do
  client = server.accept
  version, pdu_len = client.read(4).unpack("n2")
  ldp_id = client.read(6)
  client.read(pdu_len - 6)
  bad_tlv_value = [2, 180].pack("n2")
  bad_tlv = [0x0500, bad_tlv_value.bytesize].pack("n2") + bad_tlv_value
  bad_msg = [0x0200, bad_tlv.bytesize, 1].pack("n2N") + bad_tlv
  reply_ldp_id = ["0a0000020000"].pack("H12")
  reply_pdu = [2, 6 + bad_msg.bytesize].pack("n2") + reply_ldp_id + bad_msg
  client.write(reply_pdu)
  client.close
end
sleep 0.1
client_socket = TCPSocket.new('127.0.0.1', 16460)
negotiator = LdpVersionNegotiator.new
result = negotiator.negotiate(client_socket)
puts result
client_socket.close
server.close

除了单元测试，还可以使用Wireshark抓包观察真实的LDP版本协商过程。在过滤器栏输入ldp，可以清晰看到Initialization消息中的Protocol Version字段。如果版本不一致，Wireshark会直接显示Notification消息，并给出错误原因。抓包验证不仅能确认代码逻辑正确，还能帮助发现长度计算错误、字段顺序颠倒等问题。例如，如果PDU Length计算少了6字节，对端会报告Malformed PDU，而不是版本不匹配。

版本协商虽然只占LDP实现的一小部分，但它是最先被执行、也最容易暴露二进制处理功底的部分。借助Ruby简洁的pack/unpack语法和TCP套接字接口，开发者可以在很短时间内搭出一套可运行的版本协商原型，为后续实现标签映射、标签撤销等完整功能打下基础。