Go语言实现一个简单的并发聊天室的项目实战_Golang_

package main import (     "bufio"     "fmt"     "log"     "net" ) type client chan <- string //定义一个单向的向外发送数据的通道 var (     entering = make(chan client)     leaving = make(chan client)     messages = make(chan string) ) func main() {     listener, err := net.Listen("tcp","localhost:8000")     if err != nil {         log.Fatal("network is broken", err)     }     go broadcaster()     for {         conn, err := listener.Accept()         if err != nil {             log.Print(err)             continue         }         go handleConn1(conn)     } } func broadcaster()  {     clients := make(map[client]bool) //存储每个client的登录状态     for{         select {         case msg := <-messages:             for cli := range clients {                 cli <- msg             }         case cli := <-entering:             clients[cli] = true         case cli := <-leaving:             delete(clients,cli)             close(cli)         }     } } func handleConn1(conn net.Conn)  {     ch := make(chan string)     go clientWriter(conn, ch)     who := conn.RemoteAddr().String()     ch <- "You are " + who     entering <- ch     messages <- who + "has arrived"     input := bufio.NewScanner(conn)     for input.Scan() {         messages <- who + ":" + input.Text()     }     leaving <- ch     messages <- who + "has left"     conn.Close() } func clientWriter(conn net.Conn, ch <- chan string)  {     for msg := range ch {         fmt.Fprintln(conn, msg)     } }

package main import (     "io"     "log"     "net"     "os" ) func main() {     conn, err := net.Dial("tcp","localhost:8000")     if err != nil {         log.Fatal("Connected has been refused！",err)     }     defer conn.Close()     go mesCopy(os.Stdout,conn)     mesCopy(conn,os.Stdin) } func mesCopy(des io.Writer, res io.Reader)  {     if _, err := io.Copy(des, res); err != nil {         log.Print("wrong!")     } }