千家信息网

golang如何实现websocket聊天室功能

发表于:2025-02-19 作者:千家信息网编辑
千家信息网最后更新 2025年02月19日,这篇文章将为大家详细讲解有关golang如何实现websocket聊天室功能,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。基本原理:1.引入了 golang.org
千家信息网最后更新 2025年02月19日golang如何实现websocket聊天室功能

这篇文章将为大家详细讲解有关golang如何实现websocket聊天室功能,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

基本原理:
1.引入了 golang.org/x/net/websocket 包。
2.监听端口。
3.客户端连接时,发送结构体: {"type":"login","uid":"我是用户名","msg":"登陆成功"}' .服务端根据login信息,维护一个map,用来存放不同用户的连接体。
4.有用户发言时,将msg内容轮询发给给一个用户。
5.客户端使用js websocket功能,当作客户端,开始聊天。
不足之处:只是根据客户端传的uid来区分用户,没有进行身份校验,不过对一个demo来说,也没必要。

server代码:

package main import (        "encoding/json"        "fmt"        "golang.org/x/net/websocket"        "log"        "net/http") //ProxyConfig 配置type MsgConfig struct {        Type string `json:"type,omitempty"`        Uid  string `json:"uid,omitempty"`        Msg  string `json:"msg,omitempty"`} var connMap = make(map[string]*websocket.Conn) func Echo(ws *websocket.Conn) {        var err error        for {                var reply string                 if err = websocket.Message.Receive(ws, &reply); err != nil {                        fmt.Println("Can't receive")                        break                }                replyMsg := MsgConfig{}                json.Unmarshal([]byte(reply), &replyMsg)                 if replyMsg.Type == "login" && replyMsg.Uid != "" {                        connMap[replyMsg.Uid] = ws                        fmt.Println(connMap)                }                for k, v := range connMap {                        go sendMessage(replyMsg, v, k)                }         }} func sendMessage(replyMsg MsgConfig, conn *websocket.Conn, connUid string) {        msg := replyMsg.Uid + "说:" + replyMsg.Msg        if connUid == replyMsg.Uid {                fmt.Println(msg)                if replyMsg.Type == "login" {                        msg = "登陆成功"                } else {                        msg = "你说:" + replyMsg.Msg                }         }        if err := websocket.Message.Send(conn, msg); err != nil {                fmt.Println("Can't send")        } }func main() {         http.Handle("/", websocket.Handler(Echo))         if err := http.ListenAndServe(":1234", nil); err != nil {                log.Fatal("ListenAndServe:", err)        }}

客户端聊天:
可以在浏览器的控制台里面输入以下代码,进行聊天:
//ip:port设置成自己的

ws = new WebSocket("ws://127.0.0.1:1234");ws.onopen = function (ev) {        ws.send('{"type":"login","uid":"我是用户名","msg":"我登陆了"}');    };ws.onmessage = function (ev) {        if (ev.data){            console.log(ev.data)        }};//下面这句可以多次发送,当作是聊天。ws.send('{"type":"msg","uid":"我是用户名","msg":"你好啊"}');

客户端效果图:

服务器效果图:

关于"golang如何实现websocket聊天室功能"这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

用户 客户 客户端 功能 用户名 篇文章 登陆 聊天室 成功 代码 内容 效果 效果图 更多 服务 不同 不错 实用 必要 你好 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 做软件开发的怎么获客 系统集成和软件开发的区别 如何通过ibmc配置服务器 护苗网络安全课堂4 济南职业学院网络技术技能考试 国防科技大学网络安全博士 软件开发合同追加预算 关于科技互联网的新闻报道 数据库应用技术和dsp 安徽天使网络技术有限公司 电力企业信息网络安全现状 网络安全教育新模式 mysql实现跨服务器复制表 互联网科技公司服务理念 介绍自己设计的数据库设计大作业 国家实行网络安全保密制度 软件开发培训的口碑 数据库的时间格式为 网络安全名言5字 宣州区专业软件开发服务解决方案 方舟手游非专用服务器人数 三级网络安全标准 win7能当服务器吗 长城网际 网络安全 软件开发有业务部吗 干软件开发能干到多少年龄 数据库备份怎么导入苹果手机 介绍自己设计的数据库设计大作业 中小学学生网络安全教育 显示无法连接到服务器什么情况
0