使用 Websocket 在 goFiber 上实现实时通信

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《使用 Websocket 在 goFiber 上实现实时通信》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

我尝试通过websocket将执行命令的控制台输出发送到html页面。我没有完全理解这个官方网页上的 gofiber websocket 示例代码。首先，我认为我应该只向客户发送一些虚拟文本。我在 youtube 上观看了一些有关 websocket 的教程，但我仍然不清楚。

我向 ws 包添加了一些回调函数，但我不知道如何发送不同的消息以及客户端如何通过连接 websocket 接收此消息。我分享我的 ws 包和 main.go 代码语句。

package ws

import (
    "log"

    "github.com/gofiber/contrib/websocket"
    "github.com/gofiber/fiber/v2"
)

var wsupgrade = func(c *fiber.ctx) error {

    if websocket.iswebsocketupgrade(c) {
        c.locals("allowed", true)
        return c.next()
    }

    return fiber.errupgraderequired
}

var wswritemessage = func(c *websocket.conn) {

    var (
            mt  int
            msg []byte
            err error
        )
        for {
            if mt, msg, err = c.readmessage(); err != nil {
                log.println("read:", err)
                break
            }
            log.printf("recv: %s", msg)

            if err = c.writemessage(mt, msg); err != nil {
                log.println("write:", err)
                break
            }
        }
}

package main

import (
    "fiber-app/pkg/ws"

    "github.com/gofiber/contrib/websocket"
    "github.com/gofiber/fiber/v2"
    "github.com/gofiber/template/html/v2"
)

func main() {

    engine := html.New("./views", ".html")
    appconf := fiber.Config{Views: engine}

    app := fiber.New(appconf)

    app.Static("/", "./public")

    app.Use("/ws", ws.WsUpgrade)

    app.Get("/ws/progress/:id", websocket.New(ws.WsWriteMessage))

    app.Listen(":5000")
}

当我在浏览器上请求时 (ws://machine-ip:5000/ws/progress/123)，浏览器响应为“无法访问此站点”。

正确答案

服务器端代码块没有任何错误的表述。我应该在客户端添加 websocket 侦听器。我无法发送任何消息，因为客户端没有监听服务器。我在浏览器控制台上应用了以下语句，它起作用了。

// Create WebSocket connection.
const ws = new WebSocket("ws://hostip:5000");

// Connection opened
ws.addEventListener("open", (event) => {
  ws.send("Hello Server!");
});

// Listen for messages
ws.addEventListener("message", (event) => {
  console.log("Message from server ", event.data);
});

现在，我应该开始编写客户端代码。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《使用 Websocket 在 goFiber 上实现实时通信》文章吧，也可关注golang学习网公众号了解相关技术文章。