Go 语言中怎样同时监听客户端连接与终端输入

在 Go 语言开发中，常常会遇到需要同时监听客户端连接和终端输入的场景。这种需求在很多网络应用，特别是交互式网络服务中非常常见。下面就来探讨一下如何在 Go 语言里实现这一功能。

我们需要明确实现的思路。Go 语言强大的并发特性为我们提供了很好的解决方案。我们可以使用 goroutine 来分别处理客户端连接监听和终端输入监听，然后通过通道（channel）来实现不同 goroutine 之间的通信。

对于监听客户端连接，我们可以使用 net 包。以下是一个简单的示例代码：

package main

import (
    "net"
    "fmt"
)

func listenForClients() {
    // 监听本地的 8080 端口
    listener, err := net.Listen("tcp", ":8080")
    if err!= nil {
        fmt.Println("Failed to listen:", err)
        return
    }
    defer listener.Close()

    for {
        // 接受客户端连接
        conn, err := listener.Accept()
        if err!= nil {
            fmt.Println("Failed to accept connection:", err)
            continue
        }
        // 处理客户端连接的逻辑可以在这里实现
        go handleClient(conn)
    }
}

func handleClient(conn net.Conn) {
    defer conn.Close()
    // 处理客户端数据的具体逻辑
}

在上述代码中，listenForClients 函数负责监听客户端连接，当有新的连接到来时，会启动一个新的 goroutine 来处理该连接。

接下来处理终端输入监听。在 Go 语言中，我们可以使用 bufio 包来实现：

package main

import (
    "bufio"
    "os"
    "fmt"
)

func listenForTerminalInput() {
    scanner := bufio.NewScanner(os.Stdin)
    for scanner.Scan() {
        input := scanner.Text()
        // 处理终端输入的逻辑可以在这里实现
        fmt.Println("Received terminal input:", input)
    }
    if err := scanner.Err(); err!= nil {
        fmt.Println("Error reading from terminal:", err)
    }
}

listenForTerminalInput 函数使用 bufio.NewScanner 来读取终端输入，每读取一行数据就可以进行相应的处理。

最后，将这两个功能结合起来。在 main 函数中启动两个 goroutine 分别执行上述两个函数：

package main

func main() {
    go listenForClients()
    go listenForTerminalInput()

    // 防止 main 函数退出
    select {}
}

通过上述步骤，我们就实现了在 Go 语言中同时监听客户端连接与终端输入。这种方式充分利用了 Go 语言的并发优势，使得程序能够高效地处理不同来源的输入。