当前位置：首页 > 文章列表 > Golang > Go问答 > JS在重复连接Go-socket.io服务器的客户端连接

JS在重复连接Go-socket.io服务器的客户端连接

来源：stackoverflow 2024-02-12 22:00:24 0浏览收藏

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《JS在重复连接Go-socket.io服务器的客户端连接》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

问题内容

我正在尝试实现一些websocket服务，因为我使用gin作为web框架，所以我选择go-socket.io。我运行 go-socket.io 的 cors 示例。服务器端代码如下：

package main

import (
    "log"
    "net/http"

    "github.com/gin-gonic/gin"

    socketio "github.com/googollee/go-socket.io"
)

func ginmiddleware(alloworigin string) gin.handlerfunc {
    return func(c *gin.context) {
        c.writer.header().set("access-control-allow-origin", alloworigin)
        c.writer.header().set("access-control-allow-credentials", "true")
        c.writer.header().set("access-control-allow-methods", "post, options, get, put, delete")
        c.writer.header().set("access-control-allow-headers", "accept, authorization, content-type, content-length, x-csrf-token, token, session, origin, host, connection, accept-encoding, accept-language, x-requested-with")

        if c.request.method == http.methodoptions {
            c.abortwithstatus(http.statusnocontent)
            return
        }

        c.request.header.del("origin")

        c.next()
    }
}

func main() {
    router := gin.new()

    server := socketio.newserver(nil)

    server.onconnect("/", func(s socketio.conn) error {
        s.setcontext("")
        log.println("connected:", s.id())
        s.emit("reply", "hello world")
        return nil
    })

    server.onevent("/", "notice", func(s socketio.conn, msg string) {
        log.println("notice:", msg)
        s.emit("reply", "have "+msg)
    })

    server.onevent("/chat", "msg", func(s socketio.conn, msg string) string {
        s.setcontext(msg)
        return "recv " + msg
    })

    server.onevent("/", "bye", func(s socketio.conn) string {
        last := s.context().(string)
        s.emit("bye", last)
        s.close()
        return last
    })

    server.onerror("/", func(s socketio.conn, e error) {
        log.println("meet error:", e)
    })

    server.ondisconnect("/", func(s socketio.conn, msg string) {
        log.println("closed", msg)
        log.println("why????")
    })

    go func() {
        if err := server.serve(); err != nil {
            log.fatalf("socketio listen error: %s\n", err)
        }
    }()
    defer server.close()

    router.use(ginmiddleware("*"))
    router.get("/socket.io/*any", gin.wraph(server))
    router.post("/socket.io/*any", gin.wraph(server))
    router.staticfs("/public", http.dir("../asset"))

    if err := router.run(":8000"); err != nil {
        log.fatal("failed run app: ", err)
    }
}

我用js编写了一个html作为客户端：

<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <meta http-equiv="X-UA-Compatible" content="ie=edge" />
    <title>Go WebSocket Tutorial</title>
  </head>
  <body>
    <h2>Hello World2</h2>

    <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/1.4.0/socket.io.js"></script>
    <script>
            var socket = io.connect("http://localhost:8000/socket.io/",{ transports: ["websocket"], pingInterval: 60000  });  

           socket.on('news', function (data) {
               console.log(data.hello);
                socket.emit('my new event', { my:'new data' });/
            });  
            socket.on('other', function (data) {
                console.log(data.hello);  
                socket.emit('event1', { my:'other data' });  
            }); 
            socket.on("connect_error", (error) => {
                // ...
                console.log("err:", error)
            });
            socket.on("disconnect", (reason) => {
                if (reason === "io server disconnect") {
                    // the disconnection was initiated by the server, you need to reconnect manually
                    // socket.connect();
                }
                // else the socket will automatically try to reconnect
                console.log("reason:", reason)
            });
            socket.emit("notice", "my_notice")
        
    </script>
  </body>
</html>

但我反复重新连接。从开发工具来看，它似乎连接到服务器，然后关闭连接，并保持这种行为。