基本原理：
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":"你好啊"}');
客户端效果图：
服务器效果图：
摘自https://www.yuanshuli.com/post-60.html
到此这篇关于golang实现一个简单的websocket聊天室的文章就介绍到这了,更多相关golang websocket聊天室内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
