我正在嘗試為基于CONNECT的 HTTP 代理創(chuàng)建反向代理。想要使用代理的用戶(hù)只是將machine A其視為 HTTP 代理。它的工作方式如下：machine B打開(kāi)一個(gè) TCP 套接字到machine A.在 上machine A，TCP 套接字在端口上公開(kāi)，所有傳入數(shù)據(jù)都通過(guò)隧道傳輸?shù)絤achine B(io.Copy)。開(kāi)啟machine B時(shí)，所有數(shù)據(jù)都通過(guò)隧道傳輸?shù)奖镜?HTTP 服務(wù)器和套接字machine A。本質(zhì)上，這是 HTTP 代理背后的反向代理。之所以如此復(fù)雜，是因?yàn)?HTTP 代理位于 NAT 之后（打開(kāi)machine B），因此無(wú)法直接訪問(wèn)。該用例能夠在 NAT 后面托管 HTTP 代理。機(jī)器A隧道（Go）：package mainimport ( "log" "net")func Conn(c *net.TCPConn) string { return c.RemoteAddr().String() + " (" + c.LocalAddr().String() + ")"}func ProxifyConns(recipientConn, donorConn *net.TCPConn) { log.Println("Proxying", ConnrecipientConn), "and", Conn(donorConn)) go func() { _, err := io.Copy(recipientConn, donorConn) if err != nil { utils.StacktraceError(err) } recipientConn.Close() }() go func() { _, err := io.Copy(donorConn, recipientConn) if err != nil { utils.StacktraceError(err) } recipientConn.Close() }()}func main() { // Open the donor listener donorsAddr, err := net.ResolveTCPAddr("tcp4", ":11000") if err != nil { utils.StacktraceErrorAndExit(err) } listenerDonors, err := net.ListenTCP("tcp", donorsAddr) if err != nil { utils.StacktraceErrorAndExit(err) } defer listenerDonors.Close() log.Println("Listening for donors on", listenerDonors.Addr()) // Open the recipient listener recipientsAddr, err := net.ResolveTCPAddr("tcp4", ":10000") if err != nil { utils.StacktraceErrorAndExit(err) } listenerRecipients, err := net.ListenTCP("tcp", recipientsAddr) if err != nil { utils.StacktraceErrorAndExit(err) } defer listenerRecipients.Close() log.Println("Listening for recipients on", listenerRecipients.Addr())
1 回答
天涯盡頭無(wú)女友
TA貢獻(xiàn)1831條經(jīng)驗(yàn) 獲得超9個(gè)贊
當(dāng)你這樣做
go func() {
for {
donorConn, err := listenerDonors.AcceptTCP()
donorConn.SetKeepAlive(true)
if err != nil {
utils.StacktraceErrorAndExit(err)
return
}
log.Println("New donor connection from", Conn(donorConn))
donorConns <- donorConn
}
}()
您開(kāi)始處理第一個(gè) TCP 連接。此代碼塊在donorConns <- donorConn. 在此發(fā)送到通道完成之前，循環(huán)不會(huì)進(jìn)入第二次迭代（并且不會(huì)接受下一個(gè) TCP 連接）。
你做了一個(gè)非常相似的第二個(gè)循環(huán)
// Handle recipient connections
for {
recipientConn, err := listenerRecipients.AcceptTCP()
recipientConn.SetKeepAlive(true)
if err != nil {
utils.StacktraceErrorAndExit(err)
return
}
log.Println("New recipient connection from", Conn(recipientConn))
donorConn := <-donorConns
proxy.ProxifyConns(recipientConn, donorConn)
}
這需要donorConn := <-donorConns完成（從第一個(gè)循環(huán)開(kāi)始）并且需要proxy.ProxifyConns(recipientConn, donorConn)完成。
我不確定你打算如何讓整個(gè)工作，但是，很可能，你需要一個(gè)很小的改變：
go proxy.ProxifyConns(recipientConn, donorConn)
- 1 回答
- 0 關(guān)注
- 162 瀏覽
添加回答
舉報(bào)
0/150
提交
取消