2016-04-21 21 views
1

我正在使用從移動客戶端讀取上傳的Go HTTP服務器實現。但是,由於長時間保持活動狀態,我遇到了問題,如果移動客戶端脫機(經常發生),服務器將掛起相當長時間的請求緩衝區。在Go中檢測丟失連接的正確方法是什麼?

檢測掉線連接並關閉輸入緩衝區的正確方法是什麼?

回答

1

因爲我想在寫停止(快捷地只斷開連接,這樣我就可以記錄接收到的數據,到目前爲止,並允許客戶端恢復),ReadTimeout不適合我。

我在this gist找到了答案。您需要在連接本身上設置讀取。

包nettimeout

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

在服務器上設置一個合理的超時,例如:

srv := &http.Server{ 
    Addr: ":443", 
    ReadTimeout: time.Minute * 2, 
    WriteTimeout: time.Minute * 2, 
} 
log.Fatal(srv.ListenAndServeTLS(certFile, keyFile)) 
+0

,因爲我希望連接快速失敗,無論HTTP請求是多久,這不適合我的工作。例如。他們可能會上傳一個100MB的文件並獲得50MB的通過,但我希望它在停止傳輸後1秒內失敗。我將記錄迄今收到的字節並允許客戶端恢復。 – JustinHK

相關問題