《MMO 服务器开发》附录 C 实测数据汇总

// file: measurements/appendixc_test.go
// tier: L1
// verify: go test ./measurements/
package measurements

import (
	"os"
	"path/filepath"
	"regexp"
	"strings"
	"testing"
)

// Measurement 是附录 C 的一条实测数据。每一条都必须带出处节号 Source，
// 附录里不允许出现「无出处」的数字。
type Measurement struct {
	Group     string // 主题分组
	Metric    string // 指标名
	Value     string // 数值（含单位，照抄正文）
	Condition string // 测量条件
	Source    string // 出处节号，必须是真实存在的 mmo-net-* slug
}

// Table 是附录 C 的机器可读副本，顺序即正文表格顺序。
var Table = []Measurement{
	// —— 并发与连接 ——
	{"并发与连接", "基线 8 连接吞吐", "4159 rt/s", "8 条连接，本机 10 核，单进程", "mmo-net-02-2-goroutine-per-connection"},
	{"并发与连接", "2000 连接零失败", "conns=2000 failed=0", "错峰建连 5s 摊开，绕开 somaxconn=128", "mmo-net-02-2-goroutine-per-connection"},
	{"并发与连接", "2000 连接 RTT P50（惊群）", "1.339902 s", "2000 条几乎同时 dial，rtt_n=10000", "mmo-net-02-2-goroutine-per-connection"},
	{"并发与连接", "2000 连接 RTT P50（错峰）", "803.416 ms", "错峰建连，rtt_n=10000", "mmo-net-02-2-goroutine-per-connection"},
	{"并发与连接", "2000 连接吞吐（惊群）", "1008 rt/s", "Little 定律 2000 = 1008 × 1.98s", "mmo-net-02-2-goroutine-per-connection"},
	{"并发与连接", "goroutine 栈占用", "约 2053 B/实例", "100000 实例存活，StackInuse +195.8 MiB", "mmo-net-02-3-goroutine-vs-virtual-threads"},
	{"并发与连接", "1000 空连接内存", "约 6.5 KB/连接", "HeapAlloc 增量 / 1000", "mmo-net-06-2-heartbeat-and-timeout"},
	{"并发与连接", "会话表 Bind（单锁 / 64 分片）", "495.2 / 102.6 ns/op", "1000 账号，10 核，64 B/op 1 alloc", "mmo-net-07-1-session-table"},
	// —— 编解码 ——
	{"编解码", "帧固定头尺寸", "11 字节", "length(4)|cmd(2)|seq(4)|flags(1)", "mmo-net-03-1-message-header-and-cmd"},
	{"编解码", "三种编码尺寸", "json=95 B flat=32 B varint=30 B", "TestSizes，同一结构体", "mmo-net-04-1-binary-codec-from-scratch"},
	{"编解码", "JSON 编码 / 解码", "295.8 / 1137.0 ns/op", "-benchmem -count=5", "mmo-net-04-3-codec-benchmark"},
	{"编解码", "扁平化编码 / 解码", "16.7 / 14.1 ns/op", "解码 0 B/op 0 allocs", "mmo-net-04-3-codec-benchmark"},
	{"编解码", "Varint 编码 / 解码", "45.2 / 22.0 ns/op", "解码 0 B/op 0 allocs", "mmo-net-04-3-codec-benchmark"},
	// —— 可靠 UDP 与弱网 ——
	{"可靠 UDP 与弱网", "KCP 报文头 / mss", "24 B / 488 B", "MTU 固定 512", "mmo-net-05-2-kcp-from-scratch"},
	{"可靠 UDP 与弱网", "RTO 收敛", "98 → 82 ms", "链路真实 RTT=60ms", "mmo-net-05-2-kcp-from-scratch"},
	{"可靠 UDP 与弱网", "0% 丢包 P50/P99", "KCP 40.0/49.0 ms；TCP 式 34.7/39.9 ms", "确定性弱网模拟器，300 条", "mmo-net-05-3-lossy-network-benchmark"},
	{"可靠 UDP 与弱网", "5% 丢包 P99", "KCP 155.0 ms；TCP 式 239.6 ms", "冗余 1.14×", "mmo-net-05-3-lossy-network-benchmark"},
	{"可靠 UDP 与弱网", "20% 丢包 P50/P99", "KCP 55.0/357.0 ms；TCP 式 86.8/359.6 ms", "冗余 1.49×", "mmo-net-05-3-lossy-network-benchmark"},
	// —— 定时器与时间轮 ——
	{"定时器与时间轮", "时间轮挂载", "77 ns/op, 79 B, 1 alloc", "interval=10ms, slots=8", "mmo-net-09-2-time-wheel-from-scratch"},
	{"定时器与时间轮", "time.AfterFunc 挂载", "约 120 ns/op, 约 120 B, 1 alloc", "同机对照，N=10000", "mmo-net-09-1-heartbeat-and-cooldown"},
	{"定时器与时间轮", "共享表扫描", "90288 ns/op（10000 条），0 B", "约 9 ns/条，0 allocs", "mmo-net-09-1-heartbeat-and-cooldown"},
	{"定时器与时间轮", "扫描摊销", "约 36 µs/s", "10000 连接，节拍 timeout/8=2.5s", "mmo-net-09-1-heartbeat-and-cooldown"},
	{"定时器与时间轮", "心跳超时精度", "配置 300ms，实测 304–305ms", "看门狗节拍 37.5ms", "mmo-net-06-2-heartbeat-and-timeout"},
	// —— Actor 与背压 ——
	{"Actor 与背压", "邮箱 FIFO 乱序数", "0", "4 发送者 × 1000 条", "mmo-net-10-2-mailbox-and-backpressure"},
	{"Actor 与背压", "背压上界", "Σcap + 1 = 4", "三段 cap=1 的 RejectBlock 链路", "mmo-net-10-2-mailbox-and-backpressure"},
	{"Actor 与背压", "RejectDrop 丢弃数", "8", "容量 2 的邮箱收 10 条", "mmo-net-10-2-mailbox-and-backpressure"},
	{"Actor 与背压", "-race 邮箱测试", "12 个测试全绿", "go test -race", "mmo-net-10-2-mailbox-and-backpressure"},
	// —— 幂等 ——
	{"幂等", "幂等窗口单键内存", "37.8 B/键", "500k 活键 HeapAlloc 增量 / 键数", "mmo-net-11-1-idempotency-window"},
	{"幂等", "窗口活键上界", "100", "100k 键、ttl=100ms、r=1000/s → r×ttl", "mmo-net-11-1-idempotency-window"},
	{"幂等", "Window.Seen 探测", "134 ns/op, 0 allocs", "含一次 map 查找/插入", "mmo-net-11-1-idempotency-window"},
	{"幂等", "FingerprintOf（2 参数）", "≈34 ns/op, 0 allocs", "hash/fnv 全在栈上不逃逸", "mmo-net-11-2-command-id-and-fingerprint"},
	{"幂等", "Settle 命中 / 首次落 store", "37 / 321 ns/op", "首次含 map 插入，151 B/op", "mmo-net-11-3-at-least-once-correctness"},
	{"幂等", "200 次重放授予次数", "1", "窗口 1ms；64 并发同指纹也为 1", "mmo-net-11-3-at-least-once-correctness"},
	// —— 同步与 AOI 带宽 ——
	{"同步与 AOI 带宽", "全量 / 增量快照", "691020 / 2716 B", "500 实体 × 60 tick，每 tick 2 个新实体移动", "mmo-net-12-2-snapshot-and-delta"},
	{"同步与 AOI 带宽", "全量 / 增量比", "254.4×", "同一段变更序列（同机相对量级）", "mmo-net-12-2-snapshot-and-delta"},
	{"同步与 AOI 带宽", "AOI 工作集", "15.5 MB", "100 万实体，格边长 32，256×256 格", "mmo-net-12-3-interest-filtering-bandwidth"},
	{"同步与 AOI 带宽", "半径 32 每客户端", "1245 B/s，查询 7.7–9.2 µs", "3×3 格，mean interest 47.9", "mmo-net-12-3-interest-filtering-bandwidth"},
	{"同步与 AOI 带宽", "半径 128 每客户端 / 扇出", "19698 B/s / 18785 MB/s", "9×9 格，查询 41–65 µs", "mmo-net-12-3-interest-filtering-bandwidth"},
	// —— 路由与扇出 ——
	{"路由与扇出", "单帧去重判定", "约 7.3 ns/op, 0 B, 0 allocs", "64 位滑动窗口", "mmo-net-08-2-sequence-and-ordering"},
	{"路由与扇出", "广播编一次 / 逐条编", "16480 / 67489 ns/op", "1000 连接，编一次 16544 B 3 allocs", "mmo-net-08-3-broadcast-and-fanout"},
	{"路由与扇出", "广播分配次数差", "约 660×", "2001 allocs vs 3 allocs", "mmo-net-08-3-broadcast-and-fanout"},
	// —— 端到端承载 ——
	{"端到端承载", "单世界吞吐天花板", "约 3000–3200 QPS", "50/100 连接持续负载，瓶颈是世界 goroutine", "mmo-net-17-3-bot-and-first-benchmark"},
	{"端到端承载", "50 连接 × 400 请求", "3223 QPS，P50 13.0 / P99 88.2 ms", "失败 0", "mmo-net-17-3-bot-and-first-benchmark"},
	{"端到端承载", "100 连接 × 200 请求", "3008–3160 QPS，P50 26.1 / P99 124–171 ms", "失败 0", "mmo-net-17-3-bot-and-first-benchmark"},
	{"端到端承载", "500 连接 × 20 请求", "1693 QPS，P50 55.6 / P99 477.1 ms", "失败 0", "mmo-net-17-3-bot-and-first-benchmark"},
	{"端到端承载", "1000 连接 × 10 请求", "793 QPS，P50 283.8 / P99 1642.1 ms", "失败 1", "mmo-net-17-3-bot-and-first-benchmark"},
	{"端到端承载", "冒烟 200 连接 × 10 请求", "qps≈1001，p50 0.60 / p99 5.33 ms", "附录 B 复现序列", "mmo-net-appendix-b-environment"},
	// —— 防护 ——
	{"防护", "fuzz 5 秒执行次数", "约 150 万次", "-fuzztime=5s，10 个 worker", "mmo-net-16-1-protocol-fuzz"},
	{"防护", "AES-256-GCM 封解往返", "620 ns/op, 565 B/op, 5 allocs", "256 字节明文，-benchmem", "mmo-net-16-3-packet-encryption-signature"},
	{"防护", "socket write 底噪", "约 80 µs/次", "单连接校准", "mmo-net-06-2-heartbeat-and-timeout"},
	{"防护", "每 IP 上限 / 握手令牌桶", "4 条接纳；突发 3 后拒绝，100ms 恢复 1", "20 条 loopback；Burst=3 Refill=100ms", "mmo-net-16-2-flood-and-conn-exhaustion"},
	// —— Go vs Java 对照 ——
	{"Go vs Java 对照", "goroutine 创建 / 栈", "485 ns/实例 / 约 2053 B", "Go 1.26，n=100000", "mmo-net-02-3-goroutine-vs-virtual-threads"},
	{"Go vs Java 对照", "虚拟线程创建 / 内存", "0.841 µs/实例 / 约 1006 B", "JVM 21.0.12.1，n=100000", "mmo-net-02-3-goroutine-vs-virtual-threads"},
	{"Go vs Java 对照", "平台线程创建 / 内存", "3.603 µs/实例 / 约 479 B", "JVM 21.0.12.1，n=10000", "mmo-net-02-3-goroutine-vs-virtual-threads"},
	{"Go vs Java 对照", "Java 可用处理器 / 最大堆", "6 / 2482 MiB", "Colima 6 vCPU 容器内 JVM 默认", "mmo-net-02-3-goroutine-vs-virtual-threads"},
}

