我需要通过代理连接到ftp服务器,并从Golang代码下载文件.我已经实现了简单客户端:

package main

import (
    "bufio"
    "fmt"
    "github.com/jlaffaye/ftp"
    "io"
    "log"
    "net"
    "net/http"
    "os"
    "strings"
    "time"
)

var targetAddr = "ftp.dlptest.com"
var proxyAddr = "146.19.106.109:3128"
var user = "dlpuser"
var pass = "rNrKYTX9g7z3RgJRmxWuGHbeu"
var path = "/xxx.txt"

func connectViaProxy(network, address string) (net.Conn, error) {

    parts := strings.Split(address, ":")
    addr := fmt.Sprintf("%s:%s", targetAddr, parts[1])

    proxyConn, err := net.Dial(network, proxyAddr)
    if err != nil {
        return nil, err
    }

    req, err := http.NewRequest(http.MethodConnect, "http://"+addr, nil)
    if err != nil {
        proxyConn.Close()
        return nil, err
    }

    req.Header.Set("Accept", "*/*")
    req.Header.Set("User-Agent", "curl/8.1.2")
    req.Header.Set("Host", targetAddr+":21")

    err = req.Write(proxyConn)
    if err != nil {
        return nil, err
    }

    resp, err := http.ReadResponse(bufio.NewReader(proxyConn), req)
    if err != nil {
        proxyConn.Close()
        return nil, err
    }
    if resp.StatusCode != 200 {

        x, _ := io.ReadAll(resp.Body)
        fmt.Println(string(x))

        proxyConn.Close()
        return nil, fmt.Errorf("non-200 status code received from proxy: %v", resp.Status)
    }

    return proxyConn, nil
}

func main() {
    c, err := ftp.Dial(targetAddr+":21",
        ftp.DialWithTimeout(5*time.Second),
        ftp.DialWithDebugOutput(os.Stdin),
        ftp.DialWithDialFunc(connectViaProxy),
    )
    if err != nil {
        log.Fatal(err)
    }

    err = c.Login(user, pass)
    if err != nil {
        log.Fatal(err)
    }

    if r, err := c.Retr(path); err != nil {
        fmt.Println(err, ":<")
    } else {
        if reader, err := io.ReadAll(r); err != nil {
            fmt.Println(err, ":(")
        } else {
            fmt.Println(string(reader))
        }
    }

    if err = c.Quit(); err != nil {
        log.Fatal(err)
    }
}

不幸的是,我在try 连接时收到了403禁用.通常情况下,我会认为这是服务器限制,但它通过cURL完全正常工作:

curl -vvv -x 146.19.106.109:3128 -u dlpuser:rNrKYTX9g7z3RgJRmxWuGHbeu ftp://ftp.dlptest.com/xxx.txt

有人知道为什么会发生这种事吗?据我所知,curl也在幕后使用http Connect,所以我想知道我错过了什么.

另外,不要担心代码中的凭据-这些凭据可以在Web上公开测试

推荐答案

使用连接请求时,不会完成通过HTTP代理的FTP.取而代之的是,该代理被指示使用普通的GET请求获取ftp://...URL.这也是Curl正在做的事情.在Go中,这可以这样完成(为简单起见,省略错误处理):

// create the TCP connection to the proxy
conn, err := net.Dial("tcp", "146.19.106.109:3128")

// create the request with the ftp:// URL
req, err := http.NewRequest(http.MethodGet, "ftp://ftp.dlptest.com/xxx.txt", nil)
req.SetBasicAuth("dlpuser","rNrKYTX9g7z3RgJRmxWuGHbeu")

// don't use req.Write but req.WriteProxy, since the request line must
// contain the full URL and not only the path
err = req.WriteProxy(conn)

// read response
resp, err := http.ReadResponse(bufio.NewReader(conn), req)
body, _ := io.ReadAll(resp.Body)

Go相关问答推荐

如何在定制普罗米修斯出口商中测试动态计量注册?

你能帮我优化一个golang代码关于函数CrossPointTwoRect

一种基于时间的Golang函数节制器

带有条件的for循环中缺少RETURN语句

带有一个新变量的Go冒号等于运算符

减少在围棋中映射DTO时的重复代码量

转到http服务器头内容-类型设置为多部分/表单-数据,但在客户端获取内容-类型:文本/纯文本

通过代理从golang连接到ftp

确定果朗CSV行中的字节数

go-chi: 接受带有反斜杠的 url 路径参数

go-jwt 令牌验证错误 - 令牌签名无效:密钥类型无效

Docker 执行失败并显示cmd/ENTRYPOINT 中的命令未找到

是否需要手动调用rand.Seed?

Github Actions Go lambda 项目不同的 sha256sums

Go Colly 如何找到请求的元素?

为什么在单独的 go routine 中需要 wg.Wait() 和 close() ?

将未知长度切片的值分配给Go中的 struct ?

在 Go 中将十六进制转换为带符号的 Int

使用 LoadLibraryA(path_to_dll) 加载 DLL 会将文件描述符 0、1 和 2 的继承句柄标志 (HANDLE_FLAG_INHERIT) 从 1 更改为 0

如何从应用程序调用谷歌云身份 API