Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
Golang简单聊天室系统开发实战_创想鸟

Golang简单聊天室系统开发实战

答案是使用Golang基于TCP实现聊天室,利用goroutine处理并发连接,服务端通过map维护客户端并广播消息,客户端通过双goroutine实现收发。

golang简单聊天室系统开发实战

用Golang开发一个简单的聊天室系统,核心在于利用其轻量级的goroutine和高效的网络编程能力。整个系统可以基于TCP协议实现,服务端负责管理客户端连接、消息广播,客户端则用于发送和接收消息。下面从结构设计到代码实现一步步带你完成这个小项目。

系统架构与基本流程

这个聊天室采用C/S(客户端-服务器)模式:

服务器监听指定端口,等待客户端连接 每个客户端连接后,启动一个独立的goroutine处理读写 服务器维护所有活跃连接,并在收到消息时广播给其他客户端 支持用户上线通知、下线提示和群发消息

关键点是使用goroutine + channel + net包来实现并发处理,避免阻塞。

服务端实现逻辑

服务端主要功能包括:监听端口、接受连接、注册用户、广播消息、处理断开连接。

立即学习“go语言免费学习笔记(深入)”;

定义全局map保存客户端连接,配合互斥锁保证并发安全:

// 客户端集合
var clients = make(map[net.Conn]string)
var mutex sync.Mutex

主函数中启动监听:

listener, _ := net.Listen(“tcp”, “:8080”)
defer listener.Close()
fmt.Println(“服务器已启动,监听 :8080…”)

循环接受连接,每来一个客户端就开启一个goroutine:

for {
  conn, _ := listener.Accept()
  go handleClient(conn)
}

handleClient函数负责读取用户名、注册、监听消息并广播:

func handleClient(conn net.Conn) {
  // 读取用户名
  buffer := make([]byte, 1024)
  n, _ := conn.Read(buffer)
  username := string(buffer[:n-1]) // 去掉换行
  mutex.Lock()
  clients[conn] = username
  mutex.Unlock()
  broadcast(fmt.Sprintf(“%s 加入聊天n”, username), conn)  // 持续读取消息
  for {
    n, err := conn.Read(buffer)
    if err != nil { break }
    msg := string(buffer[:n])
    broadcast(username+”: “+msg, conn)
  }  // 断开处理
  mutex.Lock()
  delete(clients, conn)
  mutex.Unlock()
  broadcast(fmt.Sprintf(“%s 离开聊天n”, username), conn)
  conn.Close()
}

广播函数遍历所有客户端连接,跳过消息来源:

func broadcast(message string, sender net.Conn) {
  mutex.Lock()
  defer mutex.Unlock()
  for conn := range clients {
    if conn != sender {
      conn.Write([]byte(message))
    }
  }
}

客户端实现要点

客户端相对简单,只需要连接服务器、先发送用户名、再开启两个goroutine分别处理输入和接收消息。

连接服务器:

conn, _ := net.Dial(“tcp”, “127.0.0.1:8080”)

先输入用户名并发送:

fmt.Print(“请输入用户名: “)
scanner := bufio.NewScanner(os.Stdin)
scanner.Scan()
username := scanner.Text()
conn.Write([]byte(username + “n”))

开启两个协程:

一个持续读取控制台输入并发送到服务端 另一个持续读取服务端广播的消息并打印go func() {
  for scanner.Scan() {
    conn.Write([]byte(scanner.Text() + “n”))
  }
}()go func() {
  buf := make([]byte, 1024)
  for {
    n, err := conn.Read(buf)
    if err != nil { return }
    fmt.Print(string(buf[:n]))
  }
}()

保持主函数不退出:

select{}

运行与测试

编译运行server.go启动服务端,再打开多个终端运行client.go,输入不同用户名即可进入聊天室。任意客户端发送消息,其他人都能实时看到。

可优化方向:

加入私聊功能(通过命令如 /msg user hello) 增加在线用户列表显示 使用JSON格式传输数据提升扩展性 添加心跳机制检测连接状态

基本上就这些。Golang的并发模型让这种网络服务写起来非常直观,几段代码就能跑通一个可用的聊天室原型。

以上就是Golang简单聊天室系统开发实战的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1409783.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
Go 程序执行时 “permission denied” 错误排查与解决
上一篇 2025年12月16日 02:46:18
如何使用Golang处理云原生事件驱动
下一篇 2025年12月16日 02:46:33

