Go genetlink 怎样给只读请求封装通用消息头

在 Go 里使用 github.com/mdlayher/genetlink 访问 Linux generic netlink 时，多个只读命令通常共享同一段消息头初始化逻辑。更稳妥的做法是把 Command 和 Version 封装成一个小 helper，把 Data 留给具体命令，把 family ID 和 netlink.HeaderFlags 留在调用层。

官方地址：https://pkg.go.dev/github.com/mdlayher/genetlink

这样做的重点不是隐藏所有参数，而是明确每个参数属于哪一层：genetlink.Header 描述 generic netlink 命令，Message.Data 承载命令属性，Execute 再把消息发送到指定 family，并校验收到的回复。

只读请求真正需要统一的是什么

genetlink.Message 由 Header 和 Data 两部分组成。Header.Command 表示要执行的命令，Header.Version 表示该命令使用的版本；而属性编码后的字节应放在 Data 中。只读并不意味着所有请求的 Data 都为空，有些查询仍然需要用属性限定对象。

因此，适合复用的边界是“创建消息对象”，而不是“替调用方决定 family 或请求标志”。下面的静态结构图把这几个责任放在同一张图中，图中关系用于解释代码分层，不是运行截图或运行证据。

先写一个不改变负载的消息头 helper

helper 可以接收命令号、版本号和可选负载，返回一个新的 genetlink.Message。这里使用 append([]byte(nil), data...) 复制切片，避免调用方后续复用或修改原切片时，已经构造好的请求也跟着变化。

package readonly

import "github.com/mdlayher/genetlink"

// NewReadMessage 只封装 generic netlink 头，Data 仍由具体命令定义。
func NewReadMessage(command, version uint8, data []byte) genetlink.Message {
	// 复制负载，避免调用方复用缓冲区后改变待发送消息。
	payload := append([]byte(nil), data...)

	return genetlink.Message{
		Header: genetlink.Header{
			// Command 是目标 family 定义的命令号，不是 family ID。
			Command: command,
			// Version 保留在消息头，方便不同 family 使用各自版本。
			Version: version,
		},
		Data: payload,
	}
}

这个函数故意没有接收 family 名称、family ID 或 netlink.Request。这些值属于发送阶段：同一个消息构造 helper 可以被不同的 family 查询入口复用，而不会把传输策略硬编码进去。

为什么不要把 family 和 flags 一起塞进 helper

family.ID 是运行时通过 GetFamily 找到的，不能由通用消息构造函数凭空决定。请求标志也位于底层 netlink 层：普通单对象读取通常使用 netlink.Request，列表型读取才可能额外使用 netlink.Dump。如果 helper 直接返回“带 Dump 的查询”，调用方就很难表达单对象读取。

package readonly

import (
	"fmt"

	"github.com/mdlayher/genetlink"
	"github.com/mdlayher/netlink"
)

// ExecuteRead 把消息发送层单独保留给调用方可见的 family 和 flags。
func ExecuteRead(c *genetlink.Conn, family genetlink.Family, msg genetlink.Message, dump bool) ([]genetlink.Message, error) {
	flags := netlink.Request
	if dump {
		// 只有需要枚举多条回复时才追加 Dump，避免普通读取被误当成列表查询。
		flags |= netlink.Dump
	}

	if family.ID == 0 {
		// family ID 是内核返回的运行时值，0 通常意味着调用方没有完成发现。
		return nil, fmt.Errorf("family %q has no ID", family.Name)
	}

	return c.Execute(msg, family.ID, flags)
}

这里的 dump 只是示意调用层的选择。真正要不要使用它，仍应按照目标 family 的命令语义决定，不能因为“只读”就一律打开 Dump。

把错误模型拆成三个层次

一个可复用入口至少要区分三类错误。第一类是 family 发现失败，例如名字不存在；第二类是消息发送或回复校验失败；第三类是回复中的属性解码失败。它们的处理动作不同：第一类可以提示能力不可用，第二类要记录请求上下文，第三类要检查协议字段或版本。

package readonly

import (
	"errors"
	"fmt"
	"os"

	"github.com/mdlayher/genetlink"
)

