我正在嘗試使用 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 關注
- 194 瀏覽
添加回答
舉報
0/150
提交
取消