2

我如何在 Go 中实现一个服务器，它将每个传入行发送到 stdout ？

package main

import (
    "io"
    "log"
    "net"
)

func main() {
    srv, err := net.Listen("tcp", ":2000")
    for {
        conn, err := srv.Accept()
        go func(c net.Conn) {

            //How to split here by lines ?

            c.Close()
        }(conn)
    }
}

运行服务器后

./server

并运行 telnet

telnet localhost 2000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
test 123
foobar

我想在标准输出上看到我启动服务器的位置：

test 123
foobar

我知道这段代码缺少错误处理，但这只是为了清楚地显示我正在尝试做的事情。

4

2 回答 2

7

由于 anet.Conn是 an io.Reader，您可以将其包装在 a 中bufio.Reader并在该类型上使用该ReadString方法。你的功能会变成

func(c net.Conn) {
    f := bufio.NewReader(c)
    for {
        ln, err := f.ReadString('\n')
        if err == io.EOF {
            break
        } else if err != nil {
            panic(err)
        }
        fmt.Print(ln)
    }
    c.Close()
}

（我不确定标准输出是否在 Go 中同步；在单独的 goroutine 中循环的共享通道上发送行可能更清晰。）

于 2012-12-29T13:35:55.000 回答
5

如果这就是你想要的，只需将套接字复制到标准输出。

package main

import (
    "io"
    "log"
    "net"
    "os"
)

func main() {
    srv, err := net.Listen("tcp", ":2000")
    if err != nil {
        log.Fatalf("Error listening: %v", err)
    }
    for {
        conn, err := srv.Accept()
        if err != nil {
            log.Fatalf("Error accepting: %v", err)
        }
        go func(c net.Conn) {
            defer c.Close()
            io.Copy(os.Stdout, c)
        }(conn)
    }
}
于 2012-12-31T04:06:43.567 回答