Method TracerouteHops

internal/nodeapi/traceroute.go:47–134

TracerouteHops 启动一次 traceroute，将每跳与终态（错误/完成）通过 channel 投递。 通道在追踪结束（reach 或超时）或 ctx 取消后关闭。

(ctx context.Context, req TracerouteRequest)

// TracerouteHops 启动一次 traceroute，将每跳与终态（错误/完成）通过 channel 投递。
// 通道在追踪结束（reach 或超时）或 ctx 取消后关闭。
func (a *API) TracerouteHops(ctx context.Context, req TracerouteRequest) <-chan TracerouteEvent {
	out := make(chan TracerouteEvent, tracerouteMaxHops+2)
	go func() {
		defer close(out)
		host := strings.TrimSpace(req.Host)
		if host == "" {
			out <- TracerouteEvent{Err: "host 参数不能为空"}
			return
		}
		if strings.ContainsAny(host, " ;|&`$(){}[]<>\\'\"") {
			out <- TracerouteEvent{Err: "host 包含非法字符"}
			return
		}
		method := req.Method
		if method != "tcp" {
			method = "icmp"
		}
		port := req.Port
		if port <= 0 || port > 65535 {
			port = 80
		}

		addrs, err := net.DefaultResolver.LookupHost(ctx, host)
		if err != nil || len(addrs) == 0 {
			out <- TracerouteEvent{Err: fmt.Sprintf("DNS 解析失败: %v", err)}
			return
		}
		destIP := net.ParseIP(addrs[0])
		isIPv6 := destIP.To4() == nil

		runCtx, cancel := context.WithTimeout(ctx, tracerouteTotalLimit)
		defer cancel()

		hopCh := make(chan TracerouteHop, tracerouteMaxHops)
		doneCh := make(chan error, 1)
		go func() {
			var e error
			if method == "tcp" {
				if isIPv6 {
					e = traceTCPv6(runCtx, destIP, port, hopCh)
				} else {
					e = traceTCPv4(runCtx, destIP.To4(), port, hopCh)
				}
			} else {
				if isIPv6 {
					e = traceICMPv6(runCtx, destIP, hopCh)
				} else {
					e = traceICMPv4(runCtx, destIP.To4(), hopCh)
				}
			}
			doneCh <- e
		}()

		for {
			select {
			case hop, ok := <-hopCh:
				if !ok {
					hopCh = nil