快捷導(dǎo)航

golang實(shí)現(xiàn)一個(gè)簡單的websocket聊天室功能

更新時(shí)間：2021年10月04日 09:03:33 作者：CNBLOG

這篇文章主要介紹了golang實(shí)現(xiàn)一個(gè)簡單的websocket聊天室功能,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

基本原理：
1.引入了 golang.org/x/net/websocket 包。
2.監(jiān)聽端口。
3.客戶端連接時(shí)，發(fā)送結(jié)構(gòu)體： {"type":"login","uid":"我是用戶名","msg":"登陸成功"}' .服務(wù)端根據(jù)login信息，維護(hù)一個(gè)map，用來存放不同用戶的連接體。
4.有用戶發(fā)言時(shí)，將msg內(nèi)容輪詢發(fā)給給一個(gè)用戶。
5.客戶端使用js websocket功能，當(dāng)作客戶端，開始聊天。
不足之處：只是根據(jù)客戶端傳的uid來區(qū)分用戶，沒有進(jìn)行身份校驗(yàn)，不過對一個(gè)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)
	}
}

客戶端聊天：
可以在瀏覽器的控制臺里面輸入以下代碼，進(jìn)行聊天：
//ip:port設(shè)置成自己的

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)
        }
};

//下面這句可以多次發(fā)送，當(dāng)作是聊天。
ws.send('{"type":"msg","uid":"我是用戶名","msg":"你好啊"}');

客戶端效果圖：