如何用Golang实现TCP聊天程序_Golang网络编程入门实战

发布时间 - 2026-01-28 00:00:00    点击率:
net.Conn不能直接复用在多个goroutine中读写,因其底层读写缓冲区不并发安全;正确做法是读写分离、channel通信,并配合适当超时与连接管理。

为什么 net.Conn 不能直接复用在多个 goroutine 中读写

很多人一上来就用同一个 conn 在两个 goroutine 里分别 conn.Read()conn.Write(),结果发现消息乱序、阻塞、甚至 panic。根本原因是 net.Conn 的底层读写缓冲区不保证并发安全——Read()Write() 都会操作连接的内核 socket 缓冲区,没有内置锁或序列化机制。

正确做法是:一个 goroutine 专责读(处理输入),另一个专责写(发送输出),中间用 channel 通信。例如:

go func() {
    buf := make([]byte, 1024)
    for {
        n, err := conn.Read(buf)
        if err != nil {
            return
        }
        msg := string(buf[:n])
        inputCh <- msg // 发给主逻辑或广播协程
    }
}()
  • 不要在读 goroutine 中直接调用 conn.Write(),否则可能和写 goroutine 冲突
  • 如果需要响应式回写(比如 echo),把应答内容发到写 channel,由写 goroutine 统一发出
  • conn.SetReadDeadline() 必须在每次 Read() 前设置,否则超时只生效一次

如何让服务端支持多客户端并广播消息

关键不是“怎么 accept”,而是“怎么管理活跃连接”。常见错误是把所有 conn 存进全局 slice 然后遍历 Write(),但没考虑连接已断开、写阻塞、或并发修改 slice 导致 panic。

推荐用 map + 互斥锁 + 心跳检测组合:

var (
    clients = make(map[*net.Conn]bool)
    mu      sync.RWMutex
)
  • 每次 accept 后启动读/写 goroutine,并把 &conn 加入 clients(加写锁)
  • 读 goroutine 收到 io.EOF 或其他错误时,从 clients 删除该连接(加写锁)
  • 广播前用 mu.RLock() 遍历,对每个 conn 尝试非阻塞写(建议设 SetWriteDeadline 防卡死)
  • 避免在广播循环中做耗时操作(如格式化字符串),提前准备好字节切片

bufio.Scanner 为什么在 TCP 聊天里容易丢消息

bufio.Scanner 默认以换行符分隔,适合终端输入,但不适合网络聊天:客户端可能不发 \n(比如 telnet 手动输入后按 Ctrl+D)、或者一次性发多条带 \n 的消息,导致 scanner 一次扫出多条,或因缓冲区满被截断。

  • 生产环境更推荐用 bufio.Reader.ReadString('\n') 或直接 conn.Read() + 自定义分包逻辑
  • 如果坚持用 Scanner,必须调大缓冲区:scanner.Buffer(make([]byte, 4096), 65536)
  • 永远检查 scanner.Err(),而不仅是 scanner.Scan() 返回值;Err() 可能是 io.EOF(正常断开)也可能是 bufio.ErrTooLong(丢包信号)
  • 不要用 scanner.Text() 直接拼接日志,它返回的是内部缓冲区引用,下次 Scan() 会覆盖内存

客户端如何优雅退出并通知服务端

Ctrl+C 杀进程时,TCP 连接不会立刻通知服务端,服务端要等 keepalive 或下一次读才感知断开——这期间用户已退出,但服务端还留着“僵尸连接

”。

  • 客户端退出前主动写一条协议消息(如 "QUIT\n"),再 conn.Close()
  • 服务端读到该消息后立即清理连接,避免等待超时
  • 服务端可配 SetKeepAlive(true)SetKeepAlivePeriod(30 * time.Second) 加速探测死链
  • 注意:Windows 对 SO_KEEPALIVE 行为较保守,Linux 更敏感;跨平台建议仍以应用层心跳为主

真正麻烦的从来不是“怎么连上”,而是“怎么确认对方还活着、有没有听清、听清了又有没有执行”。TCP 提供可靠传输,不提供可靠语义——聊天程序的边界,往往卡在协议设计那层。


# linux  # go  # windows  # golang  # 字节  # win  # 网络编程  # 为什么  # echo  # EOF  # 字符串  # 循环  # 切片  # map  # 并发  # channel  # 服务端  # 客户端  # 多个  # 遍历  # 多条  # 复用  # 的是  # 很多人  # 又有  # 而不 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Win11关机界面怎么改_Win11自定义关机画面设置【工具】  javascript日期怎么处理_如何格式化输出  如何在IIS中新建站点并配置端口与物理路径?  javascript中对象的定义、使用以及对象和原型链操作小结  晋江文学城电脑版官网 晋江文学城网页版直接进入  微信公众帐号开发教程之图文消息全攻略  西安专业网站制作公司有哪些,陕西省建行官方网站?  Laravel怎么在Blade中安全地输出原始HTML内容  Win11怎么设置虚拟桌面 Win11新建多桌面切换操作【技巧】  Laravel Facade的原理是什么_深入理解Laravel门面及其工作机制  Laravel中Service Container是做什么的_Laravel服务容器与依赖注入核心概念解析  韩国代理服务器如何选?解析IP设置技巧与跨境访问优化指南  大连企业网站制作公司,大连2025企业社保缴费网上缴费流程?  jQuery中的100个技巧汇总  如何快速打造个性化非模板自助建站?  Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】  iOS验证手机号的正则表达式  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做?  php在windows下怎么调试_phpwindows环境调试操作说明【操作】  Laravel怎么集成Log日志记录_Laravel单文件与每日日志配置及自定义通道【详解】  Laravel怎么在Controller之外的地方验证数据  Laravel怎么实现模型属性转换Casting_Laravel自动将JSON字段转为数组【技巧】  php后缀怎么变mp4格式错误_修改扩展名提示格式不对怎么办【技巧】  利用 Google AI 进行 YouTube 视频 SEO 描述优化  详解vue.js组件化开发实践  js实现获取鼠标当前的位置  如何快速搭建高效香港服务器网站?  如何用虚拟主机快速搭建网站?详细步骤解析  香港服务器网站卡顿?如何解决网络延迟与负载问题?  nginx修改上传文件大小限制的方法  Laravel如何实现邮件验证激活账户_Laravel内置MustVerifyEmail接口配置【步骤】  Laravel如何实现邮箱地址验证功能_Laravel邮件验证流程与配置  Laravel观察者模式如何使用_Laravel Model Observer配置  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  如何在景安服务器上快速搭建个人网站?  制作旅游网站html,怎样注册旅游网站?  php485函数参数是什么意思_php485各参数详细说明【介绍】  如何用JavaScript实现文本编辑器_光标和选区怎么处理  在线ppt制作网站有哪些软件,如何把网页的内容做成ppt?  Chrome浏览器标签页分组怎么用_谷歌浏览器整理标签页技巧【效率】  北京的网站制作公司有哪些,哪个视频网站最好?  Laravel如何正确地在控制器和模型之间分配逻辑_Laravel代码职责分离与架构建议  Laravel如何处理JSON字段的查询和更新_Laravel JSON列操作与查询技巧  Laravel如何实现多语言支持_Laravel本地化与国际化(i18n)配置教程  Laravel怎么上传文件_Laravel图片上传及存储配置  EditPlus中的正则表达式 实战(4)  1688铺货到淘宝怎么操作 1688一键铺货到自己店铺详细步骤  网站图片在线制作软件,怎么在图片上做链接?  Laravel如何使用Telescope进行调试?(安装和使用教程)  简历没回改:利用AI润色让你的文字更专业