Go实现简易聊天室（群聊）

packagemainimport (
"fmt""net""time")
// 客户端 mapvarclientMap=make(map[string]*net.TCPConn) // 存储当前群聊中所有用户连接信息：key: ip+port, val: 用户连接信息// 监听请求funclistenClient(ipAndPortstring) {
tcpAddr, _ :=net.ResolveTCPAddr("tcp", ipAndPort)
tcpListener, _ :=net.ListenTCP("tcp", tcpAddr)
for { // 循环接收clientConn, _ :=tcpListener.AcceptTCP()                 // 监听请求连接clientMap[clientConn.RemoteAddr().String()] =clientConn// 将连接添加到 mapgoaddReceiver(clientConn)
fmt.Println("用户 : ", clientConn.RemoteAddr().String(), " 已连接.")
    }
}
// 向连接添加接收器funcaddReceiver(newConnect*net.TCPConn) {
for {
byteMsg :=make([]byte, 2048)
len, err :=newConnect.Read(byteMsg) // 从newConnect中读取信息到缓存中iferr!=nil {
newConnect.Close()
        }
fmt.Println(string(byteMsg[:len]))
msgBroadcast(byteMsg[:len], newConnect.RemoteAddr().String())
    }
}
// 广播给所有 clientfuncmsgBroadcast(byteMsg []byte, keystring) {
fork, con :=rangeclientMap {
ifk!=key { // 转发消息给当前群聊中，除自身以外的其他用户con.Write(byteMsg)
        }
    }
}
// 初始化funcinitGroupChatServer() {
fmt.Println("服务已启动...")
time.Sleep(1*time.Second)
fmt.Println("等待客户端请求连接...")
golistenClient("127.0.0.1:1801")
select {}
}
funcmain() {
initGroupChatServer()
}

packagemainimport (
"bufio""fmt""net""os")
// 用户名varloginNamestring// 本机连接varselfConnect*net.TCPConn// 读取行文本varreader=bufio.NewReader(os.Stdin)
// 建立连接funcconnect(addrstring) {
tcpAddr, _ :=net.ResolveTCPAddr("tcp", addr) // 使用tcpcon, err :=net.DialTCP("tcp", nil, tcpAddr)  // 拨号：主动向server建立连接selfConnect=coniferr!=nil {
fmt.Println("连接服务器失败")
os.Exit(1)
    }
gomsgSender()
gomsgReceiver()
}
// 消息接收器funcmsgReceiver() {
buff :=make([]byte, 2048)
for {
len, _ :=selfConnect.Read(buff) // 从建立连接的缓冲区读消息fmt.Println(string(buff[:len]))
    }
}
// 消息发送器funcmsgSender() {
for {
bMsg, _, _ :=reader.ReadLine()
bMsg= []byte(loginName+" : "+string(bMsg))
selfConnect.Write(bMsg) // 发消息    }
}
// 初始化funcinitGroupChatClient() {
fmt.Println("请问您怎么称呼？")
bName, _, _ :=reader.ReadLine()
loginName=string(bName)
connect("127.0.0.1:1801")
select {}
}
funcmain() {
initGroupChatClient()
}