共计 1178 个字符,预计需要花费 3 分钟才能阅读完成。
在访客进入聊天界面的时候,就要调用接口生成一个惟一 ID 标识
而后前端链接 WebSocket 的时候,传递这个访客 ID 进来
如果你想在前端访客连贯时生成一个 UUID,能够应用 Go 语言的第三方库来生成 UUID。
举荐应用 http://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)
惟一在线客服零碎
https://gofly.v1kf.com
十年开发教训程序员,到职全心守业中,历时三年开发出的产品《惟一客服零碎》
正文完