5

私はgo言語を学ぼうとしていて、単純なエコーサーバーを書いています。しかし、私はそれを機能させるのに苦労しています。

func listen(server string) {
    var buf []byte

    listener, ok := net.Listen("tcp", server)
    if ok != nil {
        fmt.Fprintf(os.Stderr, "Could not listen on socket: %s\n", ok.String())
        return
    }
    conn, ok := listener.Accept()
    if ok != nil {
        fmt.Fprintf(os.Stderr, "Could not accept connection on socket: %s\n", ok.String())
        return
    }

    writelen, ok := conn.Write(strings.Bytes("Ready to receive\n"))
    if ok != nil {
        fmt.Fprintf(os.Stderr, "Could not write to socket: %s\n", ok.String())
    } else {
        fmt.Printf("Wrote %d bytes to socket\n", writelen)
    }

    for ;; {
        readlen, ok := conn.Read(buf)
        if ok != nil {
            fmt.Fprintf(os.Stderr, "Error when reading from socket: %s\n", ok.String())
            return
        }
        if readlen == 0 {
            fmt.Printf("Connection closed by remote host\n")
            return
        }

        fmt.Printf("Client at %s says '%s'\n", conn.RemoteAddr().String(), buf)
    }
}

この関数から次の出力が得られます。

[nathan@ebisu ~/src/go/echo_server] ./6.out 1234
Using port 1234
Wrote 17 bytes to socket
Error when reading from socket: EOF

これは私がクライアントに見るものです：

[nathan@ebisu ~] telnet 127.0.0.1 1234
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
Ready to receive
Connection closed by foreign host.

任意の助けをいただければ幸いです（またはリソースへのポインタ。ソケットAPIのgoドキュメントには少し不満があります）。

ありがとう、

ネイサン

4

2 に答える 2

8

あなたの例では、bufは明確なサイズを持っている必要があります。長さ0のスライスとして宣言しました。

次のように宣言します。

var buf = make([]byte, 1024)
于 2010-02-16T05:38:36.887 に答える
3

もちろん、学習したい場合は、自分で作成することをお勧めしますが、それが役立つ場合は、Goにある自分のエコーサーバーを次に示します。

package main

import (
    "net";
    "os";
    "fmt";
)

func handle(conn *net.TCPConn) {
    fmt.Printf("Connection from %s\n", conn.RemoteAddr());
    message := make([]byte, 1024);
    // TODO: loop the read, we can have >1024 bytes
    n1, error := conn.Read(message);
    if error != nil {
        fmt.Printf("Cannot read: %s\n", error);
        os.Exit(1);
    }
    n2, error := conn.Write(message[0:n1]);
    if error != nil || n2 != n1 {
        fmt.Printf("Cannot write: %s\n", error);
        os.Exit(1);
    }
    fmt.Printf("Echoed %d bytes\n", n2);
    conn.Close();   // TODO: wait to see if more data? It would be better with telnet...
}

func main() {
    listen := ":7";
    addr, error := net.ResolveTCPAddr(listen);
    if error != nil {
        fmt.Printf("Cannot parse \"%s\": %s\n", listen, error);
        os.Exit(1);
    }
    listener, error := net.ListenTCP("tcp", addr);
    if error != nil {
        fmt.Printf("Cannot listen: %s\n", error);
        os.Exit(1);
    }
    for {   // ever...
        conn, error := listener.AcceptTCP();
        if error != nil {
            fmt.Printf("Cannot accept: %s\n", error);
            os.Exit(1);
        }
        go handle(conn);
    }
}
于 2010-02-18T07:12:12.723 に答える