我正在尝试使用 go channel 和 goroutine 来编写一个回显服务器,但是没有来自服务器的回复。下面的服务器监听 9090 端口,并创建一个通道ch来接收连接接受,然后它传递handleClient给处理连接细节。下面的代码有错吗?下时它没有错误go build。package mainimport ( "fmt" "net")const ( CONN_HOST = "localhost" CONN_PORT = "9090" CONN_TYPE = "tcp")func main() { listen, err := net.Listen(CONN_TYPE, CONN_HOST + ":" + CONN_PORT) if err != nil { fmt.Println("Error listening: ", err.Error()) return } ch := make(chan net.Conn) go func() { for { conn, err := listen.Accept() if err != nil { fmt.Println("Error Accept: ", err.Error()) return } ch <- conn } }() go handleClient(ch)}func handleClient(connChan <-chan net.Conn) { var tcpConn net.Conn // fmt.Println("Accepted new client: ", connChan.RemoteAddr().String()) for { tcpConn = <-connChan go Serve(tcpConn) }}func Serve(conn net.Conn) { // handle the connection}
1 回答
侃侃无极
TA贡献2051条经验 获得超10个赞
只需稍微更改您的主要内容:
ch := make(chan net.Conn)
go handleClient(ch)
for {
conn, err := listen.Accept()
if err != nil {
fmt.Println("Error Accept: ", err.Error())
return
}
ch <- conn
}
for 循环是服务器的主循环,如果您不在其他地方退出服务器,它将永远运行。
- 1 回答
- 0 关注
- 170 浏览
添加回答
举报
0/150
提交
取消