Erstellen Sie einen TCP-client in golang

Hallo, ich bin versucht zu lernen, einige socket-Programmierung in golang, ich bin zusammen mit diesem tutorial

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

Hier das Endergebnis des Tutorials auf einer Seite.
https://github.com/akrennmair/telnet-chat/blob/master/03_chat/chat.go

Ich bin verwirrt, wie zu schreiben der client-Seite mit diesem Programm erstelle ich eine Verbindung und wählen Sie in den gleichen port/ip wie der server läuft, aber von da aus weiß ich nicht. Ich habe read() und write () - Funktionen für die neu erstellte Verbindung, aber keine Ahnung, wo begrenzen Sie den lese-oder nichts. Angesichts der text-Eingabe wird vorgeführt in den server ich Stelle mir vor ich würde nur tun müssen, ein Lesen von einer Art?

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")))
    }

}
  • TCP ist ein peer-to-peer-Protokoll, und es müssen keine clients oder Server. Die client/server-Konzept ist ein Konzept Anwendung, das hat nichts mit TCP.
InformationsquelleAutor user3324984 | 2014-04-17
  1. 10

    bufio.NewReadersollte nur einmal verwendet werden, in Ihrem Fall, kurz vor der for. Zum Beispiel connbuf := bufio.NewReader(conn). Dann können Sie ReadString auf connbuf, dass gibt den string zurück, und vielleicht ein Fehler. Zum Beispiel:

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

    Ich Kontrolle lenund err weil ReadString können die Daten zurückgeben und einen Fehler (Verbindungsfehler, connection reset, etc.) so müssen Sie überprüfen.

    • Dies funktioniert für bekommen, um die erste Eingabeaufforderung jedoch, wenn der server (ich nehme an) die Ausführung bufc.ReadLine() es mir nicht erlaubt, auf nichts eingeben. Das ist die Ausgabe die ich erhalte Welcome to chat room, What is your nickname?: aber es hängt hier nicht erlaubt-Eingang.
    • Ja, natürlich. Es hält Lesen und ausdrucken. Wenn Sie brauchen, Interaktivität, können Sie entweder beenden die Schleife, wenn die Erkennung der Eingabeaufforderung, oder mit goroutines, eine für Lesen und eine für schreiben.
    • Wenn ich verstehe, was Sie möchten, können Sie zwei goroutines nachdem die Verbindung hergestellt wurde. Ein Lesen vom server, einfach mit io.Copy(os.Stdout, conn) und andere für die andere Richtung mit io.Copy(conn, os.Stdin). Dies ist vollkommen asynchron, aber es sollte genug sein, um loszulegen.
    • Ich war in der Lage zu bekommen, dass die Arbeit vielen Dank!
    InformationsquelleAutor siritinga
  2. 1

    Hier ist eine einfache Lösung, wenn Sie Lesen wollen, werden alle empfangenen Daten.

        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...
    }
    InformationsquelleAutor user3215378
Schreibe einen Kommentar