Go/Fiber中WebSocket连接的GET处理器触发机制是什么？

示例代码 #

app.Use("/ws", func(c *fiber.Ctx) error {
    // IsWebSocketUpgrade returns true if the client
    // requested upgrade to the WebSocket protocol.
    if websocket.IsWebSocketUpgrade(c) {
        return c.Next()
    }
    return fiber.ErrUpgradeRequired
})
// Websocket handler
app.Get("/ws/:id", websocket.New(func(ws *websocket.Conn) {
    handler.MediaStreamHandler(ws)
}))

疑问与解答 #

核心疑问

这段代码中app.Use的作用很明确：校验客户端的WebSocket升级请求，符合条件才允许继续，否则返回升级要求错误。但app.Get的触发逻辑、连接状态的持久化方式让人困惑：

• 谁会触发app.Get执行？
• WebSocket连接如何在app.Use和app.Get之间保持状态？
• 是否需要客户端主动请求/ws/:id才能启动实时消息接收？

解答

1. app.Get的触发条件
   完全依赖客户端主动请求：客户端必须向/ws/:id发起HTTP GET请求，同时在请求头中携带WebSocket升级所需的字段（如Upgrade: websocket、Connection: Upgrade），才会触发这个端点的处理逻辑。

2. 中间件与端点的执行流程
   当客户端请求/ws/:id时，Fiber会按顺序执行匹配的中间件和端点：

   • 先执行app.Use("/ws", ...)中间件：检查请求是否符合WebSocket升级标准，符合则调用c.Next()将请求传递给后续的app.Get端点；不符合则直接返回fiber.ErrUpgradeRequired，终止请求。
   • 接着执行app.Get端点：websocket.New会完成HTTP到WebSocket的协议升级，创建出*websocket.Conn实例，后续的实时消息收发都通过这个实例完成。

3. 连接状态的持久化方式
   WebSocket连接状态并不存在于app实例中，而是由升级后的*websocket.Conn实例持有：

   • 协议升级完成后，连接脱离了普通HTTP请求的生命周期，进入双向通信阶段；
   • 中间件和端点共享同一请求上下文，直到升级完成后，连接的状态完全由Conn实例维护，和app实例无关。

4. 拆分中间件与端点的意义
   这种写法是为了复用升级校验逻辑：如果后续新增其他WebSocket端点（如/ws/chat），只要路径前缀是/ws，就会自动经过该中间件的校验，无需重复编写升级检查代码。

内容的提问来源于stack exchange，提问作者Kode Charlie