Function TestCall_Concurrent

internal/nodehub/hub_test.go:283–322

---- 测试：并发 Call ----

(t *testing.T)

// ---- 测试：并发 Call ----

func TestCall_Concurrent(t *testing.T) {
	hub := New(Options{PeerExtractor: mdPeerExtractor})
	env := newTestEnv(t, hub)
	cc := env.dial(t)
	mock := startNodeMock(t, cc, "n")
	waitOnline(t, hub, "n")

	mock.handle("echo", func(reqID string, body []byte) (bool, []byte, string) {
		return true, body, ""
	})

	const N = 100
	var wg sync.WaitGroup
	wg.Add(N)
	errs := make(chan error, N)
	for i := 0; i < N; i++ {
		i := i
		go func() {
			defer wg.Done()
			payload, _ := json.Marshal(map[string]int{"i": i})
			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
			defer cancel()
			raw, err := hub.Call(ctx, "n", "echo", json.RawMessage(payload))
			if err != nil {
				errs <- fmt.Errorf("call %d: %w", i, err)
				return
			}
			// raw 是 node 把 body 原样回的字节；但我们把 RawMessage 序列化时
			// 会被双重编码，所以这里只校验非空与可解析。
			if len(raw) == 0 {
				errs <- fmt.Errorf("call %d: empty body", i)
			}
		}()
	}
	wg.Wait()
	close(errs)
	for err := range errs {
		t.Error(err)
	}
}

// ---- 测试：重连踢旧连接 ----