fix
This commit is contained in:
parent
787bc76868
commit
71fa126480
@ -150,18 +150,10 @@ func NewBackend(mux *http.ServeMux, httpAddress string, muxPaths ...string) *Bac
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
dialer := &websocket.Dialer{
|
|
||||||
Proxy: http.ProxyFromEnvironment,
|
|
||||||
NetDial: func(network, addr string) (net.Conn, error) {
|
|
||||||
return net.Dial(network, addr)
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
// 创建后端服务对象,包含地址和客户端
|
// 创建后端服务对象,包含地址和客户端
|
||||||
backend := &Backend{
|
backend := &Backend{
|
||||||
HttpAddress: httpAddress,
|
HttpAddress: httpAddress,
|
||||||
Client: client,
|
Client: client,
|
||||||
Dialer: dialer,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 创建处理请求的函数
|
// 创建处理请求的函数
|
||||||
@ -198,6 +190,7 @@ func NewBackend(mux *http.ServeMux, httpAddress string, muxPaths ...string) *Bac
|
|||||||
header.Del("Sec-Websocket-Key")
|
header.Del("Sec-Websocket-Key")
|
||||||
header.Del("Sec-Websocket-Version")
|
header.Del("Sec-Websocket-Version")
|
||||||
header.Del("Connection")
|
header.Del("Connection")
|
||||||
|
|
||||||
// header.Del("Origin")
|
// header.Del("Origin")
|
||||||
proxyConn, _, err := backend.Dialer.Dial(target.String(), header)
|
proxyConn, _, err := backend.Dialer.Dial(target.String(), header)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user