Tworzenie klienta TCP w golang

Question

Cześć jestem próbowali nauczyć się programowania gniazd w golang, Obserwuję wraz z tym tutorialu

http://synflood.at/tmp/golang-slides/mrmcd2012.html#1

Oto ostateczny wynik samouczka na jednej stronie . https://github.com/akrennmair/telnet-chat/blob/master/03_chat/chat.go

Jestem zdezorientowany, jak napisać stronę klienta tego programu, tworzę połączenie i dzwonię do tego samego portu/ip, na którym działa serwer, ale z tego nie wiem. Mam funkcje read() i write() dla nowo utworzonego połączenia, ale nie mam pojęcia, gdzie ograniczać czytanie lub cokolwiek. Biorąc pod uwagę, że dane wprowadzane są do serwera, wyobrażam sobie, że potrzebuję tylko jakiegoś rodzaju czytania?

package main 

import (
    "bufio" 
    "fmt" 
    "net" 
    "os" 
) 

func main() { 
    conn, err := net.Dial("tcp", "127.0.0.1:6000") 
    if err != nil { 
     fmt.Println(err) 
     os.Exit(1) 
    } 

    for { 
     fmt.Println(bufio.NewReader(conn).ReadString([]byte("\n"))) 
    } 

} 

Answer 1

bufio.NewReader powinny być używane tylko raz, w danym przypadku, tuż przed for. Na przykład connbuf := bufio.NewReader(conn). Następnie możesz użyć ReadString na connbuf, który zwraca ciąg znaków i być może błąd. Na przykład:

connbuf := bufio.NewReader(conn) 
for{ 
    str, err := connbuf.ReadString('\n') 
    if len(str)>0 { 
     fmt.Println(str) 
    } 
    if err!= nil { 
     break 
    } 
} 

mam sprawdzanie len i errReadString ponieważ może powrócić danych i błąd (błąd połączenia, resetowania połączenia, itd.), Więc trzeba sprawdzić oba.

Answer 2

Oto proste rozwiązanie, jeśli chcesz przeczytać wszystkie odebrane dane.

connbuf := bufio.NewReader(c.m_socket) 
    // Read the first byte and set the underlying buffer 
    b, _ := connbuf.ReadByte() 
    if connbuf.Buffered() > 0 { 
     var msgData []byte 
     msgData = append(msgData, b) 
     for connbuf.Buffered() > 0 { 
      // read byte by byte until the buffered data is not empty 
      b, err := connbuf.ReadByte() 
      if err == nil { 
       msgData = append(msgData, b) 
      } else { 
       log.Println("-------> unreadable caracter...", b) 
      } 
     } 
     // msgData now contain the buffered data... 
    }