今天小编给大家分享一下Go语言怎么实现一个简单的并发聊天室的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。
并发聊天服务器
这里主要是实现一个简单的并发聊天服务器。首先，客户端可以在服务器中注册自己的信息（登录以及退出），客户端发出的所有的信息由服务器向各个客户端进行转发，或者换句话说是广播。
具体代码
服务端
说的再多，没有代码简单明了，直接上代码~
package mainimport ( "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 mainimport ( "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!") }}以上就是“Go语言怎么实现一个简单的并发聊天室”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注编程网行业资讯频道。
