山东省建设建设协会网站织梦网站修改

山东省建设建设协会网站,织梦网站修改,教育机构如何引流与推广,设计制作的基本步骤是哪四个最近再写一个Go TCP 网络聊天室#xff0c;服务端有登录、注册功能。 一开始写得很顺#xff0c;功能也都能跑#xff0c;但很快我发现了一个致命问题#xff1a; 当一个客户端在登录/注册时#xff0c;其他客户端居然完全没法操作了。这不是 bug#xff0c;而是我并没有…最近再写一个Go TCP 网络聊天室服务端有登录、注册功能。一开始写得很顺功能也都能跑但很快我发现了一个致命问题当一个客户端在登录/注册时其他客户端居然完全没法操作了。这不是 bug而是我并没有真正理解 goroutine 的使用场景。一.理所当然却错误的服务端写法先来看一个非常符合新手直觉的TCP服务端结构listener, _ : net.Listen(tcp, :8888) for { conn, _ : listener.Accept() handleConn(conn) }然后在handleConn里面func handleConn(conn net.Conn) { for { msg : readMsg(conn) if msg.Type login { doLogin(conn) } if msg.Type register { doRegister(conn) } } }当时并没有考虑到 :当一个用户进行登录注册,在阻塞的时候,其他的客户端并不能自然向下进行二.问题的本质关键点就在于: **Accept()**后面的逻辑如果不并发,那么整个服务器就是串行的我原本的程序逻辑实际上是这样的接收连接A →处理A的登录(阻塞) →A没有处理完 →B永远等不到处理机会而登录/注册的阻塞有很多种:conn.Read()可能因为网络问题阻塞密码验证用户输入慢,失败重试–只要有一个人在输入密码,后面所有人陪着等数据库访问聊天室中,不止是聊天需要并发,登录注册同样需要三.修改方案给每个连接都启动一个goroutinefor { conn, err : listener.Accept() if err ! nil { continue } go handleConn(conn) }这样修改完之后,整体的逻辑就变成了这样:主 goroutine:只负责 Accept 新连接 | |-- goroutine #1 → 客户端 A登录 |-- goroutine #2 → 客户端 B聊天 |-- goroutine #3 → 客户端 C注册 |-- goroutine #4 → 客户端 D登录四.goroutine在聊天室中的真实分工连接 goroutinego handleConn(conn) // 一个客户端一个goroutine // 生命周期 连接生命周期读写解耦 goroutinego readLoop(conn) go writeLoop(conn) // 读写不阻塞,写不影响读登录注册 goroutinego func() { user : login(conn) loginResultChan - user }() // 登录校验不阻塞消息接收心跳检测/超时踢人 goroutinego func() { ticker : time.NewTicker(30 * time.Second) for range ticker.C { checkAliveUsers() } }() // 定时任务不能阻塞主流程完全可以把这些需要用的放在一个控制整体流程的函数,然后给这个函数起一个协程五.goroutine 带来的第二层问题当你开始大量使用 goroutine很快会遇到这些新问题goroutine 泄露go func() { msg : -ch // 客户端已经断开 }()客户端已经断开,goroutine会永远挂着,造成goroutine泄露解决方案:使用context包管理协程生命周期;连接关闭时 close channel在线用户 map并发读onlineUsers[userID] conn // 并发不安全解决方案: 加锁:sync.Mutex 或者channel 单 goroutine 管理状态3. 广播消息阻塞for _, conn : range conns { conn.Write(msg) // 一个慢客户端拖垮全体 }每个用户一个发送 goroutine;发送channel六.协程相关内容回顾基本概念定义:Go 语言中的轻量级并发执行单元由 Go runtime 调度特点创建成本极低初始栈 ~2KB可动态增长由 Go 调度器而非操作系统线程管理可以同时运行成千上万个 goroutine基本用法:go func() { fmt.Println(Hello, goroutine!) }()goroutine 生命周期1.创建调用 go func() {}2. 可运行等待被调度3. 运行实际在 CPU 上执行4. 阻塞IO、channel、锁等5. 结束完成或被取消阻塞的 goroutine 不占用 OS 线程Go runtime 会调度其他 goroutine 继续执行。goroutine 与线程的关系对象创建成本调度者栈大小OS 线程高操作系统MB 级Goroutine极低Go runtime~2KB可动态增长多个 goroutine 可以共享少量线程由 Go runtime 调度并发 ≠ 并行并发逻辑上同时执行并行物理上同时执行受 CPU 核心限制GMP 调度模型(Go核心原理)G (Goroutine)执行单元M (Machine / OS 线程)执行 G 的实际线程P (Processor)调度器控制可运行 goroutine 队列调度流程:新建 goroutine → 放入 P 的本地队列M 从 P 的队列取 G 执行G 阻塞 → 挂起M 可执行其他 G空闲 P 会“工作窃取”其他 P 的队列并行度由 runtime.GOMAXPROCS(n) 控制默认等于 CPU 核心数goroutine 常见问题泄露:goroutine 永远阻塞未退出解决context close(channel) 检查阻塞点main goroutine提前退出,所有的子 goroutine 会被强制结束解决: 阻塞 mainWaitGroup / select / channel闭包变量捕获陷阱for i : 0; i 3; i { go func() { fmt.Println(i) }() // ❌ go func(i int) { fmt.Println(i) }(i) // ✅ }channel 阻塞:发送方满,接收方空时阻塞解决:缓冲 channel / 超时 / 丢弃策略无限创建 goroutine:容易OOM解决:控制数量 / worker poolOOM 是 Out Of Memory 的缩写,表示系统内存被占满;Go runtime会抛出panic,程序崩掉典型表现:fatal error: runtime: out of memorygoroutine使用建议原则凡是可能阻塞的逻辑都用 goroutine 隔离。不要滥用短小、非阻塞、一次性操作不必 goroutine。确保退出路径每个 goroutine 都应能被取消或结束。通信首选 channel共享状态用锁或单 goroutine 管理。以上是本人在学习过程中遇到的困难和疑惑希望这些分享可以帮到你也希望得到你的指导和建议。