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代码：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 | 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设置成自己的
1 2 3 4 5 6 7 8 9 10 11 12 | 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":"你好啊"}'); |
客户端效果图：
服务器效果图：
摘自https://www.yuanshuli.com/post-60.html
到此这篇关于golang实现一个简单的websocket聊天室的文章就介绍到这了
原文链接：https://www.cnblogs.com/urmkhaos/p/15364033.html