// TestEveryEntryIsComplete 钉死「附录里没有无出处的数字」，并核对分组覆盖。
func TestEveryEntryIsComplete(t *testing.T) {
	if len(Table) == 0 {
		t.Fatal("Table 为空")
	}
	seen := map[string]int{}
	for i, m := range Table {
		if strings.TrimSpace(m.Group) == "" || strings.TrimSpace(m.Metric) == "" ||
			strings.TrimSpace(m.Value) == "" || strings.TrimSpace(m.Condition) == "" ||
			strings.TrimSpace(m.Source) == "" {
			t.Fatalf("第 %d 条字段缺失: %+v", i, m)
		}
		if !strings.HasPrefix(m.Source, "mmo-net-") {
			t.Fatalf("第 %d 条出处 %q 不是本卷 slug", i, m.Source)
		}
		seen[m.Group]++
	}
	for _, g := range []string{"并发与连接", "编解码", "可靠 UDP 与弱网", "定时器与时间轮",
		"Actor 与背压", "幂等", "同步与 AOI 带宽", "路由与扇出", "端到端承载", "防护", "Go vs Java 对照"} {
		if seen[g] == 0 {
			t.Fatalf("分组 %q 没有任何条目", g)
		}
	}
}

var slugRe = regexp.MustCompile(`(?m)^slug:\s*"?([A-Za-z0-9\-]+)"?\s*$`)

