我正在使用從移動客戶端讀取上傳的 Go HTTP 服務器實現。但是，我遇到了一些問題，因為長時間保持活動狀態，如果移動客戶端脫機（經常發生），服務器將掛起讀取請求緩沖區很長時間。檢測斷開的連接并關閉輸入緩沖區的正確方法是什么？
2 回答
斯蒂芬大帝
TA貢獻1827條經驗 獲得超8個贊
在服務器上設置一個合理的超時時間，例如：
srv := &http.Server{
Addr: ":443",
ReadTimeout: time.Minute * 2,
WriteTimeout: time.Minute * 2,
}
log.Fatal(srv.ListenAndServeTLS(certFile, keyFile))
慕容森
TA貢獻1853條經驗 獲得超18個贊
因為我只想在寫入停止時斷開連接（并且很快，以便我可以記錄到目前為止收到的數據并允許客戶端恢復），所以 ReadTimeout 對我來說不是正確的解決方案。
我在這個要點中找到了答案。您需要在連接本身上設置讀取。
包網絡超時
import (
"net"
"time"
)
// Listener wraps a net.Listener, and gives a place to store the timeout
// parameters. On Accept, it will wrap the net.Conn with our own Conn for us.
type Listener struct {
net.Listener
ReadTimeout time.Duration
WriteTimeout time.Duration
}
func (l *Listener) Accept() (net.Conn, error) {
c, err := l.Listener.Accept()
if err != nil {
return nil, err
}
tc := &Conn{
Conn: c,
ReadTimeout: l.ReadTimeout,
WriteTimeout: l.WriteTimeout,
}
return tc, nil
}
// Conn wraps a net.Conn, and sets a deadline for every read
// and write operation.
type Conn struct {
net.Conn
ReadTimeout time.Duration
WriteTimeout time.Duration
}
func (c *Conn) Read(b []byte) (int, error) {
err := c.Conn.SetReadDeadline(time.Now().Add(c.ReadTimeout))
if err != nil {
return 0, err
}
return c.Conn.Read(b)
}
func (c *Conn) Write(b []byte) (int, error) {
err := c.Conn.SetWriteDeadline(time.Now().Add(c.WriteTimeout))
if err != nil {
return 0, err
}
return c.Conn.Write(b)
}
func NewListener(addr string, readTimeout, writeTimeout time.Duration) (net.Listener, error) {
l, err := net.Listen("tcp", addr)
if err != nil {
return nil, err
}
tl := &Listener{
Listener: l,
ReadTimeout: readTimeout,
WriteTimeout: writeTimeout,
}
return tl, nil
}
- 2 回答
- 0 關注
- 499 瀏覽
添加回答
舉報
0/150
提交
取消