需用真实网卡和IP模拟网络拓扑:通过net.Interfaces()获取网卡,iface.Addrs()提取IPNet并过滤回环地址,节点绑定指定网卡IP+端口;启用IP转发与iptables;用gob序列化带Header的Packet结构体;以time.NewTimer+select控制节点节奏。

用 net.Interface 和 net.ParseIP 给每个节点分配真实网卡/IP
Go 本身不提供虚拟网络栈,想模拟拓扑就得靠宿主机真实网卡和 IP 做隔离。别试图用 localhost 或 127.0.0.1 拼多个“节点”——它们共享同一网络命名空间,根本测不出路由、ARP、多播失效这些真问题。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 提前在机器上配好多个子网的 IP,比如给
enp0s3加192.168.10.1/24,给enp0s8加192.168.20.1/24,再用ip link set dev enp0s8 up启用 - 代码里用
net.Interfaces()扫出可用网卡,再用iface.Addrs()提取*net.IPNet,过滤掉127.0.0.0/8和::1 - 每个“节点”启动时绑定到指定网卡的 IP+端口,例如
net.ListenTCP("tcp", &net.TCPAddr{IP: net.ParseIP("192.168.10.1"), Port: 8001}) - 注意 Linux 默认禁止跨网卡回环通信(如从
192.168.10.1发包到本机192.168.20.1),需开sysctl -w net.ipv4.conf.all.forwarding=1并配iptables规则
用 gob + 自定义 Header 实现带元信息的二进制消息收发
单纯用 json 序列化消息太重,且无法表达“这个包该走哪条链路”“TTL 还剩几跳”这类控制语义;而裸 TCP Write([]byte) 又没法区分消息边界。直接上 gob 最省事,但得自己塞头。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 定义结构体:
type Packet struct { Src, Dst uint16; TTL uint8; Payload interface{} },其中Src/Dst是节点 ID,不是 IP - 发送前用
gob.NewEncoder(conn).Encode(packet),接收端用gob.NewDecoder(conn).Decode(&packet) - 别用
interface{}存原始字节切片——gob会额外编码类型信息;改用[]byte字段,或提前注册具体类型gob.Register((*MyMsg)(nil)) - 如果节点间协议要兼容未来扩展,头字段必须固定长度(如
Src用uint16而非int),否则不同架构机器间 decode 会错位
用 time.Timer + select 控制节点行为节奏,避免 goroutine 泛滥
一个拓扑常有几十个节点,每个节点若用 for { time.Sleep(); do() } 就是几十个阻塞 goroutine,CPU 毛刺明显;用 time.Tick 更糟——它永不释放 timer,泄漏资源。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 每个节点逻辑封装成函数,内部用
timer := time.NewTimer(interval),每次 tick 后timer.Reset(interval) - 在
select中监听timer.C和退出 channel:case ,<code>case - 务必在节点 shutdown 时调用
timer.Stop(),否则 timer 会一直持有 goroutine 直到超时触发 - 如果需要“某个事件只触发一次”,别用
time.AfterFunc——它无法取消;改用time.After+selectdefault 分支 + 外部 flag 控制
用 os/exec.Command 调 tc 和 iptables 注入链路异常
纯 Go 模拟丢包、延迟、乱序,精度差、难复现、还绕不开内核协议栈。真实测试就得动底层工具:Linux 的 tc 控制 qdisc,iptables DROP/MANGLE 包。
实操建议:
立即学习“go语言免费学习笔记(深入)”;
- 写个辅助函数:
runTc(qdisc, dev, delay, loss string) error,执行类似tc qdisc add dev enp0s3 root netem delay 100ms 20ms distribution normal loss 5% - 每加一条规则前先清理:
tc qdisc del dev enp0s3 root 2>/dev/null || true,避免重复添加报错 - 用
iptables -A OUTPUT -s 192.168.10.1 -d 192.168.20.2 -j DROP模拟单向断连,注意方向(OUTPUTvsINPUT)和 IP 必须精确匹配节点绑定地址 - 所有命令都设
cmd.Stdout, cmd.Stderr = os.Stdout, os.Stderr,不然失败时静默,排查极痛苦
真正麻烦的是状态同步:哪个节点该配什么延迟、哪条链路正在被模拟中断、tc 规则是否残留——这些没法靠 Go runtime 管理,得靠外部脚本或配置文件驱动,手抖漏一条就让测试结果失真。










