मैं नेट कैसे बना सकता हूं। गोलांग में इनपुट के लिए प्रतीक्षा करें?

Question

तो मैं गो में अपने लिफ्ट के लिए एक सर्वर बना रहा हूं, और मैं एक "टीसीपी-कनेक्शन के साथ एक goroutine के रूप में" हैंडलर "समारोह चला रहा हूँ। मैं इसे किसी कनेक्शन से पढ़ना चाहता हूं, और यदि किसी निश्चित समय के भीतर कोई सिग्नल नहीं मिला है, तो मैं इसे एक त्रुटि वापस करना चाहता हूं।

func handler(conn net.Conn){ 
    conn.SetReadTimeout(5e9) 
    for{ 
     data := make([]byte, 512) 
     _,err := conn.Read(data) 
    } 
} 

जब तक ग्राहक त्रुटि EOF net.Read समारोह रिटर्न भेजने बंद हो जाता है और शुरू होता है कोई देरी से पाशन के रूप में मैं एक ग्राहक कनेक्शन यह ठीक काम कर रहा है से अधिक सामान भेजने, लेकिन जैसे ही है ।

यह हो सकता है कि रीड कैसे काम करना चाहिए, लेकिन क्या कोई समस्या को संभालने और कनेक्शन को खोलने के बिना समस्या को संभालने का एक और तरीका सुझा सकता है जब भी मैं कुछ पढ़ना चाहता हूं?

Answer 1

पढ़ना अपेक्षित काम के रूप में काम कर रहा है। ऐसा लगता है जैसे आप नेट चाहते हैं। जाओ में एक चैनल की तरह काम करने के लिए पढ़ें। सिर्फ एक चल goroutine में net.Read लपेट और चैनलों से पढ़ने के लिए एक goroutine वास्तव में सस्ती है चयन विकल्प का उपयोग और इसलिए एक चैनल

उदाहरण है इस बार में बहुत आसान है:

ch := make(chan []byte) 
eCh := make(chan error) 

// Start a goroutine to read from our net connection 
go func(ch chan []byte, eCh chan error) { 
    for { 
    // try to read the data 
    data := make([]byte, 512) 
    _,err := conn.Read(data) 
    if err != nil { 
     // send an error if it's encountered 
     eCh<- err 
     return 
    } 
    // send data if we read some. 
    ch<- data 
    } 
}(ch, eCh) 

ticker := time.Tick(time.Second) 
// continuously read from the connection 
for { 
    select { 
    // This case means we recieved data on the connection 
    case data := <-ch: 
     // Do something with the data 
    // This case means we got an error and the goroutine has finished 
    case err := <-eCh: 
     // handle our error then exit for loop 
     break; 
    // This will timeout on the read. 
    case <-ticker: 
     // do nothing? this is just so we can time out if we need to. 
     // you probably don't even need to have this here unless you want 
     // do something specifically on the timeout. 
    } 
} 

Answer 2

यह संभव है कि कचरा कलेक्टर (जीसी) कनेक्शन के एक छोर बंद कर देता है क्योंकि net.Conn जीसी दृष्टिकोण से किसी न पहुंचने योग्य वस्तु बन जाता है। इसे रोकने के लिए: क्लाइंट भेजने के बाद, सुनिश्चित करें कि क्लाइंट कनेक्शन एक चर में संग्रहीत है जो आपके कोड द्वारा सुलभ है।

एक और विकल्प यह है कि आपके प्रोग्राम में कहीं भी आप इसके बारे में जानने के बिना कनेक्शन के एक छोर को बंद कर रहे हैं।