使用 x/net 库 trowing 403 的 Websocket 服务器实现-编程学习网

php小编香蕉为您介绍一种使用x/net库的方法，用于实现一个抛出403错误的Websocket服务器。Websocket是一种在客户端和服务器之间建立持久连接的通信协议，而403错误表示服务器拒绝了客户端的请求。通过使用x/net库，我们可以轻松地创建一个Websocket服务器，并在需要的时候抛出403错误，从而实现对请求的拒绝。这种方法简单有效，适用于需要对请求进行授权或限制访问的场景。

问题内容

我正在尝试使用 x/net/websocket 标准库实现一个 websocket 服务器。

到目前为止我的尝试如下：

package main

import (
    "fmt"
    "net/http"

    "golang.org/x/net/websocket"
)

type Server struct {
    baseUri     string
    connections map[string][]*websocket.Conn
}

func initServer(baseUri string) *Server {
    return &Server{
        baseUri: baseUri,
    }
}

func (server *Server) handleConnections() {
    http.Handle("/ws", websocket.Handler(server.listenConnections))
    http.ListenAndServe(":3000", nil)
}

func (server *Server) listenConnections(ws *websocket.Conn) {
    fmt.Println("New connection established")
    for {
        fmt.Println("FOO")
    }
}

func main() {
    server := initServer("/ws")
    server.handleConnections()
}

尝试使用多个 ws 客户端连接到 ws://localhost:3000/ws 时，我总是收到相同的错误：403-Forbidden。我什至尝试了官方文档的示例，但仍然得到它。我错过了一些明显的东西吗？像默认端口阻塞或类似的吗？

提前谢谢您。

编辑：您可能需要使用不同的端口来重现该问题。在我的示例中使用 3000 ，如果不可用，只会中断程序的执行。

编辑2：您可以使用像websocat这样的客户端并执行 websocat 'ws://localhost:3000/ws' 来尝试连接到服务器

解决方法

我放弃了，但有很好的见解：如果您像我一样正在关注 Anthony GG 的从头开始在 Go 上创建 Websocket 服务器的演练，请不要。视频已经过时了，尽管它提供了如何创建视频的很好的直觉，但最好（并且没有耻辱）使用 gorilla 的 websocket 库进行学习。

package main

import (
    "fmt"
    "net/http"
    "time"

    "github.com/gorilla/mux"
    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

type Server struct {
    baseUri     string
    connections map[string][]*websocket.Conn
    router      *mux.Router
    setup       *http.Server
}

func initServer(baseUri string) *Server {
    router := mux.NewRouter()
    return &Server{
        baseUri: baseUri,
        router:  router,
        setup: &http.Server{
            Handler:      router,
            Addr:         "127.0.0.1:8000",
            WriteTimeout: 15 * time.Second,
            ReadTimeout:  15 * time.Second,
        },
    }
}

func (server *Server) handleConnections() {
    server.router.HandleFunc("/ws/{var}", server.listenConnections)
    server.setup.ListenAndServe()
}

func (server *Server) listenConnections(w http.ResponseWriter, r *http.Request) {
    connection, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        fmt.Println(err)
        return
    }
    for {
        _, message, err := connection.ReadMessage()
        if err != nil {
            break
        }

        connection.WriteMessage(websocket.TextMessage, message)
        go messageHandler(message)
    }
    fmt.Println("Out of loop")
}

func messageHandler(message []byte) {
    fmt.Println(string(message))
}

func main() {
    server := initServer("/ws")
    server.handleConnections()
}

我还使用 gorilla/mux 来使用路径参数（不知道为什么 http 处理程序不能）。请注意我如何将 http.Handle 更改为 mux.Router.HandleFunc。正如用户 @Cerise 在评论中指出的那样，x/net/websocket 包不在标准库中，但仅添加 Origin 标头也没有解决原始问题。

希望这能避免其他像我一样学习 Go 的人遇到的一些麻烦。

以上就是使用 x/net 库 trowing 403 的 Websocket 服务器实现的详细内容，更多请关注编程网其它相关文章！