// ResolveFamily 只负责发现 family，不在这里构造任何业务消息。
func ResolveFamily(c *genetlink.Conn, name string) (genetlink.Family, error) {
	family, err := c.GetFamily(name)
	if err != nil {
		if errors.Is(err, os.ErrNotExist) {
			// family 不存在是能力缺失，不应伪装成消息格式错误。
			return genetlink.Family{}, fmt.Errorf("generic netlink family %q is unavailable: %w", name, err)
		}
		return genetlink.Family{}, fmt.Errorf("resolve generic netlink family %q: %w", name, err)
	}
	return family, nil
}

Execute 内部会发送消息、接收一个或多个回复，并按请求校验回复。收到回复后，才进入 netlink.NewAttributeDecoder 等属性解码逻辑；解码失败应该保留原始错误，不要在 helper 里把它改成“请求头错误”。

完整组合：只读请求如何落到一个入口

下面的示例以一个需要命令号、family 版本和已编码属性的查询为例。命令号与属性号应来自目标内核接口的头文件或官方协议定义；示例中的常量只是调用方的占位符，不能当成所有 family 的通用值。

package main

import (
	"errors"
	"fmt"
	"log"
	"os"

	"github.com/mdlayher/genetlink"
	"github.com/mdlayher/netlink"
)

const (
	// 这些数字必须替换成目标 family 的协议常量，不能跨 family 复用。
	familyName = "example_family"
	readCommand = 1
	familyVersion = 1
)

func newReadMessage(command, version uint8, data []byte) genetlink.Message {
	// 复制 Data，让消息对象拥有自己的负载切片。
	return genetlink.Message{
		Header: genetlink.Header{Command: command, Version: version},
		Data: append([]byte(nil), data...),
	}
}

func main() {
	c, err := genetlink.Dial(nil)
	if err != nil {
		log.Fatalf("dial generic netlink: %v", err)
	}
	defer c.Close() // 退出前释放 netlink 连接。

	family, err := c.GetFamily(familyName)
	if err != nil {
		if errors.Is(err, os.ErrNotExist) {
			log.Printf("family %q is not available", familyName)
			return
		}
		log.Fatalf("get family %q: %v", familyName, err)
	}

	// 只读单对象请求可以没有属性；有属性时把已编码字节传入这里。
	request := newReadMessage(readCommand, familyVersion, nil)
	replies, err := c.Execute(request, family.ID, netlink.Request)
	if err != nil {
		log.Fatalf("execute read request: %v", err)
	}

	for i, reply := range replies {
		// 这里应按目标协议解码 reply.Data，不能把原始字节直接当结果字段。
		fmt.Printf("reply[%d]: command=%d version=%d data=%d bytes\\n", i, reply.Header.Command, reply.Header.Version, len(reply.Data))
	}
}

如果目标命令是枚举型读取，把最后一个参数改成 netlink.Request|netlink.Dump；如果是单对象查询，就保持 netlink.Request。消息头 helper 不需要知道这个选择。

接口设计时要保留的兼容边界

官方文档还说明，Conn 可以并发使用，但高吞吐场景应考虑连接池以减少竞争；这属于连接管理取舍，不应该偷偷写进消息头 helper。

常见问题

只读请求的 Data 一定要为空吗？

不一定。没有过滤条件的查询可以传 nil，但需要按对象、接口或属性筛选时，仍要把协议规定的属性编码到 Data。

Header.Version 可以固定为 1 吗？

只有目标 family 的协议明确如此时才可以。通用 helper 应保留版本参数，版本值由调用方依据 family 的协议定义传入。

为什么不直接复用同一个 Message？

如果多个 goroutine 或多次查询会修改 Data，复用同一对象容易产生隐式共享。返回独立消息更容易理解；若确实需要复用，应明确复制策略和并发边界。

什么时候用 Dump？

当目标命令语义是列出一组对象，并且 family 支持 dump 语义时使用。单对象读取不应因为“只读”而自动加上 Dump。

最终可以把原则压缩成一句话：只让 helper 统一 genetlink.Header 和负载所有权，把 family 发现、netlink flags 和回复解码留给更靠近业务的调用层。这样既减少重复代码，也不会把不同 generic netlink family 的协议差异藏起来。