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 服务器实现的详细内容,更多请关注每日运维网(www.mryunwei.com)其它相关文章!