内容简介:基本原理:1.引入了 golang.org/x/net/websocket 包。 如需使用,可能要科学上网。2.监听端口。
基本原理:
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://10.26.27.128: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":"你好啊"}');
客户端效果图:
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- 如何快速实现一个聊天室?
- go语言实现聊天室
- 实现一个简单的WebSocket聊天室
- 用go实现聊天室(WebSocket方式)
- SpringBoot 实战 (十七) | 整合 WebSocket 实现聊天室
- 基于django channel 实现websocket的聊天室
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。