golang socks5代理服务器中专

### 实现 SOCKS5 代理服务器

#### 使用 Golang 创建 SOCKS5 代理服务器的核心逻辑在于处理客户端请求并转发流量至目标地址。下面是一个简单的实现方法：

首先，导入必要的库：

import (
    "crypto/tls"
    "fmt"
    "net"

    "golang.org/x/crypto/ssh"
)

定义一个函数用于启动 SOCKS5 代理服务器：

func startSOCKSServer(addr string) error {
    listener, err := net.Listen("tcp", addr)
    if err != nil {
        return fmt.Errorf("failed to listen on %s: %v", addr, err)
    }
    
    defer listener.Close()
    
    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }

        go handleConnection(conn)
    }
}

编写 `handleConnection` 函数来处理每个连接：

func handleConnection(clientConn net.Conn) {
    // 处理握手协议部分...
    buffer := make([]byte, 262) // RFC规定最大长度为262字节
    
    _, err := io.ReadFull(clientConn, buffer[:2])
    if err != nil || buffer[0] != 0x05 { // 版本号应为5
        clientConn.Close()
        return
    }

    methodsCount := int(buffer[1])
    _, err = io.ReadFull(clientConn, buffer[:methodsCount])
    if err != nil {
        clientConn.Close()
        return
    }

    // 响应回客户端表示支持无认证方式
    response := []byte{0x05, 0x00} 
    _, _ = clientConn.Write(response)

    // 接收来自客户端的目标地址信息
    _, err = io.ReadFull(clientConn, buffer[:4]) 
    if err != nil {
        clientConn.Close()
        return
    }

    cmd := buffer[1]
    if cmd != 0x01 { // 只处理CONNECT命令
        clientConn.Close()
        return
    }

    targetAddrType := buffer[3]

    var host string
    switch targetAddrType {
    case 0x01: // IPv4 地址
        ipBytes := make([]byte, net.IPv4len)
        _, err = io.ReadFull(clientConn, ipBytes)
        if err != nil {
            clientConn.Close()
            return
        }
        host = net.IP(ipBytes).String()

    case 0x03: // 域名
        domainLen := buffer[4]
        domainBytes := make([]byte, domainLen)
        _, err = io.ReadFull(clientConn, domainBytes)
        if err != nil {
            clientConn.Close()
            return
        }
        host = string(domainBytes)

    default:
        clientConn.Close()
        return
    }

    portBytes := make([]byte, 2)
    _, err = io.ReadFull(clientConn, portBytes)
    if err != nil {
        clientConn.Close()
        return
    }

    port := binary.BigEndian.Uint16(portBytes)

    remoteConn, err := net.Dial("tcp", fmt.Sprintf("%s:%d", host, port))
    if err != nil {
        clientConn.Close()
        return
    }

    successReply := []byte{
        0x05,
        0x00,
        0x00,
        0x01,
        0x00, 0x00, 0x00, 0x00,
        0x00, 0x00,
    } 

    _, _ = clientConn.Write(successReply)

    copyDataBetweenConns(clientConn, remoteConn)
}

// 把两个连接之间的数据相互复制直到任意一方关闭
func copyDataBetweenConns(c1, c2 net.Conn) {
    done := make(chan struct{})
    go func() {
        io.Copy(c1, c2)
        close(done)
    }()
    go func() {
        io.Copy(c2, c1)
        close(done)
    }()
    <-done
    c1.Close()
    c2.Close()
}

这段代码展示了如何构建基本的SOCKS5代理功能[^1]。

对于更复杂的需求比如通过SSH隧道建立远程代理，则可以利用 Go 的官方 SSH 库 (`golang.org/x/crypto/ssh`) 来完成身份验证和安全通道建立的工作。