Golang实现的聊天程序服务端和客户端代码分享

            return
        }
        sUid := string(data[0:c])

        //转成int类型
        uid, _ := strconv.Atoi(sUid)
        if uid < 1 {
            continue
        }
        curUid = uid
        talkChan[uid] = make(chan string)
        //fmt.Println(conn, "have set uid ", uid, "can talk")

        _, err = conn.Write([]byte("have set uid "+sUid+" can talk"))
        if err != nil {
            return
        }
        break
    }

    fmt.Println("err 3")

    //当前所有的连接
    fmt.Println(talkChan)

    //读取客户端传过来的数据
    go func() {
        for {
            //不停的读客户端传过来的数据
            data := make([]byte, 1024)
            c, err := conn.Read(data)
            if err != nil {
                fmt.Println("have no client write", err)
                closed <- true //这里可以使用 | 因为是用用的go 新开的线程去处理的。 |  即便chan阻塞，后面的也会执行去读 closed 这个chan
            }

            clientString := string(data[0:c])

            //将客户端过来的数据，写到相应的chan里
            if curUid == 3 {
                talkChan[4] <- clientString
            } else {
                talkChan[3] <- clientString
            }