在访客进入聊天界面的时候,就要调用接口生成一个唯一ID标识
然后前端链接WebSocket的时候,传递这个访客ID进来
如果你想在前端访客连接时生成一个 UUID,可以使用 Go 语言的第三方库来生成 UUID。
推荐使用 github.com/satori/go.uuid 库。它是一个简单易用的 UUID 生成库,支持生成常用的几种 UUID 版本。
例如,你可以使用下面的代码生成一个 UUID V4:
package main import ( "fmt" "github.com/satori/go.uuid" ) func main() { u := uuid.NewV4() fmt.Printf("UUID: %s\n", u) }
在进入界面的时候,调用接口,接口中生成好访客ID,然后带着访客ID GET请求链接WebSocket
package main import ( "net/http" "github.com/gin-gonic/gin" "github.com/gin-gonic/websocket" ) var upgrader = websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true }, } // 定义一个全局的 map 类型变量来保存连接 var connections = make(map[string]*websocket.Conn) func main() { r := gin.Default() r.GET("/ws", func(c *gin.Context) { conn, err := upgrader.Upgrade(c.Writer, c.Request, nil) if err != nil { http.NotFound(c.Writer, c.Request) return } // 获取访客 ID visitorID := c.Query("visitor_id") // 将连接保存到全局变量中 connections[visitorID] = conn for { // 读取消息 _, message, err := conn.ReadMessage() if err != nil { delete(connections, visitorID) break } // 发送消息 err = conn.WriteMessage(websocket.TextMessage, message) if err != nil { delete(connections, visitorID) break } } })
这样就可以在程序的其他地方,拿着访客ID去给指定的访客发送消息,或者使用for循环去广播消息
var connections = make(map[string]*websocket.Conn)
文章评论