// loadRealSlugs 从落盘正文收集真实存在的 slug；目录不可达就跳过，
// 让测试在本机有意义、在别处也不假失败。
func loadRealSlugs(t *testing.T) map[string]bool {
	t.Helper()
	dir := os.Getenv("AEGIS_CONTENT_DIR")
	if dir == "" {
		dir = "/Users/bingrong.yan/projects/birdor/plumephp/content/posts/books/网络与并发内核"
	}
	entries, err := os.ReadDir(dir)
	if err != nil {
		t.Skipf("语料目录不可达，跳过存在性核对: %v", err)
	}
	slugs := map[string]bool{}
	for _, e := range entries {
		if e.IsDir() || !strings.HasSuffix(e.Name(), ".md") {
			continue
		}
		b, err := os.ReadFile(filepath.Join(dir, e.Name()))
		if err != nil {
			t.Fatalf("读取 %s 失败: %v", e.Name(), err)
		}
		if mm := slugRe.FindSubmatch(b); mm != nil {
			slugs[string(mm[1])] = true
		}
	}
	return slugs
}

// TestEverySourceExists 是本附录最硬的一条：每条数据的出处节号都必须在
// 落盘正文里找到对应 slug，写错的节号会在这里被抓出来。
func TestEverySourceExists(t *testing.T) {
	real := loadRealSlugs(t)
	src := map[string]int{}
	for i, m := range Table {
		if !real[m.Source] {
			t.Fatalf("第 %d 条出处 %q 在正文里不存在", i, m.Source)
		}
		src[m.Source]++
	}
	if len(src) < 15 {
		t.Fatalf("出处只覆盖 %d 个节，疑似漏收", len(src))
	}
	t.Logf("收录 %d 条，覆盖 %d 个真实出处节", len(Table), len(src))
}