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":"你好啊"}');

客户端效果图：

服务器效果图：

摘自https://www.yuanshuli.com/post-60.html

到此这篇关于golang实现一个简单的websocket聊天室的文章就介绍到这了,更多相关golang websocket聊天室内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！