相关推荐

  • 为什么iPhoneSE2022屏幕无响应如何强制重启?快速按音量键后长按电源键

    首先尝试强制重启,若无效则检查充电状态,最后可通过恢复模式重装系统。具体为:1. 按音量+、音量-后长按电源键10秒以上;2. 充电15分钟观察是否响应;3. 连电脑进入恢复模式恢复系统。 如果您尝试唤醒或操作您的iPhone SE(2022款),但屏幕无响应或显示黑屏,可能是系统临时卡死或软件冲突…

    2026年9月21日
    000
  • 如何在Java中实现个人财务管理工具

    首先设计Transaction、FinanceManager和Budget核心类,实现交易记录、统计分析与预算控制功能,通过ArrayList管理数据,使用LocalDate处理日期,结合ObjectOutputStream持久化存储,初期采用Scanner构建控制台菜单实现增删查改与报表展示,后期…

    2026年9月21日
    000
  • VSCode的代码折叠功能好用吗?

    VSCode代码折叠功能支持多种方式:点击箭头、快捷键、命令面板及按区域类型折叠;可自定义基于缩进的折叠、默认层级和提示装饰器;集成语言服务后能智能识别JSX、Vue组件等结构,提升大型文件编辑效率。 VSCode 的代码折叠功能非常实用,尤其在处理大型文件或复杂结构时能显著提升阅读和编辑效率。 支…

    2026年9月21日
    100
  • X旗下Grok上线即时语音搜索,挑战Google引领搜索新方向

    近日,x平台旗下的ai助手grok正式推出了“即时语音搜索”功能。用户现在可以通过语音直接提问,触发实时网页检索,并迅速获得整合后的精准答案。此举意在优化信息获取流程,推动人机交互向更自然、高效的方向演进。 该语音搜索模式实现了“即说即搜即答”的流畅体验。例如,当用户提出“星舰发射的具体时间是什么?…

    2026年9月21日
    100
  • 如何备份VSCode的全部设置和扩展?

    备份VSCode全部设置和扩展需保存配置文件与扩展目录;2. 配置文件位于各系统指定路径的User文件夹内,包含settings.json和keybindings.json;3. 通过code –list-extensions导出扩展列表并用xargs批量重装可恢复扩展;4. 推荐直接复…

    2026年9月21日
    000
  • Laravel 8 登录后重定向到仪表盘的全面指南

    本文深入探讨了 Laravel 8 中用户登录后重定向到仪表盘的多种策略。我们将详细解析默认的重定向机制,包括 LoginController 和 RedirectIfAuthenticated 中间件,并重点介绍如何通过自定义登录逻辑实现精确的重定向控制,同时提供示例代码和常见问题排查建议,确保用…

    2026年9月21日
    000
  • Guava Multimap:高效获取并打印指定键的所有关联值

    guava multimap是处理一键多值映射关系的强大工具。要获取特定键的所有关联值,应直接使用其提供的`multimap#get(k)`方法。该方法会返回一个包含所有匹配值的`collection`,即使键不存在,也会返回一个空集合而非`null`,从而简化了值检索和空值处理逻辑,是比手动迭代键…

    2026年9月21日
    000
  • Windows10提示“远程过程调用失败”怎么办_Windows10RPC远程过程调用失败修复方法

    首先检查并启动RPC相关服务,确保Remote Procedure Call (RPC)和DCOM Server Process Launcher设为自动并运行;其次临时关闭防火墙和杀毒软件以排除网络通信阻断;接着使用sfc /scannow和DISM命令修复系统文件;最后确认网络适配器中TCP/I…

    2026年9月21日
    000
  • 怎样配置VSCode与Jest、Cypress等测试框架进行集成测试?

    首先安装Jest和Cypress插件及依赖,配置jest.config.js和.vscode/settings.json实现Jest自动运行,再通过launch.json添加Cypress调试配置,最后在package.json中定义统一脚本命令,使两者在VSCode中高效协同工作。 要在 VSCo…

    2026年9月21日
    000
  • mac怎么阻止特定app访问网络_Mac阻止应用访问网络方法

    可通过系统防火墙、hosts文件、第三方工具或pf防火墙阻止应用联网。首先,macOS内置防火墙可阻断入站连接,需在“系统设置-网络-防火墙”中添加应用并启用阻止;其次,编辑/etc/hosts文件,将目标域名指向127.0.0.1可屏蔽其网络访问,需刷新DNS缓存生效;再者,使用Little Sn…

    2026年9月21日
    000
  • VSCode的括号匹配功能如何自定义?

    可通过 settings.json 自定义括号高亮的边框和背景色;2. 用 editor.matchBrackets 控制是否启用高亮;3. 启用 bracketPairColorization 可为嵌套括号着色;4. 使用 Ctrl/Cmd + Shift + 快速跳转配对括号。 VSCode 的…

    2026年9月21日
    000
  • JSF应用中Markdown文档动态链接处理指南

    本教程旨在解决jsf web应用程序中集成markdown文档时,如何动态处理内部链接以实现页面局部更新的问题。通过结合服务器端markdown渲染和客户端javascript事件监听,我们可以拦截markdown生成的html链接点击事件,利用ajax异步加载并渲染目标markdown文件,从而在…

    2026年9月21日
    500
  • mysql如何理解数据压缩

    MySQL数据压缩通过减少存储空间提升I/O效率,主要在InnoDB引擎中实现页级压缩,使用zlib算法对BLOB、TEXT等大字段表压缩效果显著,需设置ROW_FORMAT=COMPRESSED和KEY_BLOCK_SIZE;压缩可降低磁盘使用并加速全表扫描,但增加CPU开销,频繁更新可能导致页分…

    2026年9月21日
    000
  • windows10如何使用资源监视器查看网络和磁盘活动_windows10资源监视器使用方法

    资源监视器可精确定位Windows 10系统中导致网络延迟或磁盘响应缓慢的高占用进程,通过“网络”和“磁盘”选项卡实时监控各进程的流量、连接、读写速度及响应时间,帮助识别异常程序并分析性能瓶颈。 如果您发现Windows 10系统网络延迟或磁盘响应缓慢,可能是某些进程在后台大量占用资源。资源监视器能…

    2026年9月21日
    100
  • edge浏览器如何安装Chrome网上应用店的扩展_edge浏览器安装Chrome扩展方法

    答案:可通过四种方法在Edge浏览器中安装Chrome扩展。1、直接从Chrome网上应用店添加扩展,Edge会自动识别并安装;2、手动下载CRX或ZIP文件,通过开启开发者模式加载已解压的扩展程序;3、从Crx4Chrome等第三方平台下载兼容扩展并按手动方式安装;4、对扩展的manifest.j…

    2026年9月21日
    000
  • 《哈迪斯2》95分年度必玩!外媒锐评”独立游戏崛起”

    《哈迪斯2》95分年度必玩!外媒锐评”独立游戏崛起”《哈迪斯2》95分年度必玩!外媒锐评”独立游戏崛起”《哈迪斯2》95分年度必玩!外媒锐评”独立游戏崛起”《哈迪斯2》95分年度必玩!外媒锐评”独立游戏崛起”

    外媒comicbook报道,2025年是游戏界的辉煌之年,多款新作在metacritic上评分突破90分,并获得“必玩”徽章。 《哈迪斯2》以95分的成绩成为本年度评分最高的游戏,强势领跑年度最佳游戏(GOTY)的激烈竞争,独立游戏的全面崛起也成为今年最瞩目的行业亮点。 《哈迪斯2》:95分封神,战…

    2026年9月21日 用户投稿
    100
  • VSCode的快捷键映射冲突怎么办?

    首先查看快捷键绑定情况,通过Ctrl+K再Ctrl+S打开键盘快捷方式界面,搜索目标键组合如Ctrl+Shift+P,查看并识别冲突命令;接着右键冲突命令选择“更改键绑定”设置新组合或删除多余绑定;为精确定位,可查看命令ID如workbench.action.quickOpen区分相似命令;若调整较…

    2026年9月21日
    000
  • 在Java中如何创建一个天气查询小应用

    注册OpenWeatherMap获取API密钥;2. 使用Java 11+的HttpClient发送HTTP请求;3. 构造带城市参数的URL并调用天气接口;4. 解析返回的JSON数据提取温度和天气描述;5. 在控制台输出结果,支持中文城市需URL编码。 在Java中创建一个天气查询小应用,核心是…

    2026年9月21日
    000
  • 如何自定义代码的格式化规则?

    自定义代码格式化规则需选择合适工具并配置文件实现统一风格。1. 根据语言选用主流工具如Prettier、Black、clang-format等;2. 在项目根目录创建对应配置文件如.prettierrc、.eslintrc.js或pyproject.toml,定义缩进、引号、行宽等规则;3. 将配置…

    2026年9月21日
    100
  • mysql如何设置自动重连

    答案:通过连接配置、连接池和应用层逻辑实现MySQL自动重连。启用MYSQL_OPT_RECONNECT选项(旧版本),推荐使用连接池如PooledDB、HikariCP并配置ping机制,应用层捕获连接异常后重试,结合指数退避策略提升稳定性。 MySQL 客户端或应用程序在连接断开后无法自动恢复,…

    2026年9月21日
    100

发表回复

登录后才能评论
关注微信