最近有WSQ庫解決了通過 websocket 連接與 NSQ 通信的任務。

它允許在 Websocket 和 NSQ 端分別定義消息編碼/解碼邏輯。此外，WSQ 支持注入認證和授權邏輯，控制用戶訂閱和發布主題的權限，以及基于消息內容的傳入消息過濾。

創建 WSQ 服務器示例：

// Create the default config

wsqConfig := wsq.NewConfig()

// Configure Websocket CheckOrigin callback to bypass any checks.

// Don't do it in production!

wsqConfig.SetWSCheckOrigin(wsq.CheckOriginBypass)

// Create the server instance specifying message and user types to use.

server := wsq.NewServer[message, *wsq.AnonymousUser](

    // Address (optional) and port to listen on

    ":9980",

    // WSQ Config instance

    wsqConfig,

    // NSQ Config instance

    nsq.NewConfig(),

    // WSQ Transformer struct providing encoders/decoders for NSQ and Websocket sides respectivly

    &wsq.Transformer[message]{NSQEnDec: &nsqEnDec{}, WSEnDec: &wsEnDec{}},

    // Authentication controller

    &wsq.NoAuthentication,

)

server.Run()