go tcp server

weiwenwang · · 1622 次点击
存在外部没问题,但是一旦远端中断了tcp连接,这个fd就失效了。
#6
更多评论
问题还是有点意思的,可以考虑用 chan 来实现这个,下面是我写的代码,可以参考着写个更完善的。 ``` go package main import ( "bufio" "fmt" "io" "net" "os" ) func main() { l, _ := net.Listen("tcp", ":8000") for { conn, _ := l.Accept() ch := make(chan string) go talk(conn, ch) go input(ch) } } func talk(conn io.ReadWriteCloser, ch chan string) { for c := range ch { fmt.Fprintf(conn, c) } fmt.Fprintf(conn, "closed, byebye.") conn.Close() } func input(ch chan string) { reader := bufio.NewReader(os.Stdin) text, _ := reader.ReadString('\n') for text != "#\n" { ch <- text text, _ = reader.ReadString('\n') } close(ch) } ```
#2