Go 中的双向连接

Question

我正在尝试在 Go 中进行简单的控制台聊天，只是为了练习。但是，我不知道如何从服务器发回消息。服务器只是收到一条消息，然后关闭连接。我如何发送回复？我一直在搜索并找到有关 websockets 的信息，但我认为它们用于与浏览器交互。这是服务器的两个功能：func runServer() {    // Listen on a port    listen, error := net.Listen("tcp", ":8272")    // Handles eventual errors    if error != nil {        fmt.Println(error)        return    }    fmt.Println("Listening in port 8272.")    for {        // Accepts connections        con, error := listen.Accept()        // Handles eventual errors        if error != nil {            fmt.Println(error)            continue        }        fmt.Println("Connection accepted.")        // Handles the connection        go handleConnection(con)    }}func handleConnection(con net.Conn) {    fmt.Println("Handling connection.")    var message string    // Decodes the received message    decoder := gob.NewDecoder(con)    error := decoder.Decode(&message)    // Checks for errors    if error != nil {        fmt.Println(error)    } else {        fmt.Println("Received", message)    }    // Closes the connection    con.Close()    fmt.Println("Connection closed.")}这是客户端的功能：func runClient() {    // Connects to server    con, error := net.Dial("tcp", "127.0.0.1:8272")    // Handles eventual errors    if error != nil {        fmt.Println(error)        return    }    fmt.Println("Connected to 127.0.0.1:8272.")    // Sends a message    message := "Hello world"    encoder := gob.NewEncoder(con)    error = encoder.Encode(message)    // Checks for errors    if error != nil {        fmt.Println(error)    }    con.Close()    fmt.Println("Message sent. Connection closed.")}提前致谢。

Answer 1

你的con对象是一个连接，它具有Read和Write这里所描述的方法：在这里。您应该循环连接，尝试Read传入数据，然后处理它并（可能）Write返回服务器响应。（这里，bufferiopackage之类的可以帮你更方便的处理，这只是底层ReadWriter接口）

文档显示了一个小例子：

go func(c net.Conn) {

    // Echo all incoming data.

    io.Copy(c, c)

    // Shut down the connection.

    c.Close()

}(conn)

它只处理第一条消息，然后关闭。您可以像这样处理每个传入的消息：

go func(c net.Conn) {

    // Infinite loop: Get data, copy them and start over

    for {

        // Echo all incoming data.

        io.Copy(c, c)

    }

    // Shut down the connection.

    c.Close()

}(conn)

io.Copy当然，替换与您的服务器相关的任何内容，因此您的示例将是这样的：

func handleConnection(con net.Conn) {

    fmt.Println("Handling connection.")

    defer func() {

        // Closes the connection

        con.Close()

        fmt.Println("Connection closed.")

    }()

    var message string

    // Decodes the received message

    decoder := gob.NewDecoder(con)

    encoder := gob.NewEncoder(con)

    for {

        error := decoder.Decode(&message)

        // Checks for errors

        if error != nil {

            fmt.Println(error)

            // Exit the loop

            return

        } else {

            fmt.Println("Received", message)

            // Sending back

            if error = encoder.Encode(message); error != nil {

                 fmt.Println(error)

                 return

            } else {

                fmt.Println("Echo'd successfuly ! Waiting for next message...")

            }

        }

    }

}

此外，您可能应该使用 packagelog而不是fmt您的日志消息（但这在这里无关紧要）。

了解这一切如何工作的一个好地方是在此处浏览默认http服务器的实现。

同样，您的客户端应该使用相同的模式循环：

LOOP:

    Send data (e.g. encoder.Encode)

    Receive data (e.g. decoder.Decode)

    if problem or termination -> break out of loop

END

close connection