Golang中Net包：如何在已连接的UDP套接字上发送数据包

这是一个来自TCP监听器的TCP套接字。传入的UDP数据包不可能出现在该代码部分。

"已连接的UDP套接字"与TCP套接字并不相同。

但事实确实如此：我可以展示printf()的输出。当在Linux上用C语言编写的远端，在已连接的套接字上执行sendto()发送一个10字节的UDP数据包时（由于套接字已连接，目标地址为null），这个10字节的UDP数据包会从TCP套接字的Read()调用中弹出。

虽然我知道Golang使用了这个术语，但我不理解"已连接UDP套接字"这个概念：实际上并不存在这样的东西，因为UDP是无连接的。

当然。我还没有提交读取和响应UDP数据包的部分，因为它目前无法正常工作，但这一行是UDP数据包到达的位置：如果我在那里插入printf()函数，当我从远端发送UDP数据包时，可以清楚地看到我的UDP数据包到达。

为什么您认为UDP数据包到达已连接的套接字是不合理的？仅仅因为套接字已连接，并不意味着与无连接的UDP数据包传输有任何关联。它们随时都可以双向传输，这正是其设计特点。

那么printf()的出现是否只是Linux中某种未指定的行为，允许我在以SOCK_STREAM方式打开的套接字上使用sendto()？关于sendto()的文档说明：

如果在面向连接的套接字（SOCK_STREAM、SOCK_SEQPACKET）上使用sendto()，参数dest_addr和addrlen将被忽略（当它们非NULL且不为0时可能会返回错误EISCONN），并且当套接字未实际连接时会返回错误ENOTCONN。

是否有可能以这种方式调用sendto()时，底层实际上发送的是TCP数据包而非UDP数据包？

在 Go 中，net.TCPConn 和 net.UDPConn 是不同的类型，不能直接相互转换，因为它们底层处理的是不同的传输层协议。你的需求是在已经建立的 TCP 连接上发送 UDP 数据包，这在网络协议层面是不可能的，因为 TCP 和 UDP 是独立的协议，具有不同的连接语义。

然而，从你的描述来看，你可能误解了 SSH 端口转发隧道的行为。SSH 隧道通常用于转发 TCP 流量，而不支持 UDP（除非使用特定扩展如 netcat 模式）。如果你在 SSH 隧道中尝试发送 UDP 数据包，它可能被丢弃或导致错误，因为 SSH 本身不处理 UDP。

如果你确实需要在同一网络地址上同时处理 TCP 和 UDP，正确的方法是使用两个独立的套接字：一个 net.TCPConn 用于 TCP 通信，另一个 net.UDPConn 用于 UDP。以下是一个示例代码，展示如何在同一个 Go 程序中创建 TCP 和 UDP 服务器，并响应 UDP 数据包：

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    // 启动 TCP 服务器
    go startTCPServer()
    // 启动 UDP 服务器
    go startUDPServer()
    
    // 保持程序运行
    select {}
}

func startTCPServer() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("TCP Server error:", err)
        return
    }
    defer listener.Close()
    fmt.Println("TCP Server listening on :8080")
    
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("TCP accept error:", err)
            continue
        }
        go handleTCPConnection(conn)
    }
}

func handleTCPConnection(conn net.Conn) {
    defer conn.Close()
    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            fmt.Println("TCP read error:", err)
            return
        }
        fmt.Printf("TCP received: %s\n", string(buffer[:n]))
        // 处理 TCP 数据，例如回显
        conn.Write(buffer[:n])
    }
}

func startUDPServer() {
    addr, err := net.ResolveUDPAddr("udp", ":8080")
    if err != nil {
        fmt.Println("UDP resolve error:", err)
        return
    }
    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println("UDP listen error:", err)
        return
    }
    defer conn.Close()
    fmt.Println("UDP Server listening on :8080")
    
    buffer := make([]byte, 1024)
    for {
        n, clientAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            fmt.Println("UDP read error:", err)
            continue
        }
        fmt.Printf("UDP received from %s: %s\n", clientAddr, string(buffer[:n]))
        
        // 回显 UDP 数据包，包括时间戳
        response := fmt.Sprintf("Echo at %v: %s", time.Now(), string(buffer[:n]))
        _, err = conn.WriteToUDP([]byte(response), clientAddr)
        if err != nil {
            fmt.Println("UDP write error:", err)
        }
    }
}

在这个示例中：

• TCP 服务器监听端口 8080，处理传入的 TCP 连接。
• UDP 服务器也监听端口 8080，读取 UDP 数据包并回显，附加当前时间戳。

如果你坚持要通过同一个套接字发送 UDP 数据包，这在标准 Go net 包中不可行，因为 net.TCPConn 不提供 UDP 方法。你提到的 Linux sendto 系统调用用于 UDP 套接字，而不是 TCP 套接字。在 Go 中，你必须使用 net.UDPConn 来发送 UDP 数据包。

对于你的 SSH 隧道测试场景，考虑以下替代方案：

1. 使用独立的 UDP 套接字进行测试，但通过相同的网络路径（例如，配置 SSH 隧道支持 UDP，如果可能）。
2. 在应用层实现一个简单的基于 TCP 的“心跳”协议来测试连接状态，而不是依赖 UDP。

如果你必须使用 UDP 测试 SSH 隧道，请检查你的 SSH 客户端和服务器是否支持 UDP 转发（例如，通过 -w 选项在 OpenSSH 中创建 tun/tap 设备）。但这不是标准端口转发的一部分，可能需要额外配置。