使用 go channel 的 go echo 服务器,但服务器没有回复
A go echo server using go channel, but no reply from the server
我正在尝试使用go channel和goroutine写一个回显服务器,但是服务器没有回复。以下服务器侦听端口 9090,并创建一个通道 ch
来接收连接接受,然后它传递给 handleClient
来处理连接细节。下面的代码有错吗?在 go build
.
下没有错误
package main
import (
"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
}
只需稍微更改一下您的主要内容:
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 循环是服务器的主循环,如果您不在其他地方退出服务器,它将永远运行。
我正在尝试使用go channel和goroutine写一个回显服务器,但是服务器没有回复。以下服务器侦听端口 9090,并创建一个通道 ch
来接收连接接受,然后它传递给 handleClient
来处理连接细节。下面的代码有错吗?在 go build
.
package main
import (
"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
}
只需稍微更改一下您的主要内容:
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 循环是服务器的主循环,如果您不在其他地方退出服务器,它将永远运行。