Schreiben Client UDP-Socket-in Gehen

Ich bin auf der Suche nach einer guten Lösung für eine client/server-Kommunikation mit UDP-sockets in Go Sprache.

Die Beispiele, die ich im Internet gefunden die mir zeigen, wie Daten an den server senden, aber Sie nicht lehren, wie Sie zu senden an den client zurück.

Demonstrieren, mein Programm macht Folgendes:

Mein client-Programm erzeugt einen socket auf den port 4444, so wie hier:

con, err := net.Dial("udp", "127.0.0.1:4444")

Ich eine Zeichenfolge gesendet und der lokalen Adresse auf dem server, so könnte es drucken Sie den string und senden einer OK-Meldung. Ich bin mit gob für diese:

enc := gob.NewEncoder(con)
enc.Encode(Data{"test", con.LocalAddr().String()})

Meine Daten struct sieht wie folgt aus:

type Data struct{
    Msg string
    Addr string
}

Meinem server lauscht auf dem port 4444 und decodiert die Klappe richtig, aber wie kann ich senden Sie die OK-Meldung zurück? Ich bin mit der client-Adresse zu tun (auf dem server .go-Datei):

con, err := net.Dial("udp", data.Addr)

Dann bekomme ich einen Fehler-code:

write udp 127.0.0.1:35290: connection refused

Wenn der client versucht, eine Verbindung zu dem Server-port 4444, erstellt der client einen port mit einer zufälligen Zahl (in diesem Fall, 35290), so dass Sie kommunizieren können. Ich weiß, ich sollte nicht sein, vorbei die Adresse des Clients an den server, aber conn.RemoteAddress() funktioniert nicht. Eine Lösung, welche die client-Adresse würde am meisten geschätzt.

Obs.: Ich weiß, es ist ReadFromUDP, so kann ich Lesen Sie die Packungsbeilage. Sollte ich es Lesen, entdecken Sie die client-Adresse, und senden die Daten an Gob, damit er Sie entschlüsseln kann?

  • Lesen Sie Pakete, die mit ReadFromUDP. Verwenden Sie die Adresse zurückgegeben, die von ReadFromUDP Antworten mit WriteToUDP.
  • Ich war darüber nachzudenken, aber wie würde die Klappe passen in dieser situation?
  • Kodieren Sie die Klappe, um einen Puffer mit var b bytes.Buffer; err := gob.NewEncoder(&b).Encode(v) und schreiben b.Byte (), um die Verbindung. Decodieren der gobs mit err := gob.NewDecoder(bytes.NewReader(p)).Decode(&v) wobei p die gelesenen Daten aus der Verbindung.
InformationsquelleAutor Aleksandrus | 2014-09-25
  1. 21

    Überprüfen Sie die unten stehen Beispiele für die client/server-Kommunikation über UDP. Das sendResponse routine zum senden Antwort zurück an den client.

    udpclient.gehen

    package main
import (
    "fmt"
    "net"
    "bufio"
)

func main() {
    p :=  make([]byte, 2048)
    conn, err := net.Dial("udp", "127.0.0.1:1234")
    if err != nil {
        fmt.Printf("Some error %v", err)
        return
    }
    fmt.Fprintf(conn, "Hi UDP Server, How are you doing?")
    _, err = bufio.NewReader(conn).Read(p)
    if err == nil {
        fmt.Printf("%s\n", p)
    } else {
        fmt.Printf("Some error %v\n", err)
    }
    conn.Close()
}

    udpserver.gehen

    package main
import (
    "fmt" 
    "net"  
)


func sendResponse(conn *net.UDPConn, addr *net.UDPAddr) {
    _,err := conn.WriteToUDP([]byte("From server: Hello I got your mesage "), addr)
    if err != nil {
        fmt.Printf("Couldn't send response %v", err)
    }
}


func main() {
    p := make([]byte, 2048)
    addr := net.UDPAddr{
        Port: 1234,
        IP: net.ParseIP("127.0.0.1"),
    }
    ser, err := net.ListenUDP("udp", &addr)
    if err != nil {
        fmt.Printf("Some error %v\n", err)
        return
    }
    for {
        _,remoteaddr,err := ser.ReadFromUDP(p)
        fmt.Printf("Read a message from %v %s \n", remoteaddr, p)
        if err !=  nil {
            fmt.Printf("Some error  %v", err)
            continue
        }
        go sendResponse(ser, remoteaddr)
    }
}
    • Das line-conn.Schließen() in der udpclient.gehen es wird besser sein, um in einer zeitlich verzögert Satz, wie: verschieben conn.Close()
    • Ich versuche, diese arbeiten, die mit der server läuft auf einer remote-box und client lokal ausgeführt. Wenn ich die Adresse im server.gehen Sie auf "0.0.0.0", und die Adresse in der client.wechseln Sie zu der IP des Servers, client-zurück Some error read udp 127.0.0.1:58464->127.0.0.1:1234: read: connection refused. Würde mir bitte jemand einen Weg vorschlagen, damit es funktioniert? Danke!!!
    InformationsquelleAutor Nipun Talukdar
Schreibe einen Kommentar