如何用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润色让你的文字更专业

