前言

实践是检验真理的唯一标准

正文

如何将Gin框架的后端与WebSocket服务写在一起, 以达到共用一个端口的情况呢?
我们来看单纯使用 net 包和 WS 结合

  1. package main
  2. import (
  3. "flag"
  4. "fmt"
  5. "log"
  6. "net/http"
  7. "github.com/gorilla/websocket"
  8. )
  9. var addr = flag.String("addr", "localhost:8080", "http service address")
  10. var upgrader = websocket.Upgrader{
  11. // 解决跨域问题
  12. CheckOrigin: func(r *http.Request) bool {
  13. return true
  14. },
  15. } // use default options
  16. func ws(w http.ResponseWriter, r *http.Request) {
  17. c, err := upgrader.Upgrade(w, r, nil)
  18. if err != nil {
  19. log.Print("upgrade:", err)
  20. return
  21. }
  22. defer c.Close()
  23. for {
  24. mt, message, err := c.ReadMessage()
  25. if err != nil {
  26. log.Println("read:", err)
  27. break
  28. }
  29. log.Printf("recv: %s", message)
  30. err = c.WriteMessage(mt, message)
  31. if err != nil {
  32. log.Println("write:", err)
  33. break
  34. }
  35. }
  36. }
  37. func main() {
  38. flag.Parse()
  39. log.SetFlags(0)
  40. http.HandleFunc("/ws", ws)
  41. fmt.Println(*addr)
  42. log.Fatal(http.ListenAndServe(*addr, nil))
  43. }

其实本质来说, WS服务在握手的过程中最开始也是HTTP请求, 然后再 Upgrade 到WS模式的, Upgrade函数接受三个参数, 一个是返回值套接字, 一个是请求套接字, 一个是返回值的头, 而对于 Gin 的上下文 gin.Context 来说也是有这些数据的, 因此我们修改成

  1. package control
  2. import (
  3. "log"
  4. "net/http"
  5. "github.com/gin-gonic/gin"
  6. "github.com/gorilla/websocket"
  7. )
  8. var upgrader = websocket.Upgrader{
  9. // 解决跨域问题
  10. CheckOrigin: func(r *http.Request) bool {
  11. return true
  12. },
  13. } // use default options
  14. func cmdWebSocket(c *gin.Context) {
  15. ws, err := upgrader.Upgrade(c.Writer, c.Request, nil)
  16. if err != nil {
  17. log.Print("upgrade:", err)
  18. return
  19. }
  20. defer ws.Close()
  21. for {
  22. mt, message, err := ws.ReadMessage()
  23. if err != nil {
  24. log.Println("read:", err)
  25. break
  26. }
  27. log.Printf("recv: %s", message)
  28. err = ws.WriteMessage(mt, message)
  29. if err != nil {
  30. log.Println("write:", err)
  31. break
  32. }
  33. }
  34. }

即可
————————————————
作者:ChnMig
出处:https://www.cnblogs.com/chnmig/p/14463837.html