91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

golang如何實現websocket聊天室功能

發布時間:2021-10-08 09:41:28 來源:億速云 閱讀:331 作者:小新 欄目:開發技術

這篇文章將為大家詳細講解有關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":"你好啊"}');

客戶端效果圖:

golang如何實現websocket聊天室功能

服務器效果圖:

golang如何實現websocket聊天室功能

關于“golang如何實現websocket聊天室功能”這篇文章就分享到這里了,希望以上內容可以對大家有一定的幫助,使各位可以學到更多知識,如果覺得文章不錯,請把它分享出去讓更多的人看到。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

沙湾县| 南宫市| 东方市| 射洪县| 石狮市| 珠海市| 磴口县| 鲁甸县| 彝良县| 得荣县| 万盛区| 钦州市| 西乌珠穆沁旗| 静乐县| 平湖市| 东方市| 左贡县| 牡丹江市| 宁夏| 承德县| 平果县| 高碑店市| 兴安盟| 铜川市| 清原| 广德县| 仙桃市| 德令哈市| 罗平县| 鄂托克前旗| 泸水县| 东乌珠穆沁旗| 阳东县| 花垣县| 嘉兴市| 都兰县| 封丘县| 三都| 武功县| 宁国市| 崇礼县|